config

Documentation

Index

• Constants
• Variables
• func CreateInstance(cfg *models.InstanceConfig) (*models.Instance, error)
• func DeleteInstance(name string) error
• func GetInstance(name string) (*models.Instance, error)
• func GossipCreateInstance(inst *models.Instance) error
• func GossipDeleteInstance(inst string)
• func GossipInstanceStatus(inst string, status string)
• func GossipModifyInstance(inst *models.Instance) error
• func GossipNodeEndpoint()
• func GossipNodeStatus()
• func GossipStartInstance(inst string)
• func GossipStopInstance(inst string)
• func ListInstances(fuzzyName *string) []*models.Instance
• func LoadConfig(conf string)
• func LoadInstances()
• func ModifyInstance(cfg *models.InstanceConfig) (*models.Instance, error)
• func RemoveInstancesStatus(node string)
• func RemoveNodeEndpoint(node string)
• func RemoveNodeStatus(node string)
• func StartClusterGossip() error
• func StartInstance(name string) (*models.Instance, error)
• func StopInstance(name string) (*models.Instance, error)
• func SyncInstance(other *models.Instance) error
• func SyncInstances(others []*models.Instance)
• func UpdateClusterInstance()
• func UpdateInstanceStatus(node string, instName string, newStatus string)
• func UpdateNodeEndpoint(node string, nodeIp string, nodePort uint16)
• func UpdateNodeStatus(node string, status string)
• type ClusterConfig
• type HAProxyConfig
• type HAProxyDefaultsConfig
• type HAProxyGlobalConfig
• type HAProxyTimeoutConfig
• type KeepalivedConfig
• type KeepalivedGlobalDefs
• type NodeEndpoint

Constants

const (
	MsgTypeCreateInstance byte = 'c'
	MsgTypeModifyInstance byte = 'm'
	MsgTypeDeleteInstance byte = 'd'
	MsgTypeStopInstance   byte = 'p'
	MsgTypeStartInstance  byte = 'r'
	MsgTypeInstanceStatus byte = 's'
	MsgTypeNodeStatus     byte = 'S'
	MsgTypeNodeEndpoint   byte = 'e'
)

const (
	ReadyStatusReady    = "ready"
	ReadyStatusNotReady = "not_ready"
	ReadyStatusStarting = "starting"
)

Variables

var LB = struct {
	Name          string             `yaml:"name"`
	Host          string             `yaml:"host"`
	Port          uint16             `yaml:"port"`
	TLSHost       string             `yaml:"tls_host"`
	TLSPort       uint16             `yaml:"tls_port"`
	TLSCert       string             `yaml:"tls_cert"`
	TLSKey        string             `yaml:"tls_key"`
	TLSCACert     string             `yaml:"tls_ca_cert"`
	InstanceDir   string             `yaml:"instance_dir"`
	WatchInterval uint16             `yaml:"watch_interval"`
	LogLevel      uint8              `yaml:"log_level"`
	Cluster       ClusterConfig      `yaml:"cluster"`
	HAProxy       HAProxyConfig      `yaml:"haproxy"`
	Keepalived    KeepalivedConfig   `yaml:"keepalived"`
	Status        models.ReadyStatus `yaml:"status,omitempty"`
}{}

Functions

func CreateInstance

func CreateInstance(cfg *models.InstanceConfig) (*models.Instance, error)

func DeleteInstance

func DeleteInstance(name string) error

func GetInstance

func GetInstance(name string) (*models.Instance, error)

func GossipCreateInstance

func GossipCreateInstance(inst *models.Instance) error

func GossipDeleteInstance

func GossipDeleteInstance(inst string)

func GossipInstanceStatus

func GossipInstanceStatus(inst string, status string)

func GossipModifyInstance

func GossipModifyInstance(inst *models.Instance) error

func GossipNodeEndpoint

func GossipNodeEndpoint()

func GossipNodeStatus

func GossipNodeStatus()

func GossipStartInstance

func GossipStartInstance(inst string)

func GossipStopInstance

func GossipStopInstance(inst string)

func ListInstances

func ListInstances(fuzzyName *string) []*models.Instance

func LoadConfig

func LoadConfig(conf string)

func LoadInstances

func LoadInstances()

func ModifyInstance

func ModifyInstance(cfg *models.InstanceConfig) (*models.Instance, error)

func RemoveInstancesStatus

func RemoveInstancesStatus(node string)

func RemoveNodeEndpoint

func RemoveNodeEndpoint(node string)

func RemoveNodeStatus

func RemoveNodeStatus(node string)

func StartClusterGossip

func StartClusterGossip() error

func StartInstance

func StartInstance(name string) (*models.Instance, error)

func StopInstance

func StopInstance(name string) (*models.Instance, error)

func SyncInstance

func SyncInstance(other *models.Instance) error

func SyncInstances

func SyncInstances(others []*models.Instance)

func UpdateClusterInstance

func UpdateClusterInstance()

should trigger after LoadInstances

func UpdateInstanceStatus

func UpdateInstanceStatus(node string, instName string, newStatus string)

func UpdateNodeEndpoint

func UpdateNodeEndpoint(node string, nodeIp string, nodePort uint16)

func UpdateNodeStatus

func UpdateNodeStatus(node string, status string)

Types

type ClusterConfig

type ClusterConfig struct {
	Name           string                  `yaml:"name"`
	Endpoint       string                  `yaml:"endpoint"`
	Advertize      string                  `yaml:"advertize"`
	Member         string                  `yaml:"member"`
	SecretKey      string                  `yaml:"secret_key"`
	ProbeInterval  uint16                  `yaml:"probe_interval"`
	SyncInterval   uint16                  `yaml:"sync_interval"`
	RetransmitMult uint16                  `yaml:"retransmit_mult"`
	Nodes          map[string]NodeEndpoint `yaml:"nodes,omitempty"`
}

type HAProxyConfig

type HAProxyConfig struct {
	ConfigDir      string                `yaml:"config_dir"`
	PidDir         string                `yaml:"pid_dir"`
	StartTimeout   int                   `yaml:"start_timeout"`
	GlobalConfig   HAProxyGlobalConfig   `yaml:"global"`
	DefaultsConfig HAProxyDefaultsConfig `yaml:"defaults"`
}

type HAProxyDefaultsConfig

type HAProxyDefaultsConfig struct {
	Mode    string               `yaml:"mode"`
	Log     string               `yaml:"log"`
	Options []string             `yaml:"options"`
	Retries uint16               `yaml:"retries"`
	MaxConn uint16               `yaml:"maxconn"`
	Timeout HAProxyTimeoutConfig `yaml:"timeout"`
}

type HAProxyGlobalConfig

type HAProxyGlobalConfig struct {
	Daemon  bool   `yaml:"daemon"`
	MaxConn uint16 `yaml:"maxconn"`
	UID     uint16 `yaml:"uid"`
	GID     uint16 `yaml:"gid"`
	Log     string `yaml:"log"`
}

type HAProxyTimeoutConfig

type HAProxyTimeoutConfig struct {
	HTTPRequest   string `yaml:"http-request"`
	HTTPKeepAlive string `yaml:"http-keep-alive"`
	Check         string `yaml:"check"`
	Queue         string `yaml:"queue"`
	Connect       string `yaml:"connect"`
}

type KeepalivedConfig

type KeepalivedConfig struct {
	ConfigFile         string               `yaml:"config_file"`
	ConfigDir          string               `yaml:"config_dir"`
	PidFile            string               `yaml:"pid_file"`
	GlobalDefs         KeepalivedGlobalDefs `yaml:"global_defs"`
	MinVirtualRouterId uint8                `yaml:"min_virtual_router_id"`
	MaxVirtualRouterId uint8                `yaml:"max_virtual_router_id"`
	AdvertInt          uint16               `yaml:"advert_int"`
	AuthType           string               `yaml:"auth_type"`
	AuthPass           string               `yaml:"auth_pass"`
}

type KeepalivedGlobalDefs

type KeepalivedGlobalDefs struct {
	RouterID             string  `yaml:"router_id"`
	VRRPSkipCheckAdvAddr bool    `yaml:"vrrp_skip_check_adv_addr"`
	VRRPGARPInterval     float32 `yaml:"vrrp_garp_interval"`
	VRRPGNAInterval      float32 `yaml:"vrrp_gna_interval"`
}

type NodeEndpoint

type NodeEndpoint struct {
	IPAddress string `yaml:"ipaddress"`
	Port      uint16 `yaml:"port"`
}