context

Documentation

Index

• Constants
• func WithReqCtx(ctx context.Context, reqCtx ReqCtx) context.Context
• type ReqCtx
  • func NewReqCtx(engine common.Engine, reqId, clientIp string) (ReqCtx, error)
  • func ValueReqCtx(ctx context.Context) ReqCtx
• type ReqCtxImpl
  • func (t *ReqCtxImpl) Deadline() (deadline time.Time, ok bool)
  • func (t *ReqCtxImpl) Done() <-chan struct{}
  • func (t *ReqCtxImpl) Err() error
  • func (t *ReqCtxImpl) GetClientIp() string
  • func (t *ReqCtxImpl) GetEngine() common.Engine
  • func (t *ReqCtxImpl) GetLog() logs.Logger
  • func (t *ReqCtxImpl) GetTimer() *timer.XTimer
  • func (t *ReqCtxImpl) Value(key interface{}) interface{}

Constants

const (
	ReqCtxKeyName = "reqCtx"
)

Functions

func WithReqCtx

func WithReqCtx(ctx context.Context, reqCtx ReqCtx) context.Context

Types

type ReqCtx

type ReqCtx interface {
	context.Context
	GetEngine() common.Engine
	GetLog() logs.Logger
	GetTimer() *timer.XTimer
	GetClientIp() string
}

请求级别上下文

func NewReqCtx

func NewReqCtx(engine common.Engine, reqId, clientIp string) (ReqCtx, error)

func ValueReqCtx

func ValueReqCtx(ctx context.Context) ReqCtx

type ReqCtxImpl

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

func (*ReqCtxImpl) Deadline

func (t *ReqCtxImpl) Deadline() (deadline time.Time, ok bool)

func (*ReqCtxImpl) Done

func (t *ReqCtxImpl) Done() <-chan struct{}

func (*ReqCtxImpl) Err

func (t *ReqCtxImpl) Err() error

func (*ReqCtxImpl) GetClientIp

func (t *ReqCtxImpl) GetClientIp() string

func (*ReqCtxImpl) GetEngine

func (t *ReqCtxImpl) GetEngine() common.Engine

func (*ReqCtxImpl) GetLog

func (t *ReqCtxImpl) GetLog() logs.Logger

func (*ReqCtxImpl) GetTimer

func (t *ReqCtxImpl) GetTimer() *timer.XTimer

func (*ReqCtxImpl) Value

func (t *ReqCtxImpl) Value(key interface{}) interface{}