notifier

Documentation

Index

• func AsPayload[T openapi.OwnerDto | openapi.ServiceDto | openapi.RepositoryDto](dto T) openapi.NotificationPayload
• func New(configuration librepo.Configuration, customConfig config.CustomConfiguration, ...) repository.Notifier
• type Impl
  • func (r *Impl) IsNotifier() bool
  • func (r *Impl) PublishCreation(ctx context.Context, name string, payload openapi.NotificationPayload) error
  • func (r *Impl) PublishDeletion(ctx context.Context, name string, payloadType types.NotificationPayloadType)
  • func (r *Impl) PublishModification(ctx context.Context, name string, payload openapi.NotificationPayload) error
  • func (r *Impl) Setup() error
  • func (r *Impl) SetupNotifier(ctx context.Context) error

Functions

func AsPayload

func AsPayload[T openapi.OwnerDto | openapi.ServiceDto | openapi.RepositoryDto](dto T) openapi.NotificationPayload

func New

func New(
	configuration librepo.Configuration,
	customConfig config.CustomConfiguration,
	logging librepo.Logging,
) repository.Notifier

Types

type Impl

type Impl struct {
	Configuration       librepo.Configuration
	CustomConfiguration config.CustomConfiguration
	Logging             librepo.Logging

	Clients   map[string]notifierclient.NotifierClient
	SkipAsync bool // for tests
}

func (*Impl) IsNotifier

func (r *Impl) IsNotifier() bool

func (*Impl) PublishCreation

func (r *Impl) PublishCreation(ctx context.Context, name string, payload openapi.NotificationPayload) error

func (*Impl) PublishDeletion

func (r *Impl) PublishDeletion(ctx context.Context, name string, payloadType types.NotificationPayloadType)

func (*Impl) PublishModification

func (r *Impl) PublishModification(ctx context.Context, name string, payload openapi.NotificationPayload) error

func (*Impl) Setup

func (r *Impl) Setup() error

func (*Impl) SetupNotifier

func (r *Impl) SetupNotifier(ctx context.Context) error