pkg

Documentation

Index

• type FSM
  • func (fsm FSM) Apply(log *raft.Log) interface{}
  • func (fsm FSM) Restore(snap io.ReadCloser) error
  • func (fsm FSM) Snapshot() (raft.FSMSnapshot, error)
• type Logger
  • func (logger Logger) Write(data []byte) (count int, error error)
• type NetlinkNetworkConfigurator
  • func NewNetlinkNetworkConfigurator(_address, _interface string) (result NetlinkNetworkConfigurator, error error)
  • func (configurator NetlinkNetworkConfigurator) AddIP() error
  • func (configurator NetlinkNetworkConfigurator) DeleteIP() error
  • func (configurator NetlinkNetworkConfigurator) IP() string
  • func (configurator NetlinkNetworkConfigurator) Interface() string
  • func (configurator NetlinkNetworkConfigurator) IsSet() (result bool, error error)
• type NetworkConfigurator
• type Peer
• type Peers
• type Snapshot
  • func (snapshot Snapshot) Persist(sink raft.SnapshotSink) error
  • func (snapshot Snapshot) Release()
• type VIPManager
  • func NewVIPManager(id, bind string, peers Peers, logger Logger, ...) *VIPManager
  • func (manager *VIPManager) Start() error
  • func (manager *VIPManager) Stop()

Types

type FSM

type FSM struct {
}

func (FSM) Apply

func (fsm FSM) Apply(log *raft.Log) interface{}

func (FSM) Restore

func (fsm FSM) Restore(snap io.ReadCloser) error

func (FSM) Snapshot

func (fsm FSM) Snapshot() (raft.FSMSnapshot, error)

type Logger

type Logger struct {
}

func (Logger) Write

func (logger Logger) Write(data []byte) (count int, error error)

type NetlinkNetworkConfigurator

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

func NewNetlinkNetworkConfigurator

func NewNetlinkNetworkConfigurator(_address, _interface string) (result NetlinkNetworkConfigurator, error error)

func (NetlinkNetworkConfigurator) AddIP

func (configurator NetlinkNetworkConfigurator) AddIP() error

func (NetlinkNetworkConfigurator) DeleteIP

func (configurator NetlinkNetworkConfigurator) DeleteIP() error

func (NetlinkNetworkConfigurator) IP

func (configurator NetlinkNetworkConfigurator) IP() string

func (NetlinkNetworkConfigurator) Interface

func (configurator NetlinkNetworkConfigurator) Interface() string

func (NetlinkNetworkConfigurator) IsSet

func (configurator NetlinkNetworkConfigurator) IsSet() (result bool, error error)

type NetworkConfigurator

type NetworkConfigurator interface {
	AddIP() error
	DeleteIP() error
	IsSet() (bool, error)
	IP() string
	Interface() string
}

type Peer

type Peer struct {
	ID   string
	Bind string
}

type Peers

type Peers map[string]string

type Snapshot

type Snapshot struct {
}

func (Snapshot) Persist

func (snapshot Snapshot) Persist(sink raft.SnapshotSink) error

func (Snapshot) Release

func (snapshot Snapshot) Release()

type VIPManager

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

func NewVIPManager

func NewVIPManager(id, bind string, peers Peers, logger Logger, networkConfigurator NetworkConfigurator) *VIPManager

func (*VIPManager) Start

func (manager *VIPManager) Start() error

func (*VIPManager) Stop

func (manager *VIPManager) Stop()