agent

Documentation

Index

• Variables
• func AbortSeed(seedId int64) error
• func CustomCommand(hostname string, cmd string) (output string, err error)
• func DiscoverAgentInstance(hostname string, port int) error
• func FailStaleSeeds() error
• func ForgetLongUnseenAgents() error
• func InitHttpClient()
• func ReadOutdatedAgentsHosts() ([]string, error)
• func Seed(targetHostname string, sourceHostname string) (int64, error)
• func SubmitAgent(hostname string, port int, token string) (string, error)
• func SubmitSeedEntry(targetHostname string, sourceHostname string) (int64, error)
• func SyncReplicaRelayLogs(instance, otherInstance *inst.Instance) (*inst.Instance, error)
• func UpdateAgentInfo(hostname string, agent Agent) error
• func UpdateAgentLastChecked(hostname string) error
• type Agent
  • func AbortSeedCommand(hostname string, seedId int64) (Agent, error)
  • func ApplyRelaylogContents(hostname string, content string) (Agent, error)
  • func CreateSnapshot(hostname string) (Agent, error)
  • func GetAgent(hostname string) (Agent, error)
  • func MountLV(hostname string, lv string) (Agent, error)
  • func MySQLStart(hostname string) (Agent, error)
  • func MySQLStop(hostname string) (Agent, error)
  • func PostCopy(hostname, sourceHostname string) (Agent, error)
  • func ReadAgents() ([]Agent, error)
  • func ReceiveMySQLSeedData(hostname string, seedId int64) (Agent, error)
  • func RelaylogContentsTail(hostname string, startCoordinates *inst.BinlogCoordinates, ...) (Agent, error)
  • func RemoveLV(hostname string, lv string) (Agent, error)
  • func SendMySQLSeedData(hostname string, targetHostname string, seedId int64) (Agent, error)
  • func Unmount(hostname string) (Agent, error)
  • func (this *Agent) GetInstance() *inst.InstanceKey
• type LogicalVolume
• type Mount
• type SeedOperation
  • func AgentSeedDetails(seedId int64) ([]SeedOperation, error)
  • func ReadActiveSeedsForHost(hostname string) ([]SeedOperation, error)
  • func ReadRecentCompletedSeedsForHost(hostname string) ([]SeedOperation, error)
  • func ReadRecentSeeds() ([]SeedOperation, error)
• type SeedOperationState
  • func ReadSeedStates(seedId int64) ([]SeedOperationState, error)

Variables

var SeededAgents chan *Agent = make(chan *Agent)

Functions

func AbortSeed

func AbortSeed(seedId int64) error

AbortSeed will contact agents associated with a seed and request abort.

func CustomCommand

func CustomCommand(hostname string, cmd string) (output string, err error)

func DiscoverAgentInstance

func DiscoverAgentInstance(hostname string, port int) error

If a mysql port is available, try to discover against it

func FailStaleSeeds

func FailStaleSeeds() error

FailStaleSeeds marks as failed seeds where no progress have been seen recently

func ForgetLongUnseenAgents

func ForgetLongUnseenAgents() error

ForgetLongUnseenAgents will remove entries of all agents that have long since been last seen.

func InitHttpClient

func InitHttpClient()

InitHttpClient gets called once, and initializes httpClient according to config.Config

func ReadOutdatedAgentsHosts

func ReadOutdatedAgentsHosts() ([]string, error)

ReadOutdatedAgentsHosts returns agents that need to be updated

func Seed

func Seed(targetHostname string, sourceHostname string) (int64, error)

Seed is the entry point for making a seed

func SubmitAgent

func SubmitAgent(hostname string, port int, token string) (string, error)

SubmitAgent submits a new agent for listing

func SubmitSeedEntry

func SubmitSeedEntry(targetHostname string, sourceHostname string) (int64, error)

SubmitSeedEntry submits a new seed operation entry, returning its unique ID

func SyncReplicaRelayLogs

func SyncReplicaRelayLogs(instance, otherInstance *inst.Instance) (*inst.Instance, error)

func UpdateAgentInfo

func UpdateAgentInfo(hostname string, agent Agent) error

UpdateAgentInfo updates some agent state in backend table

func UpdateAgentLastChecked

func UpdateAgentLastChecked(hostname string) error

UpdateAgentLastChecked updates the last_check timestamp in the orchestrator backed database for a given agent

Types

type Agent

type Agent struct {
	Hostname                string
	Port                    int
	Token                   string
	LastSubmitted           string
	AvailableLocalSnapshots []string
	AvailableSnapshots      []string
	LogicalVolumes          []LogicalVolume
	MountPoint              Mount
	MySQLRunning            bool
	MySQLDiskUsage          int64
	MySQLPort               int64
	MySQLDatadirDiskFree    int64
	MySQLErrorLogTail       []string
}

Agent presents the data of an agent

func AbortSeedCommand

func AbortSeedCommand(hostname string, seedId int64) (Agent, error)

ReceiveMySQLSeedData requests an agent to abort seed send/receive (depending on the agent's role)

func ApplyRelaylogContents

func ApplyRelaylogContents(hostname string, content string) (Agent, error)

func CreateSnapshot

func CreateSnapshot(hostname string) (Agent, error)

CreateSnapshot requests an agent to create a new snapshot -- a DIY implementation

func GetAgent

func GetAgent(hostname string) (Agent, error)

GetAgent gets a single agent status from the agent service. This involves multiple HTTP requests.

func MountLV

func MountLV(hostname string, lv string) (Agent, error)

MountLV requests an agent to mount the given volume on the designated mount point

func MySQLStart

func MySQLStart(hostname string) (Agent, error)

MySQLStart requests an agent to start the MySQL service

func MySQLStop

func MySQLStop(hostname string) (Agent, error)

MySQLStop requests an agent to stop MySQL service

func PostCopy

func PostCopy(hostname, sourceHostname string) (Agent, error)

PostCopy will request an agent to invoke post-copy commands

func ReadAgents

func ReadAgents() ([]Agent, error)

ReadAgents returns a list of all known agents

func ReceiveMySQLSeedData

func ReceiveMySQLSeedData(hostname string, seedId int64) (Agent, error)

ReceiveMySQLSeedData requests an agent to start listening for incoming seed data

func RelaylogContentsTail

func RelaylogContentsTail(hostname string, startCoordinates *inst.BinlogCoordinates, onResponse *func([]byte)) (Agent, error)

func RemoveLV

func RemoveLV(hostname string, lv string) (Agent, error)

RemoveLV requests an agent to remove a snapshot

func SendMySQLSeedData

func SendMySQLSeedData(hostname string, targetHostname string, seedId int64) (Agent, error)

ReceiveMySQLSeedData requests an agent to start sending seed data

func Unmount

func Unmount(hostname string) (Agent, error)

Unmount unmounts the designated snapshot mount point

func (*Agent) GetInstance

func (this *Agent) GetInstance() *inst.InstanceKey

Build an instance key for a given agent

type LogicalVolume

type LogicalVolume struct {
	Name            string
	GroupName       string
	Path            string
	IsSnapshot      bool
	SnapshotPercent float64
}

LogicalVolume describes an LVM volume

type Mount

type Mount struct {
	Path           string
	Device         string
	LVPath         string
	FileSystem     string
	IsMounted      bool
	DiskUsage      int64
	MySQLDataPath  string
	MySQLDiskUsage int64
}

Mount describes a file system mount point

type SeedOperation

type SeedOperation struct {
	SeedId         int64
	TargetHostname string
	SourceHostname string
	StartTimestamp string
	EndTimestamp   string
	IsComplete     bool
	IsSuccessful   bool
}

SeedOperation makes for the high level data & state of a seed operation

func AgentSeedDetails

func AgentSeedDetails(seedId int64) ([]SeedOperation, error)

AgentSeedDetails reads details from backend table

func ReadActiveSeedsForHost

func ReadActiveSeedsForHost(hostname string) ([]SeedOperation, error)

ReadActiveSeedsForHost reads active seeds where host participates either as source or target

func ReadRecentCompletedSeedsForHost

func ReadRecentCompletedSeedsForHost(hostname string) ([]SeedOperation, error)

ReadRecentCompletedSeedsForHost reads active seeds where host participates either as source or target

func ReadRecentSeeds

func ReadRecentSeeds() ([]SeedOperation, error)

ReadRecentSeeds reads seeds from backend table.

type SeedOperationState

type SeedOperationState struct {
	SeedStateId    int64
	SeedId         int64
	StateTimestamp string
	Action         string
	ErrorMessage   string
}

SeedOperationState represents a single state (step) in a seed operation

func ReadSeedStates

func ReadSeedStates(seedId int64) ([]SeedOperationState, error)

SeedOperationState reads states for a given seed operation