helper

Documentation

Index

• Constants
• Variables
• func ContextFromMessage(msg *eventbusclient.Message) context.Context
• func GetGormFromContext(ctx context.Context) *gorm.DB
• func GetLogFieldFromMessage(message *eventbusclient.Message) logger.Fields
• func GetMessageFromDelivery(d amqp.Delivery) *eventbusclient.Message
• func GetRedisClientFromContext(ctx context.Context) *redis.Client
• func LoggerFromCtx(ctx context.Context) logger.Entry
• func SetGormToContext(ctx context.Context, dbConn *gorm.DB) context.Context
• func SetRedisClientToContext(ctx context.Context, c *redis.Client) context.Context
• func StartTransactionForEvent(nrApp newrelic.Application, job *eventbusclient.Message) newrelic.Transaction
• func StartTransactionForMessage(nrApp newrelic.Application, m *eventbusclient.Message) newrelic.Transaction

Constants

const (
	EntityIdAttr = "entityId"
	PayloadAttr  = "payload"
)

Variables

var ErrDbEmpty = errors.New("db connection invalid")

var ErrRedisEmpty = errors.New("Redis connection invalid")

var LoggerFactory logger.Factory

Functions

func ContextFromMessage

func ContextFromMessage(msg *eventbusclient.Message) context.Context

Build the context from Message, the context now will have data for logging and tracing

func GetGormFromContext

func GetGormFromContext(ctx context.Context) *gorm.DB

func GetLogFieldFromMessage

func GetLogFieldFromMessage(message *eventbusclient.Message) logger.Fields

From Message data, build the fields needed for logger

func GetMessageFromDelivery

func GetMessageFromDelivery(d amqp.Delivery) *eventbusclient.Message

From rabbitmq delivery data, build the original message

func GetRedisClientFromContext

func GetRedisClientFromContext(ctx context.Context) *redis.Client

func LoggerFromCtx

func LoggerFromCtx(ctx context.Context) logger.Entry

func SetGormToContext

func SetGormToContext(ctx context.Context, dbConn *gorm.DB) context.Context

func SetRedisClientToContext

func SetRedisClientToContext(ctx context.Context, c *redis.Client) context.Context

func StartTransactionForEvent

func StartTransactionForEvent(nrApp newrelic.Application, job *eventbusclient.Message) newrelic.Transaction

func StartTransactionForMessage

func StartTransactionForMessage(nrApp newrelic.Application, m *eventbusclient.Message) newrelic.Transaction