utils

Mar 15, 2023

Changes in this version

+ func GetContextLogger(ctx context.Context) *zap.Logger

+ func GetContextSpan(ctx context.Context) oteltrace.Span

+ func IsProducerNameExistsError(name string, err error) bool

+ func NewContextWithValues(ctx context.Context, workerName string) context.Context

+ func SetContextConsumer(ctx context.Context, consumer pulsar.Consumer)

+ func SetContextProducer(ctx context.Context, publisher pulsar.Producer)

+ type ContextKey string

+ const Consumer

+ const CurrentSpan

+ const Logger

+ const Producer

+ const Values

+ const WorkerName

+ type ContextValues struct

+ func GetContextValues(ctx context.Context) *ContextValues

+ func (c *ContextValues) Get(key string) string

+ func (c *ContextValues) GetAndDeleteCurrentSpan() oteltrace.Span

+ func (c *ContextValues) GetConsumer() pulsar.Consumer

+ func (c *ContextValues) GetCurrentSpan() oteltrace.Span

+ func (c *ContextValues) GetLogger() *zap.Logger

+ func (c *ContextValues) GetProducer() pulsar.Producer

+ func (c *ContextValues) GetWorkerName() string

+ func (c *ContextValues) Keys() []string

+ func (c *ContextValues) Set(key string, value string)