instance

Documentation

Index

• func GetMySQLInfo(it *proto.MySQLInstance) error
• type Manager
  • func NewManager(logger *pct.Logger, configDir string, api pct.APIConnector, mrm mrms.Monitor) *Manager
  • func (m *Manager) GetConfig() ([]proto.AgentConfig, []error)
  • func (m *Manager) GetMySQLInstances() []*proto.MySQLInstance
  • func (m *Manager) Handle(cmd *proto.Cmd) *proto.Reply
  • func (m *Manager) Repo() *Repo
  • func (m *Manager) Start() error
  • func (m *Manager) Status() map[string]string
  • func (m *Manager) Stop() error
• type Repo
  • func NewRepo(logger *pct.Logger, configDir string, api pct.APIConnector) *Repo
  • func (r *Repo) Add(service string, id uint, data []byte, writeToDisk bool) error
  • func (r *Repo) Get(service string, id uint, info interface{}) error
  • func (r *Repo) Init() error
  • func (r *Repo) List() []string
  • func (r *Repo) Name(service string, id uint) string
  • func (r *Repo) Remove(service string, id uint) error

Functions

func GetMySQLInfo

func GetMySQLInfo(it *proto.MySQLInstance) error

Types

type Manager

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

func NewManager

func NewManager(logger *pct.Logger, configDir string, api pct.APIConnector, mrm mrms.Monitor) *Manager

func (*Manager) GetConfig

func (m *Manager) GetConfig() ([]proto.AgentConfig, []error)

func (*Manager) GetMySQLInstances

func (m *Manager) GetMySQLInstances() []*proto.MySQLInstance

func (*Manager) Handle

func (m *Manager) Handle(cmd *proto.Cmd) *proto.Reply

@goroutine[0]

func (*Manager) Repo

func (m *Manager) Repo() *Repo

func (*Manager) Start

func (m *Manager) Start() error

@goroutine[0]

func (*Manager) Status

func (m *Manager) Status() map[string]string

func (*Manager) Stop

func (m *Manager) Stop() error

@goroutine[0]

type Repo

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

func NewRepo

func NewRepo(logger *pct.Logger, configDir string, api pct.APIConnector) *Repo

func (*Repo) Add

func (r *Repo) Add(service string, id uint, data []byte, writeToDisk bool) error

func (*Repo) Get

func (r *Repo) Get(service string, id uint, info interface{}) error

func (*Repo) Init

func (r *Repo) Init() error

func (*Repo) List

func (r *Repo) List() []string

func (*Repo) Name

func (r *Repo) Name(service string, id uint) string

func (*Repo) Remove

func (r *Repo) Remove(service string, id uint) error