fakenotifier

Documentation

Index

• func SendOnNotify(ch chan<- *notifier.NotifyRequest) func(req *notifier.NotifyRequest) (*notifier.NotifyResponse, error)
• type Config
• type Notifier
  • func New(config Config) *Notifier
  • func NotifyWaiter() (*Notifier, <-chan *notifier.NotifyRequest)
  • func (n *Notifier) Configure(ctx context.Context, req *plugin.ConfigureRequest) (*plugin.ConfigureResponse, error)
  • func (n *Notifier) GetPluginInfo(ctx context.Context, req *plugin.GetPluginInfoRequest) (*plugin.GetPluginInfoResponse, error)
  • func (n *Notifier) Notify(ctx context.Context, req *notifier.NotifyRequest) (*notifier.NotifyResponse, error)
  • func (n *Notifier) NotifyAndAdvise(ctx context.Context, req *notifier.NotifyAndAdviseRequest) (*notifier.NotifyAndAdviseResponse, error)

Functions

func SendOnNotify

func SendOnNotify(ch chan<- *notifier.NotifyRequest) func(req *notifier.NotifyRequest) (*notifier.NotifyResponse, error)

Types

type Config

type Config struct {
	OnNotify          func(*notifier.NotifyRequest) (*notifier.NotifyResponse, error)
	OnNotifyAndAdvise func(*notifier.NotifyAndAdviseRequest) (*notifier.NotifyAndAdviseResponse, error)
}

type Notifier

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

func New

func New(config Config) *Notifier

func NotifyWaiter

func NotifyWaiter() (*Notifier, <-chan *notifier.NotifyRequest)

func (*Notifier) Configure

func (n *Notifier) Configure(ctx context.Context, req *plugin.ConfigureRequest) (*plugin.ConfigureResponse, error)

func (*Notifier) GetPluginInfo

func (n *Notifier) GetPluginInfo(ctx context.Context, req *plugin.GetPluginInfoRequest) (*plugin.GetPluginInfoResponse, error)

func (*Notifier) Notify

func (n *Notifier) Notify(ctx context.Context, req *notifier.NotifyRequest) (*notifier.NotifyResponse, error)

func (*Notifier) NotifyAndAdvise

func (n *Notifier) NotifyAndAdvise(ctx context.Context, req *notifier.NotifyAndAdviseRequest) (*notifier.NotifyAndAdviseResponse, error)