client

Documentation

Index

• Variables
• type Client
  • func NewClient(addr string) *Client
  • func NewClientWithHTTP(addr string, httpClient *http.Client) *Client
  • func (c *Client) Status() (*Status, error)
  • func (c *Client) Stop() error
  • func (c *Client) WaitForReadWrite(timeout time.Duration) error
  • func (c *Client) WaitForReplSync(downstream *discoverd.Instance, timeout time.Duration) error
• type DatabaseInfo
• type Status

Variables

var ErrTimeout = errors.New("timeout waiting for expected status")

Types

type Client

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

func NewClient

func NewClient(addr string) *Client

func NewClientWithHTTP

func NewClientWithHTTP(addr string, httpClient *http.Client) *Client

func (*Client) Status

func (c *Client) Status() (*Status, error)

func (*Client) Stop

func (c *Client) Stop() error

func (*Client) WaitForReadWrite

func (c *Client) WaitForReadWrite(timeout time.Duration) error

func (*Client) WaitForReplSync

func (c *Client) WaitForReplSync(downstream *discoverd.Instance, timeout time.Duration) error

type DatabaseInfo

type DatabaseInfo struct {
	Config           *state.Config       `json:"config"`
	Running          bool                `json:"running"`
	SyncedDownstream *discoverd.Instance `json:"synced_downstream"`
	XLog             string              `json:"xlog"`
	UserExists       bool                `json:"user_exists"`
	ReadWrite        bool                `json:"read_write"`
}

type Status

type Status struct {
	Peer     *state.PeerInfo `json:"peer"`
	Database *DatabaseInfo   `json:"database"`
}