sender

Documentation

Index

• type Config
  • func (c Config) Validate() error
• type Sender
  • func New(processID int, config Config, storage services.Storage, ...) (*Sender, error)
  • func (s *Sender) Start()
  • func (s *Sender) Stop()

Types

type Config

type Config struct {
	// Broker topic name to send event with file process result
	EventTopic string `yaml:"topic" json:"topic"`

	// Number of workers to publish file to storage
	Workers int `yaml:"workers" json:"workers"`

	// Minimum seconds between each collect loop
	CollectDelay int `yaml:"delay" json:"delay"`

	CollectorCfg collector.Config `json:"collect" yaml:"collect"`
}

func (Config) Validate

func (c Config) Validate() error

type Sender

type Sender struct {
	ID int
	// contains filtered or unexported fields
}

func New

func New(
	processID int, config Config, storage services.Storage, fileServer services.FileServer, broker services.Broker,
) (*Sender, error)

func (*Sender) Start

func (s *Sender) Start()

func (*Sender) Stop

func (s *Sender) Stop()