client

Documentation

Index

• Constants
• type Client
  • func NewClient(address, checkId, output string) Client
• type ClientCreator
• type KeyValueStoreElement
• type Pool
  • func (p *Pool) Get() (Client, error)
  • func (p *Pool) Put(client Client)
• type Pools
  • func New(address, checkId, output string, maxPoolSize int, creator ClientCreator) *Pools
  • func (p Pools) With(fn func(Client) error) error

Constants

const (
	Passing     selectors.HealthStatus = "passing"
	Warning     selectors.HealthStatus = "warning"
	Critical    selectors.HealthStatus = "critical"
	Maintenance selectors.HealthStatus = "maintenance"
)

Types

type Client

type Client interface {
	Lock(selectors.Namespace) (selectors.SemaphoreUnlock, error)
	Heartbeat(selectors.HealthStatus) error
	List(fs.Prefix) (map[string]int, error)
}

func NewClient

func NewClient(address, checkId, output string) Client

type ClientCreator

type ClientCreator func(string, string, string) Client

type KeyValueStoreElement

type KeyValueStoreElement struct {
	Key  string `json:"key"`
	Node int    `json:"node"`
}

type Pool

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

func (*Pool) Get

func (p *Pool) Get() (Client, error)

func (*Pool) Put

func (p *Pool) Put(client Client)

type Pools

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

func New

func New(address, checkId, output string,
	maxPoolSize int,
	creator ClientCreator,
) *Pools

func (Pools) With

func (p Pools) With(fn func(Client) error) error