notify

Documentation

Index

• Constants
• Variables
• type Config
• type INotifier
• type Notify
  • func New(cfg *Config) (*Notify, error)
  • func (n *Notify) Queue(_ context.Context, req *protos.NotifyRequest)

Constants

const (
	EmailSubject = "Streamdal Alert"
)

Variables

var (
	ErrMissingStorageService = errors.New("Store cannot be nil")
	ErrMissingShutdownCtx    = errors.New("ShutdownCtx cannot be nil")
)

Types

type Config

type Config struct {
	Store       store.IStore
	ShutdownCtx context.Context
}

type INotifier

type INotifier interface {
	Queue(ctx context.Context, event *protos.NotifyRequest)
}

type Notify

type Notify struct {
	*Config
	// contains filtered or unexported fields
}

func New

func New(cfg *Config) (*Notify, error)

func (*Notify) Queue

func (n *Notify) Queue(_ context.Context, req *protos.NotifyRequest)