Versions in this module Expand all Collapse all v0 v0.7.0 Oct 10, 2019 Changes in this version + const HTTPPostTimeout + type Config struct + Logger *logrus.Logger + PollPodsFrequency time.Duration + func DefaultStoreConfig() Config + type Gossip struct + func NewGossip(bindAddr string, join []string, port int, logOutput io.Writer) (*Gossip, error) + func (g *Gossip) Events() <-chan serf.Event + type Store struct + Raft *raft.Raft + 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