actions

type ActionHandler interface {
	Handle(ctx context.Context, data interface{}) error
}

type Config struct {
	PollInterval    time.Duration
	PollTimeout     time.Duration
	AckTimeout      time.Duration
	AckRetriesCount int
	AckRetryWait    time.Duration
	ClusterID       string
}

type Service interface {
	Run(ctx context.Context)
}