common

README

common

Documentation

Index

• Variables
• func GenerateSpanID() string
• func GenerateTraceID() string
• func GetLicenseCiphertext(code string, version string) (string, error)
• func SendNotification(eventSource string, eventType string, eventData any) error
• type APIContext
• type AsmParam
• type ContextKey
• type DalContext
• type EventHandler
• type GlobalThisReader
• type Handler
• type HandlerFunc
  • func (hf HandlerFunc) Process(ctx APIContext) error
• type LicenseHandler
• type PreparedQuery
• type QueryResult
• type RequestContext
• type RequestReader
• type RequestWriter
• type ResponseReader
• type ResponseWriter
• type ScriptRunner

Variables

var ApiCtxKey = ContextKey{}

Functions

func GenerateSpanID

func GenerateSpanID() string

GenerateSpanID generates a 64-bit Span ID

func GenerateTraceID

func GenerateTraceID() string

GenerateTraceID generates a 128-bit Trace ID

func GetLicenseCiphertext

func GetLicenseCiphertext(code string, version string) (string, error)

func SendNotification

func SendNotification(eventSource string, eventType string, eventData any) error

Types

type APIContext

type APIContext interface {
	RequestReader
	ResponseReader
	RequestWriter
	ResponseWriter
}

APIContext combines request and response contexts

type AsmParam

type AsmParam struct {
	Api           string
	Param         []any
	SessionFilter map[string]string
	SessionValues map[string]string
}

type ContextKey

type ContextKey struct{}

type DalContext

type DalContext struct {
	DefaultEntity string
	Container     *sync.Map

	TraceID  string
	ParentID string
	SpanID   string
}

type EventHandler

type EventHandler interface {
	SendNotification(eventSource string, eventType string, eventData any) error
}

var DefaultEventManager EventHandler

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 LicenseHandler

type LicenseHandler interface {
	GetLicenseCiphertext(code string, version string) (string, error)
}

var DefaultLicenseManager LicenseHandler

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 struct {
	ApiName     string
	RemoteAddr  string
	RemoteHost  string
	RequestTime time.Time
}

type RequestReader

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

RequestReader contains request-related information

type RequestWriter

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

RequestWriter allows modification of request-related information

type ResponseReader

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

ResponseReader contains response-related information

type ResponseWriter

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

ResponseWriter allows modification of response-related information

type ScriptRunner

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