package raftpicker

import "github.com/docker/swarmkit/manager/raftpicker"

Index ¶

• type AddrSelector
• type ConnSelector
• func NewConnSelector(cluster RaftCluster, opts ...grpc.DialOption) *ConnSelector
• func (c *ConnSelector) Conn() (*grpc.ClientConn, error)
• type RaftCluster

Types ¶

type AddrSelector ¶

type AddrSelector interface {
	LeaderAddr() (string, error)
}

AddrSelector is interface which should track cluster for its leader address.

type ConnSelector ¶

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

ConnSelector is struct for obtaining connection with raftpicker.

func NewConnSelector ¶

func NewConnSelector(cluster RaftCluster, opts ...grpc.DialOption) *ConnSelector

NewConnSelector returns new ConnSelector with cluster and grpc.DialOpts which will be used for Dial on first call of Conn.

func (*ConnSelector) Conn ¶

func (c *ConnSelector) Conn() (*grpc.ClientConn, error)

Conn returns *grpc.ClientConn with picker which picks raft cluster leader. Internal connection estabilished lazily on this call. It can return error if cluster wasn't ready at the moment of initial call.

type RaftCluster ¶

type RaftCluster interface {
	AddrSelector
	IsLeader() bool
}

RaftCluster is interface which combines useful methods for clustering.

Source Files ¶

cluster.go raftpicker.go