external

Documentation

Index

• func ContextWithQueryOptions(ctx context.Context, options structs.QueryOptions) (context.Context, error)
• func ForwardMetadataContext(ctx context.Context) context.Context
• func NewServer(logger agentmiddleware.Logger, metricsObj *metrics.Metrics, ...) *grpc.Server
• func QueryOptionsFromContext(ctx context.Context) (structs.QueryOptions, error)
• func TraceID() string

Functions

func ContextWithQueryOptions

func ContextWithQueryOptions(ctx context.Context, options structs.QueryOptions) (context.Context, error)

ContextWithQueryOptions returns a context with the given query options attached.

func ForwardMetadataContext

func ForwardMetadataContext(ctx context.Context) context.Context

func NewServer

func NewServer(logger agentmiddleware.Logger, metricsObj *metrics.Metrics, tls *tlsutil.Configurator) *grpc.Server

NewServer constructs a gRPC server for the external gRPC port, to which handlers can be registered.

func QueryOptionsFromContext

func QueryOptionsFromContext(ctx context.Context) (structs.QueryOptions, error)

QueryOptionsFromContext returns the query options in the gRPC metadata attached to the given context.

func TraceID

func TraceID() string

We tag logs with a unique identifier to ease debugging. In the future this should probably be a real Open Telemetry trace ID.