corel

Documentation

Index

• func AttachCorelToHttp(corelid *CoRelationId, req *http.Request)
• func AttachCorelToHttpFromCtx(ctx context.Context, req *http.Request)
• func DecodeCorel(str string, dst interface{}) error
• func EncodeCorel(corelId *CoRelationId) string
• func NewCorelCtx(sessionId string) context.Context
• func NewCorelCtxFromCorel(corelid *CoRelationId) context.Context
• func NewCorelCtxFromCtx(ctx context.Context, sessionId string) context.Context
• func NewCorelCtxFromRequest(ctx context.Context, sessionId, requestId string) context.Context
• type CoRelationId
  • func DecodeCorelationId(encoded string) *CoRelationId
  • func GetCorelationId(ctx context.Context) (corelid *CoRelationId, err error)
  • func (corelid *CoRelationId) Child() *CoRelationId
  • func (corelid *CoRelationId) GetRequestId() string
  • func (corelid *CoRelationId) GetSessionId() string
  • func (corelid *CoRelationId) Logrus(f logrus.Fields)
  • func (corelid *CoRelationId) Sibling() *CoRelationId

Functions

func AttachCorelToHttp

func AttachCorelToHttp(corelid *CoRelationId, req *http.Request)

func AttachCorelToHttpFromCtx

func AttachCorelToHttpFromCtx(ctx context.Context, req *http.Request)

func DecodeCorel

func DecodeCorel(str string, dst interface{}) error

func EncodeCorel

func EncodeCorel(corelId *CoRelationId) string

func NewCorelCtx

func NewCorelCtx(sessionId string) context.Context

This is used when the default context is used to define a new corel

func NewCorelCtxFromCorel

func NewCorelCtxFromCorel(corelid *CoRelationId) context.Context

func NewCorelCtxFromCtx

func NewCorelCtxFromCtx(ctx context.Context, sessionId string) context.Context

This is used to define a new corel on the context

func NewCorelCtxFromRequest

func NewCorelCtxFromRequest(ctx context.Context, sessionId, requestId string) context.Context

Any task consumer will call this method only

Types

type CoRelationId

type CoRelationId struct {
	RequestId string `json:"requestId" header:"request_id"`
	SessionId string `json:"sessionId" header:"session_id"`
	Auth      string `header:"Authorization"`
	JWT       *jwtinfo

	AppRequestId,
	RequestSource string
	// contains filtered or unexported fields
}

CoRelationId correlationData

func DecodeCorelationId

func DecodeCorelationId(encoded string) *CoRelationId

func GetCorelationId

func GetCorelationId(ctx context.Context) (corelid *CoRelationId, err error)

GetCorelationId ...

func (*CoRelationId) Child

func (corelid *CoRelationId) Child() *CoRelationId

func (*CoRelationId) GetRequestId

func (corelid *CoRelationId) GetRequestId() string

func (*CoRelationId) GetSessionId

func (corelid *CoRelationId) GetSessionId() string

func (*CoRelationId) Logrus

func (corelid *CoRelationId) Logrus(f logrus.Fields)

func (*CoRelationId) Sibling

func (corelid *CoRelationId) Sibling() *CoRelationId