deaagent

Documentation

Index

• type Agent
  • func NewAgent(instancesJsonFilePath string, logger *gosteno.Logger) *Agent
  • func (agent *Agent) Start()
  • func (agent *Agent) Stop()
• type TaskListener
  • func NewTaskListener(task domain.Task, logger *gosteno.Logger) (*TaskListener, error)
  • func (tl *TaskListener) StartListening()
  • func (tl *TaskListener) StopListening()
  • func (tl *TaskListener) Task() domain.Task

Types

type Agent

type Agent struct {
	InstancesJsonFilePath string

	sync.WaitGroup
	// contains filtered or unexported fields
}

func NewAgent

func NewAgent(instancesJsonFilePath string, logger *gosteno.Logger) *Agent

func (*Agent) Start

func (agent *Agent) Start()

func (*Agent) Stop

func (agent *Agent) Stop()

type TaskListener

type TaskListener struct {
	*gosteno.Logger

	sync.WaitGroup
	// contains filtered or unexported fields
}

func NewTaskListener

func NewTaskListener(task domain.Task, logger *gosteno.Logger) (*TaskListener, error)

func (*TaskListener) StartListening

func (tl *TaskListener) StartListening()

func (*TaskListener) StopListening

func (tl *TaskListener) StopListening()

func (*TaskListener) Task

func (tl *TaskListener) Task() domain.Task