notifier

Documentation

Index

• type ClientRefresher
• type Notifier
• type Publisher
  • func RefreshClient() (Publisher, error)
• type SNSNotifier
  • func (s *SNSNotifier) Notify(ctx context.Context, message string) error

Types

type ClientRefresher

type ClientRefresher func() (Publisher, error)

type Notifier

type Notifier interface {
	Notify(context.Context, string) error
}

type Publisher

type Publisher interface {
	Publish(
		context.Context,
		*sns.PublishInput,
		...func(*sns.Options)) (*sns.PublishOutput, error)
}

func RefreshClient

func RefreshClient() (Publisher, error)

type SNSNotifier

type SNSNotifier struct {
	Pub           Publisher
	RefreshClient ClientRefresher
	Log           logr.Logger
}

func (*SNSNotifier) Notify

func (s *SNSNotifier) Notify(ctx context.Context, message string) error