webhook

Documentation

Index

• Constants
• type Notifier
  • func NewNotifier(ctx context.Context, eventBatchInterval time.Duration, errHandler func(error)) *Notifier
  • func (s *Notifier) Close() error
  • func (s *Notifier) Trigger(attr scheduler.WebhookAttrs)
  • func (s *Notifier) Worker(ctx context.Context)

Constants

const (
	DefaultEventBatchInterval = time.Second * 10
)

Types

type Notifier

type Notifier struct {
	io.Closer
	// contains filtered or unexported fields
}

func NewNotifier

func NewNotifier(ctx context.Context, eventBatchInterval time.Duration, errHandler func(error)) *Notifier

func (*Notifier) Close

func (s *Notifier) Close() error

func (*Notifier) Trigger

func (s *Notifier) Trigger(attr scheduler.WebhookAttrs)

func (*Notifier) Worker

func (s *Notifier) Worker(ctx context.Context)