subscription

Documentation

Index

• type SubscribeAPI
• type Subscriber
  • func NewSubscriber(awsRegion string, awsEndpoint string, l log.Logger) (*Subscriber, error)
  • func (s *Subscriber) Stop()
  • func (s *Subscriber) Subscribe(nodeId string, secretId string)
• type WatchAPI
• type WatchOption
  • func WithInterval(min, max time.Duration) WatchOption
• type Watcher
  • func NewWatcher(nodeId *string, secretId *string, api aws.SecretsManagerAPI, ...) *Watcher
  • func (w *Watcher) Start()
  • func (w *Watcher) Stop()

Types

type SubscribeAPI

type SubscribeAPI interface {
	Subscribe(nodeId string, secretId string)
	Stop()
}

type Subscriber

type Subscriber struct {
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber(awsRegion string, awsEndpoint string, l log.Logger) (*Subscriber, error)

func (*Subscriber) Stop

func (s *Subscriber) Stop()

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(nodeId string, secretId string)

type WatchAPI

type WatchAPI interface {
	Start()
}

type WatchOption

type WatchOption func(watcher *Watcher)

func WithInterval

func WithInterval(min, max time.Duration) WatchOption

type Watcher

type Watcher struct {
	// contains filtered or unexported fields
}

func NewWatcher

func NewWatcher(nodeId *string, secretId *string, api aws.SecretsManagerAPI, notifyCh chan *tlsV3.Secret, l log.Logger, opts ...WatchOption) *Watcher

func (*Watcher) Start

func (w *Watcher) Start()

func (*Watcher) Stop

func (w *Watcher) Stop()