application

Documentation

Index

• func NewGrep() common.Application
• func NewPost() common.Application
• func NewPublish() common.Application
• func NewReport() common.Application
• type Abstract
  • func (a *Abstract) Close()
  • func (a *Abstract) CloseEvents()
  • func (a *Abstract) Done() <-chan bool
  • func (a *Abstract) FireFinish(event *common.ApplicationEvent, abstractService interface{})
  • func (a *Abstract) FireInit(event *common.ApplicationEvent, abstractService interface{})
  • func (a *Abstract) FireRun(event *common.ApplicationEvent, abstractService interface{})
  • func (a *Abstract) GetConfigData() ([]byte, error, error)
  • func (a *Abstract) Init(_ *common.ApplicationEvent, _ bool)
  • func (a *Abstract) InitChannels(cBufSize int)
  • func (a *Abstract) InitConfig()
  • func (a *Abstract) IsValidConfigFilename(filename string) bool
  • func (a *Abstract) OnEvent(f func(ev *common.ApplicationEvent))
  • func (a *Abstract) Run()
  • func (a *Abstract) RunWithArgs(args ...interface{})
  • func (a *Abstract) SendEvents(ev *common.ApplicationEvent) bool
  • func (a *Abstract) Services() []interface{}
  • func (a *Abstract) SetConfigMeta(configFilename, configRemoteAddr, configUpdateDuration string)
  • func (a *Abstract) SetEvents(events chan *common.ApplicationEvent)
  • func (a *Abstract) Timeout() common.Timeout
• type ConfigMeta
• type FinishFireAction
  • func (f FinishFireAction) Fire(app common.Application, event *common.ApplicationEvent, ...)
  • func (f FinishFireAction) PostFire(app common.Application, event *common.ApplicationEvent)
• type FireAction
• type Grep
  • func (g *Grep) FireRun(event *common.ApplicationEvent, abstractService interface{})
  • func (g *Grep) RunWithArgs(args ...interface{})
• type InitFireAction
  • func (i InitFireAction) Fire(app common.Application, event *common.ApplicationEvent, ...)
  • func (i InitFireAction) PostFire(app common.Application, event *common.ApplicationEvent)
  • func (i InitFireAction) PreFire(app common.Application, event *common.ApplicationEvent)
• type Post
  • func (p *Post) FireFinish(event *common.ApplicationEvent, abstractService interface{})
  • func (p *Post) FireRun(event *common.ApplicationEvent, abstractService interface{})
  • func (p *Post) Init(event *common.ApplicationEvent, soft bool)
  • func (p *Post) Run()
• type PostFireAction
• type PreFireAction
• type Publish
  • func (p *Publish) FireRun(event *common.ApplicationEvent, abstractService interface{})
  • func (p *Publish) RunWithArgs(args ...interface{})
• type ReconfigureFireAction
  • func (r ReconfigureFireAction) Fire(app common.Application, event *common.ApplicationEvent, ...)
  • func (r ReconfigureFireAction) PostFire(app common.Application, event *common.ApplicationEvent)
• type Report
  • func (r *Report) FireRun(event *common.ApplicationEvent, abstractService interface{})
  • func (r *Report) Run()
• type RunFireAction
  • func (r RunFireAction) Fire(app common.Application, event *common.ApplicationEvent, ...)

Functions

func NewGrep

func NewGrep() common.Application

NewGrep создает новое приложение

func NewPost

func NewPost() common.Application

NewPost создает новое приложение

func NewPublish

func NewPublish() common.Application

NewPublish создает новое приложение

func NewReport

func NewReport() common.Application

создает новое приложение

Types

type Abstract

type Abstract struct {
	CommonTimeout common.Timeout `yaml:"timeouts"`
	// contains filtered or unexported fields
}

Abstract базовое приложение

func (*Abstract) Close

func (a *Abstract) Close()

func (*Abstract) CloseEvents

func (a *Abstract) CloseEvents()

CloseEvents close events channel

func (*Abstract) Done

func (a *Abstract) Done() <-chan bool

Done возвращает канал завершения приложения

func (*Abstract) FireFinish

func (a *Abstract) FireFinish(event *common.ApplicationEvent, abstractService interface{})

FireFinish останавливает сервисы приложения

func (*Abstract) FireInit

func (a *Abstract) FireInit(event *common.ApplicationEvent, abstractService interface{})

FireInit инициализирует сервисы

func (*Abstract) FireRun

func (a *Abstract) FireRun(event *common.ApplicationEvent, abstractService interface{})

FireRun запускает сервисы приложения

func (*Abstract) GetConfigData

func (a *Abstract) GetConfigData() ([]byte, error, error)

func (*Abstract) Init

func (a *Abstract) Init(_ *common.ApplicationEvent, _ bool)

Init инициализирует приложение

func (*Abstract) InitChannels

func (a *Abstract) InitChannels(cBufSize int)

InitChannels init channels

func (*Abstract) InitConfig

func (a *Abstract) InitConfig()

func (*Abstract) IsValidConfigFilename

func (a *Abstract) IsValidConfigFilename(filename string) bool

IsValidConfigFilename проверяет валидность пути к файлу с настройками

func (*Abstract) OnEvent

func (a *Abstract) OnEvent(f func(ev *common.ApplicationEvent))

func (*Abstract) Run

func (a *Abstract) Run()

Run запускает приложение

func (*Abstract) RunWithArgs

func (a *Abstract) RunWithArgs(args ...interface{})

RunWithArgs запускает приложение с аргументами

func (*Abstract) SendEvents

func (a *Abstract) SendEvents(ev *common.ApplicationEvent) bool

func (*Abstract) Services

func (a *Abstract) Services() []interface{}

Services возвращает сервисы, используемые приложением

func (*Abstract) SetConfigMeta

func (a *Abstract) SetConfigMeta(configFilename, configRemoteAddr, configUpdateDuration string)

func (*Abstract) SetEvents

func (a *Abstract) SetEvents(events chan *common.ApplicationEvent)

SetEvents устанавливает канал событий приложения

func (*Abstract) Timeout

func (a *Abstract) Timeout() common.Timeout

Timeout возвращает таймауты приложения

type ConfigMeta

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

type FinishFireAction

type FinishFireAction func(*Abstract, *common.ApplicationEvent, interface{})

func (FinishFireAction) Fire

func (f FinishFireAction) Fire(app common.Application, event *common.ApplicationEvent, abstractService interface{})

func (FinishFireAction) PostFire

func (f FinishFireAction) PostFire(app common.Application, event *common.ApplicationEvent)

type FireAction

type FireAction interface {
	Fire(common.Application, *common.ApplicationEvent, interface{})
}

type Grep

type Grep struct {
	Abstract
}

Grep приложение, ищущее логи по адресату или получателю

func (*Grep) FireRun

func (g *Grep) FireRun(event *common.ApplicationEvent, abstractService interface{})

FireRun запускает сервисы приложения

func (*Grep) RunWithArgs

func (g *Grep) RunWithArgs(args ...interface{})

RunWithArgs запускает приложение с аргументами

type InitFireAction

type InitFireAction func(*Abstract, *common.ApplicationEvent, interface{})

func (InitFireAction) Fire

func (i InitFireAction) Fire(app common.Application, event *common.ApplicationEvent, abstractService interface{})

func (InitFireAction) PostFire

func (i InitFireAction) PostFire(app common.Application, event *common.ApplicationEvent)

func (InitFireAction) PreFire

func (i InitFireAction) PreFire(app common.Application, event *common.ApplicationEvent)

type Post

type Post struct {
	Abstract

	// Workers количество отправителей
	Workers int `yaml:"workers"`
}

Post приложение, рассылающее письма

func (*Post) FireFinish

func (p *Post) FireFinish(event *common.ApplicationEvent, abstractService interface{})

FireFinish останавливает сервисы приложения

func (*Post) FireRun

func (p *Post) FireRun(event *common.ApplicationEvent, abstractService interface{})

FireRun запускает сервисы приложения

func (*Post) Init

func (p *Post) Init(event *common.ApplicationEvent, soft bool)

Init инициализирует приложение

func (*Post) Run

func (p *Post) Run()

Run запускает приложение

type PostFireAction

type PostFireAction interface {
	FireAction
	PostFire(common.Application, *common.ApplicationEvent)
}

type PreFireAction

type PreFireAction interface {
	FireAction
	PreFire(common.Application, *common.ApplicationEvent)
}

type Publish

type Publish struct {
	Abstract
}

Publish приложение, перекладывающее письма из очереди в очередь

func (*Publish) FireRun

func (p *Publish) FireRun(event *common.ApplicationEvent, abstractService interface{})

FireRun запускает сервисы приложения

func (*Publish) RunWithArgs

func (p *Publish) RunWithArgs(args ...interface{})

RunWithArgs запускает приложение с аргументами

type ReconfigureFireAction

type ReconfigureFireAction func(*Abstract, *common.ApplicationEvent, interface{})

func (ReconfigureFireAction) Fire

func (r ReconfigureFireAction) Fire(app common.Application, event *common.ApplicationEvent, abstractService interface{})

func (ReconfigureFireAction) PostFire

func (r ReconfigureFireAction) PostFire(app common.Application, event *common.ApplicationEvent)

type Report

type Report struct {
	Abstract
}

приложение, анализирующее неотправленные сообщения

func (*Report) FireRun

func (r *Report) FireRun(event *common.ApplicationEvent, abstractService interface{})

запускает сервисы приложения

func (*Report) Run

func (r *Report) Run()

запускает приложение

type RunFireAction

type RunFireAction func(*Abstract, *common.ApplicationEvent, interface{})

func (RunFireAction) Fire

func (r RunFireAction) Fire(app common.Application, event *common.ApplicationEvent, abstractService interface{})