Documentation ¶
Index ¶
- func GetValueFromContext(ctx context.Context, key ContextKey) interface{}
- func HTTPMemstatsHandler(w http.ResponseWriter, r *http.Request)
- func HTTPRoot(serviceName, buildNumber string) http.HandlerFunc
- func ParseWorkerKeyFromContext(ctx context.Context) []byte
- func SetToContext(ctx context.Context, key ContextKey, value interface{}) context.Context
- type ContextKey
- type ErrorRetrier
- type EventContext
- func (e *EventContext) Context() context.Context
- func (e *EventContext) Err() error
- func (e *EventContext) HandlerRoute() string
- func (e *EventContext) Header() map[string]string
- func (e *EventContext) Key() string
- func (e *EventContext) Message() []byte
- func (e *EventContext) Read(p []byte) (n int, err error)
- func (e *EventContext) SetContext(ctx context.Context)
- func (e *EventContext) SetError(err error)
- func (e *EventContext) SetHandlerRoute(h string)
- func (e *EventContext) SetHeader(header map[string]string)
- func (e *EventContext) SetKey(key string)
- func (e *EventContext) SetWorkerType(w string)
- func (e *EventContext) WorkerType() string
- func (e *EventContext) Write(p []byte) (n int, err error)
- func (e *EventContext) WriteString(s string) (n int, err error)
- type Filter
- type GraphQLErrorResolver
- type Meta
- type PublisherArgument
- type Queue
- type Result
- type SliceResult
- type TokenClaim
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetValueFromContext ¶
func GetValueFromContext(ctx context.Context, key ContextKey) interface{}
GetValueFromContext will get context with specific key
func HTTPMemstatsHandler ¶ added in v1.0.4
func HTTPMemstatsHandler(w http.ResponseWriter, r *http.Request)
HTTPMemstatsHandler calculate runtime statistic
func HTTPRoot ¶ added in v1.0.4
func HTTPRoot(serviceName, buildNumber string) http.HandlerFunc
HTTPRoot http handler
func ParseWorkerKeyFromContext ¶
ParseWorkerKeyFromContext parse token claim from given context
func SetToContext ¶
func SetToContext(ctx context.Context, key ContextKey, value interface{}) context.Context
SetToContext will set context with specific key
Types ¶
type ContextKey ¶
type ContextKey string
ContextKey represent Key of all context
const ( // ContextKeyHTTPHeader context key ContextKeyHTTPHeader ContextKey = "httpHeader" // ContextKeyTaskQueueRetry context key ContextKeyTaskQueueRetry ContextKey = "taskQueueRetry" // ContextKeyTokenClaim context key ContextKeyTokenClaim ContextKey = "tokenClaim" // ContextKeyWorkerKey context key ContextKeyWorkerKey ContextKey = "workerKey" // ContextKeySQLTransaction context key ContextKeySQLTransaction ContextKey = "sqltx" )
type ErrorRetrier ¶ added in v1.0.6
ErrorRetrier task queue worker for retry error with retry count and delay between retry
func (*ErrorRetrier) Error ¶ added in v1.0.6
func (e *ErrorRetrier) Error() string
Error implement error
type EventContext ¶ added in v1.10.0
type EventContext struct {
// contains filtered or unexported fields
}
EventContext worker context in handler
func (*EventContext) Context ¶ added in v1.10.0
func (e *EventContext) Context() context.Context
Context get context
func (*EventContext) HandlerRoute ¶ added in v1.10.0
func (e *EventContext) HandlerRoute() string
HandlerRoute get handler name, contains unique topic name, or task name
func (*EventContext) Header ¶ added in v1.10.0
func (e *EventContext) Header() map[string]string
Header get context
func (*EventContext) Message ¶ added in v1.10.0
func (e *EventContext) Message() []byte
Message get context
func (*EventContext) Read ¶ added in v1.10.0
func (e *EventContext) Read(p []byte) (n int, err error)
Read implement io.Reader
func (*EventContext) SetContext ¶ added in v1.10.0
func (e *EventContext) SetContext(ctx context.Context)
SetContext setter
func (*EventContext) SetError ¶ added in v1.10.0
func (e *EventContext) SetError(err error)
SetError setter
func (*EventContext) SetHandlerRoute ¶ added in v1.10.0
func (e *EventContext) SetHandlerRoute(h string)
SetHandlerRoute setter can contains unique topic name, key, or task name
func (*EventContext) SetHeader ¶ added in v1.10.0
func (e *EventContext) SetHeader(header map[string]string)
SetHeader setter
func (*EventContext) SetKey ¶ added in v1.10.0
func (e *EventContext) SetKey(key string)
SetKey setter
func (*EventContext) SetWorkerType ¶ added in v1.10.0
func (e *EventContext) SetWorkerType(w string)
SetWorkerType setter
func (*EventContext) WorkerType ¶ added in v1.10.0
func (e *EventContext) WorkerType() string
WorkerType get worker type
func (*EventContext) Write ¶ added in v1.10.0
func (e *EventContext) Write(p []byte) (n int, err error)
Write implement io.Writer
func (*EventContext) WriteString ¶ added in v1.10.0
func (e *EventContext) WriteString(s string) (n int, err error)
WriteString method
type Filter ¶
type Filter struct { Limit int `json:"limit" default:"10"` Page int `json:"page" default:"1"` Offset int `json:"-"` Search string `json:"search,omitempty"` OrderBy string `json:"orderBy,omitempty"` Sort string `json:"sort,omitempty" default:"desc" lower:"true"` ShowAll bool `json:"showAll"` AllowEmptyFilter bool `json:"-"` }
Filter data
type GraphQLErrorResolver ¶
GraphQLErrorResolver graphql error with extensions
func NewGraphQLErrorResolver ¶
func NewGraphQLErrorResolver(errMesage string, extensions map[string]interface{}) GraphQLErrorResolver
NewGraphQLErrorResolver constructor
type Meta ¶
type Meta struct { Page int `json:"page"` Limit int `json:"limit"` TotalRecords int `json:"totalRecords"` TotalPages int `json:"totalPages"` }
Meta model
type PublisherArgument ¶
type PublisherArgument struct { // Topic or queue name Topic string Key string Header map[string]interface{} ContentType string // Deprecated : use Message Data interface{} Message []byte }
PublisherArgument declare publisher argument
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue represents a single instance of the queue data structure.
func (*Queue) Peek ¶
Peek returns the element at the head of the queue. This call panics if the queue is empty.
type SliceResult ¶
SliceResult include meta
type TokenClaim ¶
type TokenClaim struct { jwt.StandardClaims Role string Additional interface{} }
TokenClaim for token claim data
func ParseTokenClaimFromContext ¶
func ParseTokenClaimFromContext(ctx context.Context) *TokenClaim
ParseTokenClaimFromContext parse token claim from given context