master

Documentation

Index

• type Config
• type Master
  • func New(pwd string, cfg Config, ver string) (*Master, error)
  • func (m *Master) Auth(username, password string) bool
  • func (m *Master) Close() error
  • func (m *Master) InspectSystem() *openedge.Inspect
  • func (m *Master) ReportInstance(serviceName, instanceName string, partialStats engine.PartialStats) error
  • func (m *Master) StartInstance(service, instance string, dynamicConfig map[string]string) error
  • func (m *Master) StopInstance(service, instance string) error
  • func (m *Master) UpdateSystem(target string) error
• type Server

Types

type Config

type Config struct {
	Mode   string         `yaml:"mode" json:"mode" default:"docker" validate:"regexp=^(native|docker)$"`
	Server Server         `yaml:"server" json:"server"`
	Logger logger.LogInfo `yaml:"logger" json:"logger"`
	Grace  time.Duration  `yaml:"grace" json:"grace" default:"30s"`
}

Config master init config

type Master

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

Master master manages all modules and connects with cloud

func New

func New(pwd string, cfg Config, ver string) (*Master, error)

New creates a new master

func (*Master) Auth

func (m *Master) Auth(username, password string) bool

Auth auth api request from services

func (*Master) Close

func (m *Master) Close() error

Close closes agent

func (*Master) InspectSystem

func (m *Master) InspectSystem() *openedge.Inspect

InspectSystem inspects info and stats of openedge system

func (*Master) ReportInstance

func (m *Master) ReportInstance(serviceName, instanceName string, partialStats engine.PartialStats) error

ReportInstance reports the stats of the instance of the service

func (*Master) StartInstance

func (m *Master) StartInstance(service, instance string, dynamicConfig map[string]string) error

StartInstance starts a service instance

func (*Master) StopInstance

func (m *Master) StopInstance(service, instance string) error

StopInstance stops a service instance

func (*Master) UpdateSystem

func (m *Master) UpdateSystem(target string) error

UpdateSystem updates system

type Server

type Server struct {
	Address           string        `yaml:"address" json:"address" default:"unix:///var/run/openedge.sock"`
	Timeout           time.Duration `yaml:"timeout" json:"timeout" default:"5m"`
	utils.Certificate `yaml:",inline" json:",inline"`
}

Server server config