notifier

Documentation

Index

• func AsPayload[T openapi.OwnerDto | openapi.ServiceDto | openapi.RepositoryDto](dto T) openapi.NotificationPayload
• func New() auacornapi.Acorn
• type Impl
  • func (r *Impl) AcornName() string
  • func (r *Impl) AssembleAcorn(registry auacornapi.AcornRegistry) error
  • 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(ctx context.Context) error
  • func (r *Impl) SetupAcorn(registry auacornapi.AcornRegistry) error
  • func (r *Impl) TeardownAcorn(registry auacornapi.AcornRegistry) error

Functions

func AsPayload

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

func New

func New() auacornapi.Acorn

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) AcornName

func (r *Impl) AcornName() string

func (*Impl) AssembleAcorn

func (r *Impl) AssembleAcorn(registry auacornapi.AcornRegistry) error

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(ctx context.Context) error

func (*Impl) SetupAcorn

func (r *Impl) SetupAcorn(registry auacornapi.AcornRegistry) error

func (*Impl) TeardownAcorn

func (r *Impl) TeardownAcorn(registry auacornapi.AcornRegistry) error