common

README

common

Documentation

Index

• Variables
• type APIContext
• type Chain
  • func NewChain() *Chain
  • func (c *Chain) Append(middleware func(Handler) Handler)
  • func (c *Chain) Apply(h Handler) Handler
• type ContextKey
• type DalContext
• type GlobalThisReader
• type Handler
• type HandlerFunc
  • func (hf HandlerFunc) Process(ctx APIContext) error
• type MutableRequestContext
• type MutableResponseContext
• type PreparedQuery
• type QueryResult
• type RequestContext
• type ResponseContext
• type ScriptRunner

Variables

var ApiCtxKey = ContextKey{}

Types

type APIContext

type APIContext interface {
	RequestContext
	ResponseContext
	MutableRequestContext
	MutableResponseContext
}

APIContext combines request and response contexts

type Chain

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

func NewChain

func NewChain() *Chain

func (*Chain) Append

func (c *Chain) Append(middleware func(Handler) Handler)

func (*Chain) Apply

func (c *Chain) Apply(h Handler) Handler

type ContextKey

type ContextKey struct{}

type DalContext

type DalContext struct {
	DefaultEntity string
	Container     *sync.Map

	TraceID  string
	ParentID string
	SpanID   string
}

type GlobalThisReader

type GlobalThisReader interface {
	Input() any
	Env() map[string]any
	Metas() map[string]any
	Session() map[string]any
	RequestHeaders() map[string]any

	Output() any
	ResponseHeaders() map[string]any
}

type Handler

type Handler interface {
	Process(APIContext) error
}

type HandlerFunc

type HandlerFunc func(APIContext) error

func (HandlerFunc) Process

func (hf HandlerFunc) Process(ctx APIContext) error

type MutableRequestContext

type MutableRequestContext interface {
	SetRequestID(string)
	SetMethod(string)
	SetParams(any)
	SetRawParams([]byte)
	SetMetas(map[string]any)
}

MutableRequestContext allows modification of request context

type MutableResponseContext

type MutableResponseContext interface {
	SetResult(any)
	SetErr(error)
}

MutableResponseContext allows modification of response context

type PreparedQuery

type PreparedQuery struct {
	Query     string `json:"query"`
	Bind      []any  `json:"bind"`
	QueryType string `json:"queryType"`

	CheckPoint      []*PreparedQuery `json:"checkPoint"`
	DatabaseUpdater []*PreparedQuery `json:"databaseUpdater"`
	ResultEnricher  []*PreparedQuery `json:"resultEnricher"`
}

type QueryResult

type QueryResult struct {
	QueryType    string
	LastInsertId int64
	RowsAffected int64
	Row          map[string]any
	Rows         []map[string]any
	Total        int64
}

type RequestContext

type RequestContext interface {
	RequestID() string
	Method() string
	Params() any
	RawParams() []byte
	Metas() map[string]any
}

RequestContext contains request-related information

type ResponseContext

type ResponseContext interface {
	Result() any
	Err() error
}

ResponseContext contains response-related information

type ScriptRunner

type ScriptRunner interface {
	RunScript(globalThis map[string]any, dalCtx *DalContext, sourceCode string) (any, error)
}