infrastructure

Documentation

Index

• type EBusAdapter
  • func NewEBusAdapter(redisClient *tredis.RedisClient) EBusAdapter
  • func (a EBusAdapter) Listen(ctx context.Context, channelName string, ...)

Types

type EBusAdapter

type EBusAdapter struct {
	// 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, logData me.LogData))

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