agent

Documentation

Index

• Constants
• Variables
• func JSONResponse(w http.ResponseWriter, statusCode int, v interface{})
• func LoadConfig() ([]byte, error)
• type Agent
  • func NewAgent(config *pc.Agent, logger *pct.Logger, client pct.WebsocketClient, addr string, ...) *Agent
  • func (agent *Agent) AllStatus() map[string]string
  • func (agent *Agent) GetAllConfigs() (interface{}, []error)
  • func (agent *Agent) GetConfig() ([]proto.AgentConfig, []error)
  • func (agent *Agent) GetDefaults() (interface{}, []error)
  • func (agent *Agent) Handle(cmd *proto.Cmd) *proto.Reply
  • func (agent *Agent) Run() error
  • func (agent *Agent) Status() map[string]string
• type LocalInterface
  • func NewLocalInterface(addr string, agent *Agent, repo *instance.Repo) *LocalInterface
  • func (lo *LocalInterface) Run()

Constants

const (
	DEFAULT_KEEPALIVE = 76
	DEFAULT_PIDFILE   = "percona-agent.pid"
	DEFAULT_LISTEN    = "127.0.0.1:9000"
)

const (
	CMD_QUEUE_SIZE              = 10
	STATUS_QUEUE_SIZE           = 10
	MAX_ERRORS                  = 3
	MIN_SUPPORTED_MYSQL_VERSION = "5.1.0"
)

Variables

var (
	ErrRestart = errors.New("received Restart command")
	ErrStop    = errors.New("received Stop command")
)

Functions

func JSONResponse

func JSONResponse(w http.ResponseWriter, statusCode int, v interface{})

func LoadConfig

func LoadConfig() ([]byte, error)

Types

type Agent

type Agent struct {
	// contains filtered or unexported fields
}

func NewAgent

func NewAgent(config *pc.Agent, logger *pct.Logger, client pct.WebsocketClient, addr string, services map[string]pct.ServiceManager) *Agent

func (*Agent) AllStatus

func (agent *Agent) AllStatus() map[string]string

func (*Agent) GetAllConfigs

func (agent *Agent) GetAllConfigs() (interface{}, []error)

func (*Agent) GetConfig

func (agent *Agent) GetConfig() ([]proto.AgentConfig, []error)

func (*Agent) GetDefaults

func (agent *Agent) GetDefaults() (interface{}, []error)

func (*Agent) Handle

func (agent *Agent) Handle(cmd *proto.Cmd) *proto.Reply

func (*Agent) Run

func (agent *Agent) Run() error

func (*Agent) Status

func (agent *Agent) Status() map[string]string

type LocalInterface

type LocalInterface struct {
	// contains filtered or unexported fields
}

func NewLocalInterface

func NewLocalInterface(addr string, agent *Agent, repo *instance.Repo) *LocalInterface

func (*LocalInterface) Run

func (lo *LocalInterface) Run()