handler

Oct 21, 2024

Changes in this version

type MockRenderParser

+ func (_m *MockRenderParser) Name() string

type MockRenderParser_Expecter

+ func (_e *MockRenderParser_Expecter) Name() *MockRenderParser_Name_Call

+ type MockRenderParser_Name_Call struct

+ func (_c *MockRenderParser_Name_Call) Return(_a0 string) *MockRenderParser_Name_Call

+ func (_c *MockRenderParser_Name_Call) Run(run func()) *MockRenderParser_Name_Call

+ func (_c *MockRenderParser_Name_Call) RunAndReturn(run func() string) *MockRenderParser_Name_Call

type MockWaitComposer

+ func (_m *MockWaitComposer) Prepare(_a0 context.Context, _a1 string, _a2 Parser) (int64, map[string]interface{}, error)

type MockWaitComposer_Expecter

+ func (_e *MockWaitComposer_Expecter) Prepare(_a0 interface{}, _a1 interface{}, _a2 interface{}) *MockWaitComposer_Prepare_Call

+ type MockWaitComposer_Prepare_Call struct

+ func (_c *MockWaitComposer_Prepare_Call) Return(_a0 int64, _a1 map[string]interface{}, _a2 error) *MockWaitComposer_Prepare_Call

+ func (_c *MockWaitComposer_Prepare_Call) Run(run func(_a0 context.Context, _a1 string, _a2 Parser)) *MockWaitComposer_Prepare_Call

+ func (_c *MockWaitComposer_Prepare_Call) RunAndReturn(...) *MockWaitComposer_Prepare_Call

type RenderParser

+ Name func() string

type WaitComposer

+ Prepare func(context.Context, string, Parser) (int64, map[string]any, error)

Oct 17, 2024

Changes in this version

+ type MockRenderParser struct

+ func NewMockRenderParser(t interface{ ... }) *MockRenderParser

+ func (_m *MockRenderParser) EXPECT() *MockRenderParser_Expecter

+ func (_m *MockRenderParser) Parse(data []byte) (map[string]interface{}, error)

+ func (_m *MockRenderParser) Render(w io.Writer, reqID int64, params map[string]interface{}) error

+ type MockRenderParser_Expecter struct

+ func (_e *MockRenderParser_Expecter) Parse(data interface{}) *MockRenderParser_Parse_Call

+ func (_e *MockRenderParser_Expecter) Render(w interface{}, reqID interface{}, params interface{}) *MockRenderParser_Render_Call

+ type MockRenderParser_Parse_Call struct

+ func (_c *MockRenderParser_Parse_Call) Return(_a0 map[string]interface{}, _a1 error) *MockRenderParser_Parse_Call

+ func (_c *MockRenderParser_Parse_Call) Run(run func(data []byte)) *MockRenderParser_Parse_Call

+ func (_c *MockRenderParser_Parse_Call) RunAndReturn(run func([]byte) (map[string]interface{}, error)) *MockRenderParser_Parse_Call

+ type MockRenderParser_Render_Call struct

+ func (_c *MockRenderParser_Render_Call) Return(_a0 error) *MockRenderParser_Render_Call

+ func (_c *MockRenderParser_Render_Call) Run(run func(w io.Writer, reqID int64, params map[string]interface{})) *MockRenderParser_Render_Call

+ func (_c *MockRenderParser_Render_Call) RunAndReturn(run func(io.Writer, int64, map[string]interface{}) error) *MockRenderParser_Render_Call

+ type MockValidator struct

+ func NewMockValidator(t interface{ ... }) *MockValidator

+ func (_m *MockValidator) EXPECT() *MockValidator_Expecter

+ func (_m *MockValidator) Validate(data map[string]interface{}) error

+ type MockValidator_Expecter struct

+ func (_e *MockValidator_Expecter) Validate(data interface{}) *MockValidator_Validate_Call

+ type MockValidator_Validate_Call struct

+ func (_c *MockValidator_Validate_Call) Return(_a0 error) *MockValidator_Validate_Call

+ func (_c *MockValidator_Validate_Call) Run(run func(data map[string]interface{})) *MockValidator_Validate_Call

+ func (_c *MockValidator_Validate_Call) RunAndReturn(run func(map[string]interface{}) error) *MockValidator_Validate_Call

+ type MockWaitComposer struct

+ func NewMockWaitComposer(t interface{ ... }) *MockWaitComposer

+ func (_m *MockWaitComposer) Compose() (map[string]interface{}, error)

+ func (_m *MockWaitComposer) EXPECT() *MockWaitComposer_Expecter

+ func (_m *MockWaitComposer) Wait(ctx context.Context, parser Parser, respChan <-chan []byte)

+ type MockWaitComposer_Compose_Call struct

+ func (_c *MockWaitComposer_Compose_Call) Return(_a0 map[string]interface{}, _a1 error) *MockWaitComposer_Compose_Call

+ func (_c *MockWaitComposer_Compose_Call) Run(run func()) *MockWaitComposer_Compose_Call

+ func (_c *MockWaitComposer_Compose_Call) RunAndReturn(run func() (map[string]interface{}, error)) *MockWaitComposer_Compose_Call

+ type MockWaitComposer_Expecter struct

+ func (_e *MockWaitComposer_Expecter) Compose() *MockWaitComposer_Compose_Call

+ func (_e *MockWaitComposer_Expecter) Wait(ctx interface{}, parser interface{}, respChan interface{}) *MockWaitComposer_Wait_Call

+ type MockWaitComposer_Wait_Call struct

+ func (_c *MockWaitComposer_Wait_Call) Return() *MockWaitComposer_Wait_Call

+ func (_c *MockWaitComposer_Wait_Call) Run(run func(ctx context.Context, parser Parser, respChan <-chan []byte)) *MockWaitComposer_Wait_Call

+ func (_c *MockWaitComposer_Wait_Call) RunAndReturn(run func(context.Context, Parser, <-chan []byte)) *MockWaitComposer_Wait_Call

Oct 14, 2024

Changes in this version

+ type Handler struct

+ func New(val Validator, proc []RenderParser, composeFactory func() WaitComposer) *Handler

+ func (h *Handler) Handle(ctx context.Context, params map[string]any, watcher core.Waiter, ...) (map[string]any, error)

+ type Parser func([]byte) (map[string]any, error)

+ type RenderParser interface

+ Parse func(data []byte) (map[string]any, error)

+ Render func(w io.Writer, reqID int64, params map[string]any) error

+ type Validator interface

+ Validate func(data map[string]any) error

+ type WaitComposer interface

+ Compose func() (map[string]any, error)

+ Wait func(ctx context.Context, parser Parser, respChan <-chan []byte)