request

Documentation

Index

• type BaseRequestHandler
  • func NewBaseRequestHandler(cfg engine.Config, rs resource.Resource, stateDb db.Db, userdataDb db.Db, ...) *BaseRequestHandler
  • func (f *BaseRequestHandler) GetConfig() engine.Config
  • func (f *BaseRequestHandler) GetEngine(cfg engine.Config, rs resource.Resource, pr *persist.Persister) engine.Engine
  • func (f *BaseRequestHandler) GetRequestParser() RequestParser
  • func (f *BaseRequestHandler) Output(rqs RequestSession) (RequestSession, error)
  • func (f *BaseRequestHandler) Process(rqs RequestSession) (RequestSession, error)
  • func (f *BaseRequestHandler) Reset(ctx context.Context, rqs RequestSession) (RequestSession, error)
  • func (f *BaseRequestHandler) Shutdown(ctx context.Context)
• type RequestHandler
• type RequestParser
• type RequestSession

Types

type BaseRequestHandler

type BaseRequestHandler struct {
	// contains filtered or unexported fields
}

func NewBaseRequestHandler

func NewBaseRequestHandler(cfg engine.Config, rs resource.Resource, stateDb db.Db, userdataDb db.Db, rp RequestParser, hn entry.EntryHandler) *BaseRequestHandler

func NewBaseRequestHandler(cfg engine.Config, rs resource.Resource, stateDb db.Db, userdataDb db.Db, rp request.RequestParser, hn *handlers.Handlers) *BaseRequestHandler {

func (*BaseRequestHandler) GetConfig

func (f *BaseRequestHandler) GetConfig() engine.Config

func (*BaseRequestHandler) GetEngine

func (f *BaseRequestHandler) GetEngine(cfg engine.Config, rs resource.Resource, pr *persist.Persister) engine.Engine

func (*BaseRequestHandler) GetRequestParser

func (f *BaseRequestHandler) GetRequestParser() RequestParser

func (*BaseRequestHandler) Output

func (f *BaseRequestHandler) Output(rqs RequestSession) (RequestSession, error)

func (*BaseRequestHandler) Process

func (f *BaseRequestHandler) Process(rqs RequestSession) (RequestSession, error)

func (*BaseRequestHandler) Reset

func (f *BaseRequestHandler) Reset(ctx context.Context, rqs RequestSession) (RequestSession, error)

func (*BaseRequestHandler) Shutdown

func (f *BaseRequestHandler) Shutdown(ctx context.Context)

type RequestHandler

type RequestHandler interface {
	GetConfig() engine.Config
	GetRequestParser() RequestParser
	GetEngine(engine.Config, resource.Resource, *persist.Persister) engine.Engine
	Process(RequestSession) (RequestSession, error)
	Output(RequestSession) (RequestSession, error)
	Reset(context.Context, RequestSession) (RequestSession, error)
	Shutdown(ctx context.Context)
}

type RequestParser

type RequestParser interface {
	GetSessionId(context.Context, any) (string, error)
	GetInput(any) ([]byte, error)
}

TODO: seems like can remove this.

type RequestSession

type RequestSession struct {
	Ctx      context.Context
	Config   engine.Config
	Engine   engine.Engine
	Input    []byte
	Storage  *storage.Storage
	Writer   io.Writer
	Continue bool
}