infrastructure

Documentation

Index

• func Log(ctx context.Context, logData *pb_logging.LogData) (*pb_logging.LoggingResult, error)
• type RedisAdapter
  • func NewRedisAdapter(redisClient *tredis.RedisClient) RedisAdapter
  • func (a *RedisAdapter) ConsumeChannel(ctx context.Context, channelName string) *redis.PubSub
  • func (a *RedisAdapter) 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 RedisAdapter

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

func NewRedisAdapter

func NewRedisAdapter(redisClient *tredis.RedisClient) RedisAdapter

func (*RedisAdapter) ConsumeChannel

func (a *RedisAdapter) ConsumeChannel(ctx context.Context, channelName string) *redis.PubSub

ConsumeChannel subscribes the given channel to Redis and returns *redis.PubSub

func (*RedisAdapter) SetLogger

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

SetLogger sets logging call-back function