notifier

Documentation

Index

• type Notifier
  • func New(grpc_endpoint *grpc.ClientConn, opts ...NotifierOption) Notifier
  • func NewWithClient(client api.NotificationsClient, opts ...NotifierOption) Notifier
• type NotifierOption
  • func WithBacklog(b int) NotifierOption
  • func WithConcurrency(c int) NotifierOption

Types

type Notifier

type Notifier interface {
	Send(context.Context, *api.Event)
	QueueSize() int
}

Notifier an interface that will allow us to create different notifier implementations

func New

func New(grpc_endpoint *grpc.ClientConn, opts ...NotifierOption) Notifier

func NewWithClient

func NewWithClient(client api.NotificationsClient, opts ...NotifierOption) Notifier

type NotifierOption

type NotifierOption func(*notifierOptions)

func WithBacklog

func WithBacklog(b int) NotifierOption

WithBacklog returns a NotifierOption which sets how requests are allowed to be queued up at the same time.

func WithConcurrency

func WithConcurrency(c int) NotifierOption

WithConcurrency returns a NotifierOption which sets how many notification requests can be in flight at the same time. The minimum value allowed is 1