utils

Documentation

Index

• Constants
• func BackwardTransformIfSystem(key string) string
• func GetContextFromRequest(c *fasthttp.RequestCtx) context.Context
• func PrepareExpirationHeader(ctx context.Context, p *pool.Pool, headers map[string]string, now time.Time) 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 AppParams
• type EpochDurations
  • func GetEpochDurations(ctx context.Context, p *pool.Pool) (*EpochDurations, error)

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, p *pool.Pool, 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 AppParams

type AppParams struct {
	Logger   *zap.Logger
	Pool     *pool.Pool
	Owner    *user.ID
	Resolver *resolver.ContainerResolver
	Cache    *cache.BucketCache
}

type EpochDurations

type EpochDurations struct {
	CurrentEpoch  uint64
	MsPerBlock    int64
	BlockPerEpoch uint64
}

func GetEpochDurations

func GetEpochDurations(ctx context.Context, p *pool.Pool) (*EpochDurations, error)