correlationid

Documentation

Index

• Constants
• func DefaultGeneratorSource() *generatorSource
• func DefaultMetadataSource() *metadataSource
• func NewGeneratorSource(generator correlationIdGenerator) *generatorSource
• func NewMetadataSource(headers ...string) *metadataSource
• func StreamServerInterceptor(opts ...Option) grpc.StreamServerInterceptor
• func UnaryServerInterceptor(opts ...Option) grpc.UnaryServerInterceptor
• type Option
  • func Source(s ...correlationIdSource) Option
  • func Store(s ...correlationIdStore) Option
  • func WithSource(s ...correlationIdSource) Option
  • func WithStore(s ...correlationIdStore) Option
• type Options

Constants

const TagCorrelationID = "correlationid"

Functions

func DefaultGeneratorSource

func DefaultGeneratorSource() *generatorSource

DefaultGeneratorSource returns a new correlation ID source which generates a new correlation ID. The underlying generator is a default random string generator.

func DefaultMetadataSource

func DefaultMetadataSource() *metadataSource

DefaultMetadataSource returns a correlation ID source which retrieves the correlation ID from gRPC metadata headers.

func NewGeneratorSource

func NewGeneratorSource(generator correlationIdGenerator) *generatorSource

NewGeneratorSource returns a new correlation ID source which generates a new correlation ID.

func NewMetadataSource

func NewMetadataSource(headers ...string) *metadataSource

NewMetadataSource returns a correlation ID source which retrieves the correlation ID from gRPC metadata headers.

func StreamServerInterceptor

func StreamServerInterceptor(opts ...Option) grpc.StreamServerInterceptor

StreamServerInterceptor returns a new streaming server interceptor for propagating correlation ID.

func UnaryServerInterceptor

func UnaryServerInterceptor(opts ...Option) grpc.UnaryServerInterceptor

UnaryServerInterceptor returns a new unary server interceptor for propagating correlation ID.

Types

type Option

type Option interface {
	// contains filtered or unexported methods
}

Option is used to define middleware configuration.

func Source

func Source(s ...correlationIdSource) Option

Source sets a set of correlation ID sources in the middleware.

func Store

func Store(s ...correlationIdStore) Option

Store sets a set of correlation ID stores in the middleware.

func WithSource

func WithSource(s ...correlationIdSource) Option

WithSource appends a set of correlation ID sources in the middleware.

func WithStore

func WithStore(s ...correlationIdStore) Option

WithStore appends a set of correlation ID stores in the middleware.

type Options

type Options []Option

Options is a set of middleware options together.