corel

Documentation

Index

• func AttachCorelToHttp(corelid *CoRelationId, req *http.Request)
• func AttachCorelToHttpFromCtx(ctx context.Context, req *http.Request)
• func NewCorelCtx(sessionId string) context.Context
• func NewCorelCtxFromCtx(ctx context.Context, sessionId string) context.Context
• func NewCorelCtxFromRequest(ctx context.Context, sessionId, requestId string) context.Context
• type CoRelationId
  • func GetCorelationId(ctx context.Context) (corelid *CoRelationId, err error)
  • func NewCoRelationId(sessionId string) *CoRelationId
  • func (corelid *CoRelationId) Logrus(f logrus.Fields)
  • func (corelid *CoRelationId) RequestId() string
  • func (corelid *CoRelationId) SessionId() string

Functions

func AttachCorelToHttp

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

func AttachCorelToHttpFromCtx

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

func NewCorelCtx

func NewCorelCtx(sessionId string) context.Context

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

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 GetCorelationId

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

GetCorelationId ...

func NewCoRelationId

func NewCoRelationId(sessionId string) *CoRelationId

todo: do we need this

func (*CoRelationId) Logrus

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

func (*CoRelationId) RequestId

func (corelid *CoRelationId) RequestId() string

func (*CoRelationId) SessionId

func (corelid *CoRelationId) SessionId() string