reqctx

Documentation

Index

• func GetPool[REQ ReqCtx]() sync.Pool
• func GetToken[REQ ReqCtx](r REQ) string
• type Auth
• type AuthInfo
• type AuthInterface
• type Context
  • func FromContextValue[REQ ReqCtx](ctx context.Context) *Context[REQ]
  • func New[REQ ReqCtx](ctx context.Context, req REQ) *Context[REQ]
  • func (c *Context[REQ]) Device() *DeviceInfo
  • func (c *Context[REQ]) Method() string
  • func (c *Context[REQ]) SendHeader(md metadata.MD) error
  • func (c *Context[REQ]) SetCookie(v string) error
  • func (c *Context[REQ]) SetHeader(md metadata.MD) error
  • func (c *Context[REQ]) SetTrailer(md metadata.MD) error
  • func (c *Context[REQ]) StartSpanX(name string, o ...trace.SpanStartOption) (*Context[REQ], trace.Span)
  • func (c *Context[REQ]) Wrapper() context.Context
• type DeviceInfo
  • func Device(infoHeader, area, location, userAgent, ip string) *DeviceInfo
• type ReqCtx
• type ReqValue
• type RequestAt
  • func NewRequestAt() RequestAt
  • func NewRequestAtFromTime(t time.Time) RequestAt
  • func (r *RequestAt) String() string

Functions

func GetPool

func GetPool[REQ ReqCtx]() sync.Pool

func GetToken

func GetToken[REQ ReqCtx](r REQ) string

Types

type Auth

type Auth struct {
	AuthInfoRaw string
	AuthID      string
	AuthInfo
}

type AuthInfo

type AuthInfo interface {
	IdStr() string
}

type AuthInterface

type AuthInterface interface {
	ParseToken(token string, secret []byte) error
}

type Context

type Context[REQ ReqCtx] struct {
	context2.Context
	ReqValue
	ReqCtx REQ
}

func FromContextValue

func FromContextValue[REQ ReqCtx](ctx context.Context) *Context[REQ]

func New

func New[REQ ReqCtx](ctx context.Context, req REQ) *Context[REQ]

func (*Context[REQ]) Device

func (c *Context[REQ]) Device() *DeviceInfo

func (*Context[REQ]) Method

func (c *Context[REQ]) Method() string

func (*Context[REQ]) SendHeader

func (c *Context[REQ]) SendHeader(md metadata.MD) error

func (*Context[REQ]) SetCookie

func (c *Context[REQ]) SetCookie(v string) error

func (*Context[REQ]) SetHeader

func (c *Context[REQ]) SetHeader(md metadata.MD) error

func (*Context[REQ]) SetTrailer

func (c *Context[REQ]) SetTrailer(md metadata.MD) error

func (*Context[REQ]) StartSpanX

func (c *Context[REQ]) StartSpanX(name string, o ...trace.SpanStartOption) (*Context[REQ], trace.Span)

func (*Context[REQ]) Wrapper

func (c *Context[REQ]) Wrapper() context.Context

type DeviceInfo

type DeviceInfo struct {
	//设备
	Device    string  `json:"device" gorm:"size:255"`
	OS        string  `json:"os" gorm:"size:255"`
	AppCode   string  `json:"appCode" gorm:"size:255"`
	AppVer    string  `json:"appVer" gorm:"size:255"`
	IP        string  `json:"ip" gorm:"size:255"`
	Lng       float64 `json:"lng" gorm:"type:numeric(10,6)"`
	Lat       float64 `json:"lat" gorm:"type:numeric(10,6)"`
	Area      string  `json:"area" gorm:"size:255"`
	UserAgent string  `json:"userAgent" gorm:"size:255"`
}

func Device

func Device(infoHeader, area, location, userAgent, ip string) *DeviceInfo

info: device,os,appCode,appVersion area:xxx location:1.23456,2.123456

type ReqCtx

type ReqCtx interface {
	SetHeaders(md http.Header)
	SetHeader(k, v string)
	AddHeader(k, v string)
	GetHeader(k string) string
}

type ReqValue

type ReqValue struct {
	Token string
	Auth

	grpc.ServerTransportStream
	Internal string
	RequestAt
	// contains filtered or unexported fields
}

type RequestAt

type RequestAt struct {
	Time      time.Time
	TimeStamp int64
	// contains filtered or unexported fields
}

func NewRequestAt

func NewRequestAt() RequestAt

func NewRequestAtFromTime

func NewRequestAtFromTime(t time.Time) RequestAt

func (*RequestAt) String

func (r *RequestAt) String() string