Documentation
¶
Index ¶
- type MockEngine
- type MockRequestHandler
- func (m *MockRequestHandler) GetConfig() engine.Config
- func (m *MockRequestHandler) GetEngine(cfg engine.Config, rs resource.Resource, pe *persist.Persister) engine.Engine
- func (m *MockRequestHandler) GetRequestParser() request.RequestParser
- func (m *MockRequestHandler) Output(rs request.RequestSession) (request.RequestSession, error)
- func (m *MockRequestHandler) Process(rqs request.RequestSession) (request.RequestSession, error)
- func (m *MockRequestHandler) Reset(ctx context.Context, rs request.RequestSession) (request.RequestSession, error)
- func (m *MockRequestHandler) Shutdown(ctx context.Context)
- type MockRequestParser
- type MockWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockEngine ¶
type MockEngine struct { InitFunc func(context.Context) (bool, error) ExecFunc func(context.Context, []byte) (bool, error) FlushFunc func(context.Context, io.Writer) (int, error) FinishFunc func(context.Context) error }
MockEngine implements the engine.Engine interface for testing
type MockRequestHandler ¶
type MockRequestHandler struct { ProcessFunc func(request.RequestSession) (request.RequestSession, error) GetConfigFunc func() engine.Config GetEngineFunc func(cfg engine.Config, rs resource.Resource, pe *persist.Persister) engine.Engine OutputFunc func(rs request.RequestSession) (request.RequestSession, error) ResetFunc func(ctx context.Context, rs request.RequestSession) (request.RequestSession, error) ShutdownFunc func(ctx context.Context) GetRequestParserFunc func() request.RequestParser }
MockRequestHandler implements request.RequestHandler interface for testing
func (*MockRequestHandler) GetConfig ¶
func (m *MockRequestHandler) GetConfig() engine.Config
func (*MockRequestHandler) GetRequestParser ¶
func (m *MockRequestHandler) GetRequestParser() request.RequestParser
func (*MockRequestHandler) Output ¶
func (m *MockRequestHandler) Output(rs request.RequestSession) (request.RequestSession, error)
func (*MockRequestHandler) Process ¶
func (m *MockRequestHandler) Process(rqs request.RequestSession) (request.RequestSession, error)
func (*MockRequestHandler) Reset ¶
func (m *MockRequestHandler) Reset(ctx context.Context, rs request.RequestSession) (request.RequestSession, error)
func (*MockRequestHandler) Shutdown ¶
func (m *MockRequestHandler) Shutdown(ctx context.Context)
type MockRequestParser ¶
type MockRequestParser struct { GetSessionIdFunc func(any) (string, error) GetInputFunc func(any) ([]byte, error) }
MockRequestParser implements the handlers.RequestParser interface for testing
func (*MockRequestParser) GetSessionId ¶
type MockWriter ¶
MockWriter implements a mock io.Writer for testing
func (*MockWriter) Header ¶
func (m *MockWriter) Header() http.Header
func (*MockWriter) WriteHeader ¶
func (m *MockWriter) WriteHeader(statusCode int)
func (*MockWriter) WriteString ¶
func (m *MockWriter) WriteString(s string) (n int, err error)
Click to show internal directories.
Click to hide internal directories.