connectors

Documentation

Index

• type Connector
  • func NewConnector(config *conf.Configuration, clusterDao dao.ClusterDao, ...) *Connector
  • func (c *Connector) CreateAggregateSchedulesPool(buf chan store.ScheduleWrapper)
  • func (c *Connector) CreateStatusUpdatePool(buf chan s.StatusTask)
  • func (c *Connector) InitConnectors(callbackWorkers bool)
  • func (c *Connector) StartScheduleCreateWorkers(tasks <-chan s.CreateScheduleTask)

Types

type Connector

type Connector struct {
	Config      *conf.Configuration
	ClusterDao  dao.ClusterDao
	ScheduleDao dao.ScheduleDao
	HttpClient  *http.Client
	Monitor     monitoring.Monitor
}

Connector represents a component that manages various worker pools for different tasks.

func NewConnector

func NewConnector(config *conf.Configuration, clusterDao dao.ClusterDao, scheduleDAO dao.ScheduleDao, monitor monitoring.Monitor) *Connector

NewConnector creates a new Connector instance with the given configuration, DAOs, and monitoring.

func (*Connector) CreateAggregateSchedulesPool

func (c *Connector) CreateAggregateSchedulesPool(buf chan store.ScheduleWrapper)

create status update work pool

func (*Connector) CreateStatusUpdatePool

func (c *Connector) CreateStatusUpdatePool(buf chan s.StatusTask)

CreateStatusUpdatePool create status update work pool

func (*Connector) InitConnectors

func (c *Connector) InitConnectors(callbackWorkers bool)

InitConnectors initializes all the worker pools managed by the Connector.

func (*Connector) StartScheduleCreateWorkers

func (c *Connector) StartScheduleCreateWorkers(tasks <-chan s.CreateScheduleTask)

Start count number of go routines to listen on the task channel The routines on receiving the messages will create one time schedules.