emitter

Documentation

Overview

Package emitter defines rotation event notification

Index

• Constants
• type Event
  • func (e *Event) SetNextRun(now time.Time)
• type Service
  • func New(stream *config.Stream) (*Service, error)
  • func (s *Service) Close() error
  • func (s *Service) Emit(event *Event) error
  • func (s *Service) Schedule(event *Event) error

Constants

const (
	//DestPath dest path
	DestPath = "$DestPath"
	//Dest dest location
	Dest = "$Dest"
	//DestName dest simple name
	DestName = "$DestName"
	//TimePath stream create time based path fragment
	TimePath = "$TimePath"
)

Types

type Event

type Event struct {
	Config  *config.Event
	Created time.Time
	URL     string
	// contains filtered or unexported fields
}

Event represents an event

func (*Event) SetNextRun

func (e *Event) SetNextRun(now time.Time)

SetNextRun set next run

type Service

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

Service represents emitter service

func New

func New(stream *config.Stream) (*Service, error)

New creates new service

func (*Service) Close

func (s *Service) Close() error

Close closes service

func (*Service) Emit

func (s *Service) Emit(event *Event) error

Emit emits an event

func (*Service) Schedule

func (s *Service) Schedule(event *Event) error

Schedule schedules an event