runtime

Documentation

Index

• type Agent
  • func NewAgent(id string, address string, parentAddress string, name string, ...) *Agent
  • func (self *Agent) Add(r *http.Request, conn *websocket.Conn) *ws.Socket
  • func (self *Agent) Listen()
  • func (self *Agent) Logger() *client.LoggerClient
  • func (self *Agent) Remove(socketId string) error
  • func (self *Agent) SendToAgent(agentId string, msg ws.Message) error
  • func (self *Agent) SendToAgents(msg ws.Message) error
  • func (self *Agent) SendToParent(msg ws.Message) error

Types

type Agent

type Agent struct {
	ID            string
	Address       string
	ParentAddress string
	Name          string
	Description   string
	ClientID      string
	ClientSecret  string
	StartedAt     time.Time
	Edges         []models.AgentStat
	// contains filtered or unexported fields
}

func NewAgent

func NewAgent(
	id string,
	address string,
	parentAddress string,
	name string,
	description string,
	clientId string,
	clientSecret string,
	startedAt time.Time,
) *Agent

func (*Agent) Add

func (self *Agent) Add(r *http.Request, conn *websocket.Conn) *ws.Socket

func (*Agent) Listen

func (self *Agent) Listen()

func (*Agent) Logger

func (self *Agent) Logger() *client.LoggerClient

func (*Agent) Remove

func (self *Agent) Remove(socketId string) error

func (*Agent) SendToAgent

func (self *Agent) SendToAgent(agentId string, msg ws.Message) error

func (*Agent) SendToAgents

func (self *Agent) SendToAgents(msg ws.Message) error

func (*Agent) SendToParent

func (self *Agent) SendToParent(msg ws.Message) error