core

Documentation

Index

• type BasePipe
  • func NewPipe(gOrc Orchestrator) *BasePipe
  • func (p *BasePipe) Add(mw Middleware) *BasePipe
  • func (p *BasePipe) AddIf(mw Middleware, predicate bool) *BasePipe
  • func (p *BasePipe) AddRange(mws []Middleware) *BasePipe
  • func (p *BasePipe) Run(handler Handler, opts ...SetRunOpt) (interface{}, error)
  • func (p *BasePipe) SetOrchestrator(o Orchestrator) *BasePipe
• type Context
  • func NewContext() Context
  • func NewContextWithReq(req *http.Request) Context
• type Handler
• type HttpFileResponse
• type HttpResponse
• type Middleware
  • func NewHandlerMiddleware(handler Handler) Middleware
• type MockMiddleware
  • func (_m *MockMiddleware) Handle(ctx Context) error
  • func (_m *MockMiddleware) Priority() int
  • func (_m *MockMiddleware) SetNext(next Middleware)
• type Orchestrator
• type RawHttpResponse
• type ResponseWriter
• type RunOpt
• type SetRunOpt
  • func WithRunContext(ctx Context) SetRunOpt
• type SpecCodeHttpResponse

Types

type BasePipe

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

func NewPipe

func NewPipe(gOrc Orchestrator) *BasePipe

func (*BasePipe) Add

func (p *BasePipe) Add(mw Middleware) *BasePipe

func (*BasePipe) AddIf

func (p *BasePipe) AddIf(mw Middleware, predicate bool) *BasePipe

func (*BasePipe) AddRange

func (p *BasePipe) AddRange(mws []Middleware) *BasePipe

func (*BasePipe) Run

func (p *BasePipe) Run(handler Handler, opts ...SetRunOpt) (interface{}, error)

func (*BasePipe) SetOrchestrator

func (p *BasePipe) SetOrchestrator(o Orchestrator) *BasePipe

type Context

type Context interface {
	Context() context.Context
	SetContext(context.Context)
	Get(key string) interface{}
	GetString(key string) string
	Set(key string, value interface{})
	SetInput(interface{})
	Input() interface{}
	SetOutput(interface{})
	Output() interface{}
	SetPath(path string)
	Path() string
	Request() *http.Request
	ResponseHeader() http.Header
}

func NewContext

func NewContext() Context

func NewContextWithReq

func NewContextWithReq(req *http.Request) Context

type Handler

type Handler func(ctx Context) (interface{}, error)

type HttpFileResponse

type HttpFileResponse = data.HttpFileResponse

Deprecated: plz use data.HttpFileResponse instead of it

type HttpResponse

type HttpResponse = data.HttpResponse

Deprecated: plz use data.HttpResponse instead of it

type Middleware

type Middleware interface {
	SetNext(next Middleware)
	Handle(ctx Context) error
}

func NewHandlerMiddleware

func NewHandlerMiddleware(handler Handler) Middleware

type MockMiddleware

type MockMiddleware struct {
	mock.Mock
}

MockMiddleware is an autogenerated mock type for the Middleware type

func (*MockMiddleware) Handle

func (_m *MockMiddleware) Handle(ctx Context) error

Handle provides a mock function with given fields: ctx

func (*MockMiddleware) Priority

func (_m *MockMiddleware) Priority() int

Priority provides a mock function with given fields:

func (*MockMiddleware) SetNext

func (_m *MockMiddleware) SetNext(next Middleware)

SetNext provides a mock function with given fields: next

type Orchestrator

type Orchestrator func(mws []Middleware) []Middleware

type RawHttpResponse

type RawHttpResponse = data.RawResponse

Deprecated: plz use data.RawResponse instead of it

type ResponseWriter

type ResponseWriter = data.SpecCodeHttpResponse

Deprecated: plz use data.SpecCodeHttpResponse instead of it

type RunOpt

type RunOpt struct {
	InitContext Context
}

type SetRunOpt

type SetRunOpt func(opt *RunOpt)

func WithRunContext

func WithRunContext(ctx Context) SetRunOpt

type SpecCodeHttpResponse

type SpecCodeHttpResponse = data.SpecCodeResponse

Deprecated: plz use data.SpecCodeResponse instead of it