notification

Documentation

Index

• Constants
• type Agent
• type Dispatcher
  • func NewNotificationDispatcher(logger *zerolog.Logger) *Dispatcher
  • func (d *Dispatcher) RegisterAgent(agent Agent)
  • func (d *Dispatcher) SendEvent(event Event)
  • func (d *Dispatcher) SendEventAddMovie(name string, item *provider.ListItem, movie *radarr.Movie)
  • func (d *Dispatcher) SendEventEndAllFeeds(approved int, added int)
  • func (d *Dispatcher) SendEventEndFeed(name string, approved int, added int)
  • func (d *Dispatcher) SendEventRevisionMovie(name string, item *provider.ListItem, movie *radarr.Movie)
  • func (d *Dispatcher) SendEventStartFeed(name string)
• type Event
• type EventType
• type WebhookAgent
  • func NewWebhookAgent(url string, events []EventType, logger zerolog.Logger, ...) *WebhookAgent
  • func (a *WebhookAgent) IsSubscribe(eventType EventType) bool
  • func (a *WebhookAgent) SendMessage(event Event, message interface{})

Constants

const (
	START_FEED       = "START_FEED"
	FINISH_FEED      = "FINISH_FEED"
	FINISH_ALL_FEEDS = "FINISH_ALL_FEEDS"
	ADDED_MOVIE      = "ADDED_MOVIE"
	REVISION_MOVIE   = "REVISION_MOVIE"
)

Types

type Agent

type Agent interface {
	SendEvent(event Event)
	Name() string
}

type Dispatcher

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

func NewNotificationDispatcher

func NewNotificationDispatcher(logger *zerolog.Logger) *Dispatcher

func (*Dispatcher) RegisterAgent

func (d *Dispatcher) RegisterAgent(agent Agent)

func (*Dispatcher) SendEvent

func (d *Dispatcher) SendEvent(event Event)

func (*Dispatcher) SendEventAddMovie

func (d *Dispatcher) SendEventAddMovie(name string, item *provider.ListItem, movie *radarr.Movie)

func (*Dispatcher) SendEventEndAllFeeds

func (d *Dispatcher) SendEventEndAllFeeds(approved int, added int)

func (*Dispatcher) SendEventEndFeed

func (d *Dispatcher) SendEventEndFeed(name string, approved int, added int)

func (*Dispatcher) SendEventRevisionMovie

func (d *Dispatcher) SendEventRevisionMovie(name string, item *provider.ListItem, movie *radarr.Movie)

func (*Dispatcher) SendEventStartFeed

func (d *Dispatcher) SendEventStartFeed(name string)

type Event

type Event struct {
	Type EventType
	Data map[string]interface{}
}

type EventType

type EventType string

type WebhookAgent

type WebhookAgent struct {
	Logger zerolog.Logger

	Url string
	// contains filtered or unexported fields
}

func NewWebhookAgent

func NewWebhookAgent(url string, events []EventType, logger zerolog.Logger, restyClient *resty.Client) *WebhookAgent

func (*WebhookAgent) IsSubscribe

func (a *WebhookAgent) IsSubscribe(eventType EventType) bool

func (*WebhookAgent) SendMessage

func (a *WebhookAgent) SendMessage(event Event, message interface{})