instance

Documentation

Index

• Variables
• func GetMySQLInfo(in *proto.Instance) error
• type ByUUID
  • func (s ByUUID) Len() int
  • func (s ByUUID) Less(i, j int) bool
  • func (s ByUUID) Swap(i, j int)
• type Manager
  • func NewManager(logger *pct.Logger, instanceDir string, api pct.APIConnector, ...) *Manager
  • func (m *Manager) GetConfig() ([]proto.AgentConfig, []error)
  • func (m *Manager) GetDefaults() map[string]interface{}
  • 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, instanceDir string, api pct.APIConnector) *Repo
  • func (r *Repo) Add(in proto.Instance, writeToDisk bool) error
  • func (r *Repo) Get(uuid string, cache bool) (proto.Instance, error)
  • func (r *Repo) Init() (err error)
  • func (r *Repo) List(subsystemName string) []proto.Instance
  • func (r *Repo) Remove(uuid string) error

Variables

var (
	ErrDuplicateInstance = errors.New("duplicate instance")
	ErrInstanceNotFound  = errors.New("instance not found")
	ErrCmdNotSupport     = errors.New("command not supported")
	ErrNoLink            = errors.New("no instances link from API")
)

Functions

func GetMySQLInfo

func GetMySQLInfo(in *proto.Instance) error

Types

type ByUUID

type ByUUID []proto.Instance

func (ByUUID) Len

func (s ByUUID) Len() int

func (ByUUID) Less

func (s ByUUID) Less(i, j int) bool

func (ByUUID) Swap

func (s ByUUID) Swap(i, j int)

type Manager

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

func NewManager

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

func (*Manager) GetConfig

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

func (*Manager) GetDefaults

func (m *Manager) GetDefaults() map[string]interface{}

func (*Manager) Handle

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

func (*Manager) Repo

func (m *Manager) Repo() *Repo

func (*Manager) Start

func (m *Manager) Start() error

func (*Manager) Status

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

func (*Manager) Stop

func (m *Manager) Stop() error

type Repo

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

func NewRepo

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

Creates a new instance repository and returns a pointer to it

func (*Repo) Add

func (r *Repo) Add(in proto.Instance, writeToDisk bool) error

func (*Repo) Get

func (r *Repo) Get(uuid string, cache bool) (proto.Instance, error)

func (*Repo) Init

func (r *Repo) Init() (err error)

Initializes the instance repository by reading system tree from local file

func (*Repo) List

func (r *Repo) List(subsystemName string) []proto.Instance

func (*Repo) Remove

func (r *Repo) Remove(uuid string) error