agent

Documentation

Index

• Variables
• type Client
  • func (c Client) InstallKey(key string) error
  • func (c Client) JoinMembers() error
  • func (c Client) Leave() error
  • func (c Client) ListKeys() ([]string, error)
  • func (c Client) Members(wan bool) ([]*api.AgentMember, error)
  • func (c Client) RaftStats() (map[string]interface{}, error)
  • func (c Client) RemoveKey(key string) error
  • func (c Client) Self() error
  • func (c Client) SetKeys(keys []string, keyringFile string) error
  • func (c Client) UseKey(key string) error
  • func (c Client) VerifyJoined() error
  • func (c Client) VerifySynced() error
• type Runner
  • func (r *Runner) Cleanup() error
  • func (r *Runner) Exited() bool
  • func (r *Runner) Run() error
  • func (r *Runner) Stop() error
  • func (r *Runner) Wait() error
  • func (r *Runner) WritePID() error

Variables

var NoMembersToJoinError = errors.New("no members to join")

Types

type Client

type Client struct {
	ExpectedMembers   []string
	ConsulAPIAgent    consulAPIAgent
	ConsulAPIOperator consulAPIOperator
	Logger            logger
}

func (Client) InstallKey

func (c Client) InstallKey(key string) error

func (Client) JoinMembers

func (c Client) JoinMembers() error

func (Client) Leave

func (c Client) Leave() error

func (Client) ListKeys

func (c Client) ListKeys() ([]string, error)

func (Client) Members

func (c Client) Members(wan bool) ([]*api.AgentMember, error)

func (Client) RaftStats

func (c Client) RaftStats() (map[string]interface{}, error)

func (Client) RemoveKey

func (c Client) RemoveKey(key string) error

func (Client) Self

func (c Client) Self() error

func (Client) SetKeys

func (c Client) SetKeys(keys []string, keyringFile string) error

func (Client) UseKey

func (c Client) UseKey(key string) error

func (Client) VerifyJoined

func (c Client) VerifyJoined() error

func (Client) VerifySynced

func (c Client) VerifySynced() error

type Runner

type Runner struct {
	Path      string
	PIDFile   string
	ConfigDir string
	Stdout    io.Writer
	Stderr    io.Writer
	Recursors []string
	Logger    logger
	// contains filtered or unexported fields
}

func (*Runner) Cleanup

func (r *Runner) Cleanup() error

func (*Runner) Exited

func (r *Runner) Exited() bool

func (*Runner) Run

func (r *Runner) Run() error

func (*Runner) Stop

func (r *Runner) Stop() error

func (*Runner) Wait

func (r *Runner) Wait() error

func (*Runner) WritePID

func (r *Runner) WritePID() error