consumer

Documentation

Index

• type EventConsumer
• type EventConsumerHandler
• type RedisEventConsumer
  • func (adapter RedisEventConsumer) Run(ctx context.Context) error

Types

type EventConsumer

type EventConsumer interface {
	Run(ctx context.Context) error
}

type EventConsumerHandler

type EventConsumerHandler interface {
	Apply(event eventstorming.Event) error
}

type RedisEventConsumer

type RedisEventConsumer struct {
	RedisURL         string
	DBIndex          string
	Password         string
	Group            string
	Consumer         string
	NewMessage       bool
	Foreground       bool
	HandlerConsumers map[string]EventConsumerHandler
	LogFunction      func(functionName string, message string)
}

func (RedisEventConsumer) Run

func (adapter RedisEventConsumer) Run(ctx context.Context) error