utils

Documentation

Index

• Constants
• func BackwardTransformIfSystem(key string) string
• func GetContextFromRequest(c *fasthttp.RequestCtx) context.Context
• func PrepareExpirationHeader(ctx context.Context, epochFetcher EpochInfoFetcher, headers map[string]string, ...) error
• func SetContextToRequest(ctx context.Context, c *fasthttp.RequestCtx)
• func SetHTTPTraceInfo(ctx context.Context, span trace.Span, req *fasthttp.RequestCtx)
• func StartHTTPServerSpan(ctx context.Context, req *fasthttp.RequestCtx, operationName string, ...) (context.Context, trace.Span)
• func TransformIfSystem(key []byte) []byte
• type EpochDurations
• type EpochInfoFetcher

Constants

const (
	UserAttributeHeaderPrefix = "X-Attribute-"
)

Functions

func BackwardTransformIfSystem

func BackwardTransformIfSystem(key string) string

func GetContextFromRequest

func GetContextFromRequest(c *fasthttp.RequestCtx) context.Context

GetContextFromRequest returns main context from fasthttp request context.

func PrepareExpirationHeader

func PrepareExpirationHeader(ctx context.Context, epochFetcher EpochInfoFetcher, headers map[string]string, now time.Time) error

func SetContextToRequest

func SetContextToRequest(ctx context.Context, c *fasthttp.RequestCtx)

SetContextToRequest adds new context to fasthttp request.

func SetHTTPTraceInfo

func SetHTTPTraceInfo(ctx context.Context, span trace.Span, req *fasthttp.RequestCtx)

SetHTTPTraceInfo saves trace headers to response.

func StartHTTPServerSpan

func StartHTTPServerSpan(ctx context.Context, req *fasthttp.RequestCtx, operationName string, opts ...trace.SpanStartOption) (context.Context, trace.Span)

StartHTTPServerSpan starts root HTTP server span.

func TransformIfSystem

func TransformIfSystem(key []byte) []byte

Types

type EpochDurations

type EpochDurations struct {
	CurrentEpoch  uint64
	MsPerBlock    int64
	BlockPerEpoch uint64
}

type EpochInfoFetcher

type EpochInfoFetcher interface {
	GetEpochDurations(context.Context) (*EpochDurations, error)
}