consul

Jun 9, 2017

Changes in this version

type Client

+ func NewClientLogger(config *Config, logger *log.Logger) (*Client, error)

+ func (c *Client) GetLANCoordinate() (*coordinate.Coordinate, error)

type Config

+ UseTLS bool

type Server

+ func NewServerLogger(config *Config, logger *log.Logger) (*Server, error)

May 9, 2017

Changes in this version

+ const DefaultRPCPort

type Config

+ CAPath string

+ RPCSrcAddr *net.TCPAddr

+ TLSCipherSuites []uint16

+ TLSPreferServerCipherSuites bool

+ func (c *Config) CheckProtocolVersion() error

Apr 17, 2017

Changes in this version

+ func ServersMeetMinimumVersion(members []serf.Member, minVersion *version.Version) bool

Apr 5, 2017

Changes in this version

+ func ServerMinRaftProtocol(members []serf.Member) (int, error)

+ type AutopilotPolicy interface

+ PromoteNonVoters func(*structs.AutopilotConfig) error

+ type BasicAutopilot struct

+ func (b *BasicAutopilot) PromoteNonVoters(autopilotConf *structs.AutopilotConfig) error

type Config

+ AutopilotConfig *structs.AutopilotConfig

+ AutopilotInterval time.Duration

+ NonVoter bool

+ SerfFloodInterval time.Duration

+ ServerHealthInterval time.Duration

type ConnPool

+ func (p *ConnPool) DialTimeout(dc string, addr net.Addr, timeout time.Duration) (net.Conn, HalfCloser, error)

type Operator

+ func (op *Operator) AutopilotGetConfiguration(args *structs.DCSpecificRequest, reply *structs.AutopilotConfig) error

+ func (op *Operator) AutopilotSetConfiguration(args *structs.AutopilotSetConfigRequest, reply *bool) error

+ func (op *Operator) RaftRemovePeerByID(args *structs.RaftRemovePeerRequest, reply *struct{}) error

+ func (op *Operator) ServerHealth(args *structs.DCSpecificRequest, reply *structs.OperatorHealthReply) error

type Server

+ func (s *Server) Flood(portFn servers.FloodPortFn, global *serf.Serf)

+ func (s *Server) FloodNotify()

+ type StatsFetcher struct

+ func NewStatsFetcher(logger *log.Logger, pool *ConnPool, datacenter string) *StatsFetcher

+ func (f *StatsFetcher) Fetch(ctx context.Context, servers []*agent.Server) map[string]*structs.ServerStats

type Status

+ func (s *Status) RaftStats(args struct{}, reply *structs.ServerStats) error

Feb 6, 2017

Changes in this version

type Config

+ TLSMinVersion string

Jan 26, 2017

Changes in this version

type Config

+ NodeID types.NodeID

Dec 19, 2016

Changes in this version

type Config

+ ACLAgentToken string

+ ACLEnforceVersion8 bool

+ func (c *Config) GetTokenForAgent() string

Nov 10, 2016

Changes in this version

+ func SnapshotRPC(pool *ConnPool, dc string, addr net.Addr, args *structs.SnapshotRequest, ...) (io.ReadCloser, error)

type Client

+ func (c *Client) SnapshotRPC(args *structs.SnapshotRequest, in io.Reader, out io.Writer, ...) error

type ConnPool

+ func (p *ConnPool) Dial(dc string, addr net.Addr) (net.Conn, HalfCloser, error)

+ type HalfCloser interface

+ CloseWrite func() error

type Server

+ func (s *Server) SnapshotRPC(args *structs.SnapshotRequest, in io.Reader, out io.Writer, ...) error

+ type SnapshotReplyFn func(reply *structs.SnapshotResponse) error

Sep 14, 2016

Changes in this version

+ const DefaultRaftMultiplier

+ const MaxRaftMultiplier

+ func FilterTxnResults(acl acl.ACL, results structs.TxnResults) structs.TxnResults

+ func GetPublicIPv6() (net.IP, error)

type ACL

+ func (a *ACL) ReplicationStatus(args *structs.DCSpecificRequest, reply *structs.ACLReplicationStatus) error

type Config

+ ACLReplicationApplyLimit int

+ ACLReplicationInterval time.Duration

+ ACLReplicationToken string

+ RPCHoldTimeout time.Duration

+ func (c *Config) ScaleRaft(raftMultRaw uint)

type ConnPool

+ func (p *ConnPool) PingConsulServer(s *agent.Server) (bool, error)

+ type Operator struct

+ func (op *Operator) RaftGetConfiguration(args *structs.DCSpecificRequest, reply *structs.RaftConfigurationResponse) error

+ func (op *Operator) RaftRemovePeerByAddress(args *structs.RaftPeerByAddressRequest, reply *struct{}) error

type Server

+ func (s *Server) IsACLReplicationEnabled() bool

+ type Txn struct

+ func (t *Txn) Apply(args *structs.TxnRequest, reply *structs.TxnResponse) error

+ func (t *Txn) Read(args *structs.TxnReadRequest, reply *structs.TxnReadResponse) error

Mar 16, 2016

Changes in this version

type PreparedQuery

+ func (p *PreparedQuery) Explain(args *structs.PreparedQueryExecuteRequest, ...) error

Jan 6, 2016

Changes in this version

type Config

+ DevMode bool

Dec 3, 2015

Changes in this version

+ const ProtocolVersion2Compatible

+ var ErrQueryNotFound = errors.New("Query not found")

+ func CanServersUnderstandProtocol(members []serf.Member, version uint8) (bool, error)

type Client

+ func (c *Client) GetCoordinate() (*coordinate.Coordinate, error)

type Config

+ CoordinateUpdateBatchSize int

+ CoordinateUpdateMaxBatches int

+ CoordinateUpdatePeriod time.Duration

+ DisableCoordinates bool

+ type Coordinate struct

+ func NewCoordinate(srv *Server) *Coordinate

+ func (c *Coordinate) ListDatacenters(args *struct{}, reply *[]structs.DatacenterMap) error

+ func (c *Coordinate) ListNodes(args *structs.DCSpecificRequest, reply *structs.IndexedCoordinates) error

+ func (c *Coordinate) Update(args *structs.CoordinateUpdateRequest, reply *struct{}) (err error)

+ type PreparedQuery struct

+ func (p *PreparedQuery) Apply(args *structs.PreparedQueryRequest, reply *string) (err error)

+ func (p *PreparedQuery) Execute(args *structs.PreparedQueryExecuteRequest, ...) error

+ func (p *PreparedQuery) ExecuteRemote(args *structs.PreparedQueryExecuteRemoteRequest, ...) error

+ func (p *PreparedQuery) Get(args *structs.PreparedQuerySpecificRequest, ...) error

+ func (p *PreparedQuery) List(args *structs.DCSpecificRequest, reply *structs.IndexedPreparedQueries) error

type Server

+ func (s *Server) GetLANCoordinate() (*coordinate.Coordinate, error)

+ func (s *Server) GetWANCoordinate() (*coordinate.Coordinate, error)

+ func (s *Server) InjectEndpoint(endpoint interface{}) error

May 18, 2015

Changes in this version

type NotifyGroup

+ func (n *NotifyGroup) Clear(ch chan struct{})

type StateStore

+ func (s *StateStore) StopWatch(tables MDBTables, notify chan struct{})

+ func (s *StateStore) StopWatchKV(prefix string, notify chan struct{})

May 13, 2015

Changes in this version

type Config

+ Domain string

+ SessionTTLMin time.Duration

+ VerifyServerHostname bool

type StreamClient

+ func (sc *StreamClient) Close()

Feb 19, 2015

Changes in this version

type Client

+ func (c *Client) Encrypted() bool

+ func (c *Client) KeyManagerLAN() *serf.KeyManager

type Config

+ TombstoneTTL time.Duration

+ TombstoneTTLGranularity time.Duration

type Internal

+ func (m *Internal) KeyringOperation(args *structs.KeyringRequest, reply *structs.KeyringResponses) error

type MDBTable

+ func (t *MDBTable) GetTxnLimit(tx *MDBTxn, limit int, index string, parts ...string) ([]interface{}, error)

type Server

+ func (s *Server) Encrypted() bool

+ func (s *Server) KeyManagerLAN() *serf.KeyManager

+ func (s *Server) KeyManagerWAN() *serf.KeyManager

type Session

+ func (s *Session) Renew(args *structs.SessionSpecificRequest, reply *structs.IndexedSessions) error

type StateSnapshot

+ func (s *StateSnapshot) TombstoneDump(stream chan<- interface{}) error

type StateStore

+ func (s *StateStore) KVSDeleteCheckAndSet(index uint64, key string, casIndex uint64) (bool, error)

+ func (s *StateStore) ReapTombstones(index uint64) error

+ func (s *StateStore) TombstoneRestore(d *structs.DirEntry) error

+ func (s *StateStore) WatchKV(prefix string, notify chan struct{})

+ type TombstoneGC struct

+ func NewTombstoneGC(ttl, granularity time.Duration) (*TombstoneGC, error)

+ func (t *TombstoneGC) ExpireCh() <-chan uint64

+ func (t *TombstoneGC) Hint(index uint64)

+ func (t *TombstoneGC) PendingExpiration() bool

+ func (t *TombstoneGC) SetEnabled(enabled bool)

Oct 20, 2014

Changes in this version

type StateStore

+ func NewStateStorePath(path string, logOutput io.Writer) (*StateStore, error)

Sep 5, 2014

Changes in this version

+ func FilterDirEnt(acl acl.ACL, ent structs.DirEntries) structs.DirEntries

+ func FilterEntries(f Filter) int

+ func FilterKeys(acl acl.ACL, keys []string) []string

+ func ToLowerList(l []string) []string

+ type ACL struct

+ func (a *ACL) Apply(args *structs.ACLRequest, reply *string) error

+ func (a *ACL) Get(args *structs.ACLSpecificRequest, reply *structs.IndexedACLs) error

+ func (a *ACL) GetPolicy(args *structs.ACLPolicyRequest, reply *structs.ACLPolicy) error

+ func (a *ACL) List(args *structs.DCSpecificRequest, reply *structs.IndexedACLs) error

type Client

+ func (c *Client) UserEvent(name string, payload []byte) error

type Config

+ ACLDatacenter string

+ ACLDefaultPolicy string

+ ACLDownPolicy string

+ ACLMasterToken string

+ ACLTTL time.Duration

+ ACLToken string

+ UserEventHandler func(serf.UserEvent)

+ func (c *Config) CheckACL() error

+ type Filter interface

+ Filter func(int) bool

+ Len func() int

+ Move func(dst, src, span int)

type Internal

+ func (m *Internal) EventFire(args *structs.EventFireRequest, reply *structs.EventFireResponse) error

type MDBIndex

+ CaseInsensitive bool

type Server

+ func (s *Server) UserEvent(name string, payload []byte) error

type StateSnapshot

+ func (s *StateSnapshot) ACLList() ([]*structs.ACL, error)

type StateStore

+ func (s *StateStore) ACLDelete(index uint64, id string) error

+ func (s *StateStore) ACLGet(id string) (uint64, *structs.ACL, error)

+ func (s *StateStore) ACLList() (uint64, []*structs.ACL, error)

+ func (s *StateStore) ACLRestore(acl *structs.ACL) error

+ func (s *StateStore) ACLSet(index uint64, acl *structs.ACL, allowCreate bool) error

+ func (s *StateStore) EnsureRegistration(index uint64, req *structs.RegisterRequest) error

Jul 21, 2014

Changes in this version

type Config

+ BootstrapExpect int

Jun 13, 2014

Changes in this version

+ const SerfCheckAliveOutput

+ const SerfCheckFailedOutput

type Client

+ func (c *Client) LocalMember() serf.Member

type Config

+ Build string

+ RejoinAfterLeave bool

+ ServerName string

+ func (c *Config) AppendCA(pool *x509.CertPool) error

type Interface

+ LocalMember func() serf.Member

type MDBTable

+ func (t *MDBTable) SetMaxLastIndexTxn(tx *MDBTxn, index uint64) error

type MDBTxn

+ func (t *MDBTxn) Defer(f func())

type Server

+ func (c *Server) LocalMember() serf.Member

+ type Session struct

+ func (s *Session) Apply(args *structs.SessionRequest, reply *string) error

+ func (s *Session) Get(args *structs.SessionSpecificRequest, reply *structs.IndexedSessions) error

+ func (s *Session) List(args *structs.DCSpecificRequest, reply *structs.IndexedSessions) error

+ func (s *Session) NodeSessions(args *structs.NodeSpecificRequest, reply *structs.IndexedSessions) error

type StateSnapshot

+ func (s *StateSnapshot) SessionList() ([]*structs.Session, error)

type StateStore

+ func (s *StateStore) KVSLock(index uint64, d *structs.DirEntry) (bool, error)

+ func (s *StateStore) KVSLockDelay(key string) time.Time

+ func (s *StateStore) KVSUnlock(index uint64, d *structs.DirEntry) (bool, error)

+ func (s *StateStore) NodeSessions(node string) (uint64, []*structs.Session, error)

+ func (s *StateStore) SessionCreate(index uint64, session *structs.Session) error

+ func (s *StateStore) SessionDestroy(index uint64, id string) error

+ func (s *StateStore) SessionGet(id string) (uint64, *structs.Session, error)

+ func (s *StateStore) SessionList() (uint64, []*structs.Session, error)

+ func (s *StateStore) SessionRestore(session *structs.Session) error

+ type StreamClient struct

May 1, 2014

Changes in this version

+ type Internal struct

+ func (m *Internal) NodeDump(args *structs.DCSpecificRequest, reply *structs.IndexedNodeDump) error

+ func (m *Internal) NodeInfo(args *structs.NodeSpecificRequest, reply *structs.IndexedNodeDump) error

type KVS

+ func (k *KVS) ListKeys(args *structs.KeyListRequest, reply *structs.IndexedKeyList) error

type StateStore

+ func (s *StateStore) KVSListKeys(prefix, seperator string) (uint64, []string, error)

+ func (s *StateStore) NodeDump() (uint64, structs.NodeDump)

+ func (s *StateStore) NodeInfo(node string) (uint64, structs.NodeDump)

Apr 16, 2014

Changes in this version

+ const ConsulServiceID

+ const ConsulServiceName

+ const DefaultDC

+ const DefaultLANSerfPort

+ const DefaultWANSerfPort

+ const ProtocolVersionMax

+ const ProtocolVersionMin

+ const SerfCheckID

+ const SerfCheckName

+ const StatusReap

+ var DefaultRPCAddr = &net.TCPAddr

+ func DefaultIndexFunc(idx *MDBIndex, parts []string) string

+ func DefaultIndexPrefixFunc(idx *MDBIndex, parts []string) string

+ func GetPrivateIP() (*net.IPNet, error)

+ func NewFSM(logOutput io.Writer) (*consulFSM, error)

+ type Catalog struct

+ func (c *Catalog) Deregister(args *structs.DeregisterRequest, reply *struct{}) error

+ func (c *Catalog) ListDatacenters(args *struct{}, reply *[]string) error

+ func (c *Catalog) ListNodes(args *structs.DCSpecificRequest, reply *structs.IndexedNodes) error

+ func (c *Catalog) ListServices(args *structs.DCSpecificRequest, reply *structs.IndexedServices) error

+ func (c *Catalog) NodeServices(args *structs.NodeSpecificRequest, reply *structs.IndexedNodeServices) error

+ func (c *Catalog) Register(args *structs.RegisterRequest, reply *struct{}) error

+ func (c *Catalog) ServiceNodes(args *structs.ServiceSpecificRequest, reply *structs.IndexedServiceNodes) error

+ type Client struct

+ func NewClient(config *Config) (*Client, error)

+ func (c *Client) JoinLAN(addrs []string) (int, error)

+ func (c *Client) LANMembers() []serf.Member

+ func (c *Client) Leave() error

+ func (c *Client) RPC(method string, args interface{}, reply interface{}) error

+ func (c *Client) RemoveFailedNode(node string) error

+ func (c *Client) Shutdown() error

+ func (c *Client) Stats() map[string]map[string]string

+ type Config struct

+ Bootstrap bool

+ CAFile string

+ CertFile string

+ DataDir string

+ Datacenter string

+ KeyFile string

+ LogOutput io.Writer

+ NodeName string

+ ProtocolVersion uint8

+ RPCAddr *net.TCPAddr

+ RPCAdvertise *net.TCPAddr

+ RaftConfig *raft.Config

+ ReconcileInterval time.Duration

+ SerfLANConfig *serf.Config

+ SerfWANConfig *serf.Config

+ ServerUp func()

+ VerifyIncoming bool

+ VerifyOutgoing bool

+ func DefaultConfig() *Config

+ func (c *Config) CACertificate() (*x509.Certificate, error)

+ func (c *Config) CheckVersion() error

+ func (c *Config) IncomingTLSConfig() (*tls.Config, error)

+ func (c *Config) KeyPair() (*tls.Certificate, error)

+ func (c *Config) OutgoingTLSConfig() (*tls.Config, error)

+ type Conn struct

+ func (c *Conn) Close() error

+ type ConnPool struct

+ func NewPool(maxTime time.Duration, tlsConfig *tls.Config) *ConnPool

+ func (p *ConnPool) RPC(addr net.Addr, method string, args interface{}, reply interface{}) error

+ func (p *ConnPool) Shutdown() error

+ type Health struct

+ func (h *Health) ChecksInState(args *structs.ChecksInStateRequest, reply *structs.IndexedHealthChecks) error

+ func (h *Health) NodeChecks(args *structs.NodeSpecificRequest, reply *structs.IndexedHealthChecks) error

+ func (h *Health) ServiceChecks(args *structs.ServiceSpecificRequest, reply *structs.IndexedHealthChecks) error

+ func (h *Health) ServiceNodes(args *structs.ServiceSpecificRequest, reply *structs.IndexedCheckServiceNodes) error

+ type IndexFunc func(*MDBIndex, []string) string

+ type Interface interface

+ LANMembers func() []serf.Member

+ RPC func(method string, args interface{}, reply interface{}) error

+ type KVS struct

+ func (k *KVS) Apply(args *structs.KVSRequest, reply *bool) error

+ func (k *KVS) Get(args *structs.KeyRequest, reply *structs.IndexedDirEntries) error

+ func (k *KVS) List(args *structs.KeyRequest, reply *structs.IndexedDirEntries) error

+ type MDBIndex struct

+ AllowBlank bool

+ Fields []string

+ IdxFunc IndexFunc

+ RealIndex string

+ Unique bool

+ Virtual bool

+ type MDBTable struct

+ Decoder func([]byte) interface{}

+ Encoder func(interface{}) []byte

+ Env *mdb.Env

+ Indexes map[string]*MDBIndex

+ Name string

+ func (t *MDBTable) Delete(index string, parts ...string) (num int, err error)

+ func (t *MDBTable) DeleteTxn(tx *MDBTxn, index string, parts ...string) (int, error)

+ func (t *MDBTable) Get(index string, parts ...string) (uint64, []interface{}, error)

+ func (t *MDBTable) GetTxn(tx *MDBTxn, index string, parts ...string) ([]interface{}, error)

+ func (t *MDBTable) Init() error

+ func (t *MDBTable) Insert(obj interface{}) error

+ func (t *MDBTable) InsertTxn(tx *MDBTxn, obj interface{}) error

+ func (t *MDBTable) LastIndex() (uint64, error)

+ func (t *MDBTable) LastIndexTxn(tx *MDBTxn) (uint64, error)

+ func (t *MDBTable) SetLastIndex(index uint64) error

+ func (t *MDBTable) SetLastIndexTxn(tx *MDBTxn, index uint64) error

+ func (t *MDBTable) StartTxn(readonly bool, mdbTxn *MDBTxn) (*MDBTxn, error)

+ func (t *MDBTable) StreamTxn(stream chan<- interface{}, tx *MDBTxn, index string, parts ...string) error

+ type MDBTables []*MDBTable

+ func (t MDBTables) LastIndexTxn(tx *MDBTxn) (uint64, error)

+ func (t MDBTables) StartTxn(readonly bool) (*MDBTxn, error)

+ type MDBTxn struct

+ func (t *MDBTxn) Abort()

+ func (t *MDBTxn) Commit() error

+ type NotifyGroup struct

+ func (n *NotifyGroup) Notify()

+ func (n *NotifyGroup) Wait(ch chan struct{})

+ func (n *NotifyGroup) WaitCh() chan struct{}

+ type RPCType byte

+ type Raft struct

+ func (r *Raft) RemovePeer(args string, reply *struct{}) error

+ func (r *Raft) Snapshot(args struct{}, reply *struct{}) error

+ type RaftLayer struct

+ func NewRaftLayer(addr net.Addr, tlsConfig *tls.Config) *RaftLayer

+ func (l *RaftLayer) Accept() (net.Conn, error)

+ func (l *RaftLayer) Addr() net.Addr

+ func (l *RaftLayer) Close() error

+ func (l *RaftLayer) Dial(address string, timeout time.Duration) (net.Conn, error)

+ func (l *RaftLayer) Handoff(c net.Conn) error

+ type Server struct

+ func NewServer(config *Config) (*Server, error)

+ func (s *Server) IsLeader() bool

+ func (s *Server) JoinLAN(addrs []string) (int, error)

+ func (s *Server) JoinWAN(addrs []string) (int, error)

+ func (s *Server) LANMembers() []serf.Member

+ func (s *Server) Leave() error

+ func (s *Server) RPC(method string, args interface{}, reply interface{}) error

+ func (s *Server) RemoveFailedNode(node string) error

+ func (s *Server) Shutdown() error

+ func (s *Server) Stats() map[string]map[string]string

+ func (s *Server) WANMembers() []serf.Member

+ type StateSnapshot struct

+ func (s *StateSnapshot) Close() error

+ func (s *StateSnapshot) KVSDump(stream chan<- interface{}) error

+ func (s *StateSnapshot) LastIndex() uint64

+ func (s *StateSnapshot) NodeChecks(node string) structs.HealthChecks

+ func (s *StateSnapshot) NodeServices(name string) *structs.NodeServices

+ func (s *StateSnapshot) Nodes() structs.Nodes

+ type StateStore struct

+ func NewStateStore(logOutput io.Writer) (*StateStore, error)

+ func (s *StateStore) CheckServiceNodes(service string) (uint64, structs.CheckServiceNodes)

+ func (s *StateStore) CheckServiceTagNodes(service, tag string) (uint64, structs.CheckServiceNodes)

+ func (s *StateStore) ChecksInState(state string) (uint64, structs.HealthChecks)

+ func (s *StateStore) Close() error

+ func (s *StateStore) DeleteNode(index uint64, node string) error

+ func (s *StateStore) DeleteNodeCheck(index uint64, node, id string) error

+ func (s *StateStore) DeleteNodeService(index uint64, node, id string) error

+ func (s *StateStore) EnsureCheck(index uint64, check *structs.HealthCheck) error

+ func (s *StateStore) EnsureNode(index uint64, node structs.Node) error

+ func (s *StateStore) EnsureService(index uint64, node string, ns *structs.NodeService) error

+ func (s *StateStore) GetNode(name string) (uint64, bool, string)

+ func (s *StateStore) KVSCheckAndSet(index uint64, d *structs.DirEntry) (bool, error)

+ func (s *StateStore) KVSDelete(index uint64, key string) error

+ func (s *StateStore) KVSDeleteTree(index uint64, prefix string) error

+ func (s *StateStore) KVSGet(key string) (uint64, *structs.DirEntry, error)

+ func (s *StateStore) KVSList(prefix string) (uint64, structs.DirEntries, error)

+ func (s *StateStore) KVSRestore(d *structs.DirEntry) error

+ func (s *StateStore) KVSSet(index uint64, d *structs.DirEntry) error

+ func (s *StateStore) NodeChecks(node string) (uint64, structs.HealthChecks)

+ func (s *StateStore) NodeServices(name string) (uint64, *structs.NodeServices)

+ func (s *StateStore) Nodes() (uint64, structs.Nodes)

+ func (s *StateStore) QueryTables(q string) MDBTables

+ func (s *StateStore) ServiceChecks(service string) (uint64, structs.HealthChecks)

+ func (s *StateStore) ServiceNodes(service string) (uint64, structs.ServiceNodes)

+ func (s *StateStore) ServiceTagNodes(service, tag string) (uint64, structs.ServiceNodes)

+ func (s *StateStore) Services() (uint64, map[string][]string)

+ func (s *StateStore) Snapshot() (*StateSnapshot, error)

+ func (s *StateStore) Watch(tables MDBTables, notify chan struct{})

+ type Status struct

+ func (s *Status) Leader(args struct{}, reply *string) error

+ func (s *Status) Peers(args struct{}, reply *[]string) error

+ func (s *Status) Ping(args struct{}, reply *struct{}) error