cluster

Documentation

Index

• Constants
• type Config
  • func DefaultStoreConfig() Config
• type Gossip
  • func NewGossip(bindAddr string, join []string, port int, logOutput io.Writer) (*Gossip, error)
  • func (g *Gossip) Events() <-chan serf.Event
• type Store
  • func NewStore(gossip *Gossip, kubeClient *client.Kube, vaultClient *client.Vault, ...) *Store
  • func (s *Store) Apply(l *raft.Log) interface{}
  • func (s *Store) Restore(snap io.ReadCloser) error
  • func (s *Store) Shutdown()
  • func (s *Store) Snapshot() (raft.FSMSnapshot, error)
  • func (s *Store) StartRaft(dataDir string, bindAddr string, logOutput io.Writer) error

Constants

const (
	HTTPPostTimeout = 30 * time.Second
)

Types

type Config

type Config struct {
	Logger            *logrus.Logger
	PollPodsFrequency time.Duration
}

func DefaultStoreConfig

func DefaultStoreConfig() Config

type Gossip

type Gossip struct {
	*serf.Serf
	// contains filtered or unexported fields
}

func NewGossip

func NewGossip(bindAddr string, join []string, port int, logOutput io.Writer) (*Gossip, error)

func (*Gossip) Events

func (g *Gossip) Events() <-chan serf.Event

type Store

type Store struct {
	Raft *raft.Raft

	sync.Mutex
	// contains filtered or unexported fields
}

func NewStore

func NewStore(gossip *Gossip, kubeClient *client.Kube, vaultClient *client.Vault, config Config) *Store

func (*Store) Apply

func (s *Store) Apply(l *raft.Log) interface{}

func (*Store) Restore

func (s *Store) Restore(snap io.ReadCloser) error

func (*Store) Shutdown

func (s *Store) Shutdown()

func (*Store) Snapshot

func (s *Store) Snapshot() (raft.FSMSnapshot, error)

func (*Store) StartRaft

func (s *Store) StartRaft(dataDir string, bindAddr string, logOutput io.Writer) error