infrastructure

Documentation

Index

• func Log(ctx context.Context, logData *pb_logging.LogData) (*pb_logging.LoggingResult, error)
• type EBusAdapter
  • func NewEBusAdapter(redisClient *tredis.RedisClient) EBusAdapter
  • func (a EBusAdapter) Listen(ctx context.Context, channelName string, ...)
  • func (a *EBusAdapter) SetLogger(...)

Functions

func Log

func Log(ctx context.Context, logData *pb_logging.LogData) (*pb_logging.LoggingResult, error)

Log is the default log function

Types

type EBusAdapter

type EBusAdapter struct {
	Log func(ctx context.Context, logData *pb_logging.LogData) (*pb_logging.LoggingResult, error)
	// contains filtered or unexported fields
}

func NewEBusAdapter

func NewEBusAdapter(redisClient *tredis.RedisClient) EBusAdapter

func (EBusAdapter) Listen

func (a EBusAdapter) Listen(ctx context.Context, channelName string, callBack func(channelName string, data any))

Listen listens to the redis messaging queue and calls the given callBack function for each received any data.

func (*EBusAdapter) SetLogger

func (a *EBusAdapter) SetLogger(LoggerFunc func(ctx context.Context, logData *pb_logging.LogData) (*pb_logging.LoggingResult, error))

SetLogger sets logging call-back function