notify

Documentation

Index

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

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) error
}

type Notification

type Notification struct {
	Req      *protos.NotifyRequest
	Pipeline *protos.Pipeline
	Aud      *protos.Audience
	Configs  []*protos.NotificationConfig
}

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(ctx context.Context, req *protos.NotifyRequest) error