application

Documentation

Index

• func NewGrep() common.Application
• func NewPost() common.Application
• func NewPublish() common.Application
• func NewReport() common.Application
• type Abstract
  • func (a *Abstract) Done() chan bool
  • func (a *Abstract) Events() chan *common.ApplicationEvent
  • 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) Init(event *common.ApplicationEvent)
  • func (a *Abstract) IsValidConfigFilename(filename string) bool
  • func (a *Abstract) Run()
  • func (a *Abstract) RunWithArgs(args ...interface{})
  • func (a *Abstract) Services() []interface{}
  • func (a *Abstract) SetConfigFilename(configFilename string)
  • func (a *Abstract) SetDone(done chan bool)
  • func (a *Abstract) SetEvents(events chan *common.ApplicationEvent)
  • func (a *Abstract) Timeout() common.Timeout
• type Grep
  • func (g *Grep) FireRun(event *common.ApplicationEvent, abstractService interface{})
  • func (g *Grep) RunWithArgs(args ...interface{})
• 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)
  • func (p *Post) Run()
• type Publish
  • func (p *Publish) FireRun(event *common.ApplicationEvent, abstractService interface{})
  • func (p *Publish) RunWithArgs(args ...interface{})
• type Report
  • func (r *Report) FireRun(event *common.ApplicationEvent, abstractService interface{})
  • func (r *Report) Run()

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

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

Types

type Abstract

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

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

func (*Abstract) Done

func (a *Abstract) Done() chan bool

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

func (*Abstract) Events

func (a *Abstract) Events() chan *common.ApplicationEvent

Events возвращает канал событий приложения

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) Init

func (a *Abstract) Init(event *common.ApplicationEvent)

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

func (*Abstract) IsValidConfigFilename

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

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

func (*Abstract) Run

func (a *Abstract) Run()

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

func (*Abstract) RunWithArgs

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

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

func (*Abstract) Services

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

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

func (*Abstract) SetConfigFilename

func (a *Abstract) SetConfigFilename(configFilename string)

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

func (*Abstract) SetDone

func (a *Abstract) SetDone(done chan bool)

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

func (*Abstract) SetEvents

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

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

func (*Abstract) Timeout

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

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

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 Post

type Post struct {
	Abstract

	// количество отправителей
	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)

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

func (*Post) Run

func (p *Post) Run()

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

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 Report

type Report struct {
	Abstract
}

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

func (*Report) FireRun

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

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

func (*Report) Run

func (r *Report) Run()

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