notification

Documentation

Index

• Constants
• func NextID() string
• type EventConsumer
• type Notification
• type NotificationCallback
• type NotificationType
• type Notifier
  • func NewNotifier(callbackFn NotificationCallback) (*Notifier, error)
  • func (n *Notifier) Close() error
  • func (n *Notifier) Notify(notif Notification) error
  • func (n *Notifier) SendSoftRestart(hint string) error
  • func (n *Notifier) Start() error

Constants

const HardRestartMessage = "__hard_restart"

const SoftRestartMessage = "__soft_reload"

Functions

func NextID

func NextID() string

Types

type EventConsumer

type EventConsumer interface {
	Notify(n Notification) error
}

type Notification

type Notification struct {
	ID              string           `json:"id" db:"id"` // snowflake
	Date            time.Time        `json:"createdAt" db:"created_at"`
	ChildProccessID string           `json:"childProcessId" db:"child_process_id"` // snowflake
	Type            NotificationType `json:"type" db:"event_type"`
	Message         string           `json:"message" db:"event_data"`
}

type NotificationCallback

type NotificationCallback func(n Notification) error

type NotificationType

type NotificationType int

const (
	NotificationTypeSystemError NotificationType = iota
	NotificationTypeSoftRestartRequested
	NotificationTypeHardRestartRequested
	NotificationTypeOOBTaskRequested
	NotificationTypeShutdownRequested
	NotificationTypeSystemShutdown
	NotificationTypeStartup
	NotificationTypeHardRestart
	NotificationTypeSoftRestart
	NotificationTypeShutdown
	NotificationTypeLogEvent
	NotificationTypeStdOut
	NotificationTypeStdErr
	NotificationTypeOOBTaskStartup
	NotificationTypeOOBTaskStdOut
	NotificationTypeOOBTaskStdErr
	NotificationTypeIPC
)

type Notifier

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

func NewNotifier

func NewNotifier(callbackFn NotificationCallback) (*Notifier, error)

func (*Notifier) Close

func (n *Notifier) Close() error

func (*Notifier) Notify

func (n *Notifier) Notify(notif Notification) error

func (*Notifier) SendSoftRestart

func (n *Notifier) SendSoftRestart(hint string) error

func (*Notifier) Start

func (n *Notifier) Start() error