subscribe

Documentation

Index

• type Subscriber
  • func NewSubscriber(logger common.Logger, aggregateVotesUseCase *usecases.AggregateVotes, ...) Subscriber
• type SubscriberConfig

Types

type Subscriber

type Subscriber interface {
	Start(ctx context.Context, config SubscriberConfig)
	Shutdown(ctx context.Context)
}

func NewSubscriber

func NewSubscriber(
	logger common.Logger,
	aggregateVotesUseCase *usecases.AggregateVotes,
	hydrateUsersUseCase *usecases.HydrateUsers,
) Subscriber

type SubscriberConfig

type SubscriberConfig struct {
	Group            string
	Consumer         string
	ConnectionString string
	DialTimeout      time.Duration
	MinIdleConns     int
	PoolSize         int
	ReadTimeout      time.Duration
	WriteTimeout     time.Duration
}