Versions in this module Expand all Collapse all v1 v1.1.4 Oct 31, 2019 v1.1.3 Oct 31, 2019 Changes in this version + type Address struct + Address string + Port int type Agent + ForceLeave func(ctx Ctx, node string) error + Join func(ctx Ctx, address string, wan bool) error + Leave func(ctx Ctx) error + Metrics func(ctx Ctx) (Metrics, error) + SetACLToken func(ctx Ctx, kind, token string) error + type AgentMock struct + ForceLeaveMock mAgentMockForceLeave + JoinMock mAgentMockJoin + LeaveMock mAgentMockLeave + MaintenanceModeMock mAgentMockMaintenanceMode + MembersMock mAgentMockMembers + MetricsMock mAgentMockMetrics + ReloadMock mAgentMockReload + SelfMock mAgentMockSelf + SetACLTokenMock mAgentMockSetACLToken + func NewAgentMock(t minimock.Tester) *AgentMock + func (m *AgentMock) MinimockFinish() + func (m *AgentMock) MinimockForceLeaveDone() bool + func (m *AgentMock) MinimockForceLeaveInspect() + func (m *AgentMock) MinimockJoinDone() bool + func (m *AgentMock) MinimockJoinInspect() + func (m *AgentMock) MinimockLeaveDone() bool + func (m *AgentMock) MinimockLeaveInspect() + func (m *AgentMock) MinimockMaintenanceModeDone() bool + func (m *AgentMock) MinimockMaintenanceModeInspect() + func (m *AgentMock) MinimockMembersDone() bool + func (m *AgentMock) MinimockMembersInspect() + func (m *AgentMock) MinimockMetricsDone() bool + func (m *AgentMock) MinimockMetricsInspect() + func (m *AgentMock) MinimockReloadDone() bool + func (m *AgentMock) MinimockReloadInspect() + func (m *AgentMock) MinimockSelfDone() bool + func (m *AgentMock) MinimockSelfInspect() + func (m *AgentMock) MinimockSetACLTokenDone() bool + func (m *AgentMock) MinimockSetACLTokenInspect() + func (m *AgentMock) MinimockWait(timeout mm_time.Duration) + func (mmForceLeave *AgentMock) ForceLeave(ctx Ctx, node string) (err error) + func (mmForceLeave *AgentMock) ForceLeaveAfterCounter() uint64 + func (mmForceLeave *AgentMock) ForceLeaveBeforeCounter() uint64 + func (mmJoin *AgentMock) Join(ctx Ctx, address string, wan bool) (err error) + func (mmJoin *AgentMock) JoinAfterCounter() uint64 + func (mmJoin *AgentMock) JoinBeforeCounter() uint64 + func (mmLeave *AgentMock) Leave(ctx Ctx) (err error) + func (mmLeave *AgentMock) LeaveAfterCounter() uint64 + func (mmLeave *AgentMock) LeaveBeforeCounter() uint64 + func (mmMaintenanceMode *AgentMock) MaintenanceMode(ctx Ctx, enabled bool, reason string) (err error) + func (mmMaintenanceMode *AgentMock) MaintenanceModeAfterCounter() uint64 + func (mmMaintenanceMode *AgentMock) MaintenanceModeBeforeCounter() uint64 + func (mmMembers *AgentMock) Members(ctx Ctx, wan bool) (aa1 []AgentInfo, err error) + func (mmMembers *AgentMock) MembersAfterCounter() uint64 + func (mmMembers *AgentMock) MembersBeforeCounter() uint64 + func (mmMetrics *AgentMock) Metrics(ctx Ctx) (m1 Metrics, err error) + func (mmMetrics *AgentMock) MetricsAfterCounter() uint64 + func (mmMetrics *AgentMock) MetricsBeforeCounter() uint64 + func (mmReload *AgentMock) Reload(ctx Ctx) (err error) + func (mmReload *AgentMock) ReloadAfterCounter() uint64 + func (mmReload *AgentMock) ReloadBeforeCounter() uint64 + func (mmSelf *AgentMock) Self(ctx Ctx) (a1 AgentInfo, err error) + func (mmSelf *AgentMock) SelfAfterCounter() uint64 + func (mmSelf *AgentMock) SelfBeforeCounter() uint64 + func (mmSetACLToken *AgentMock) SetACLToken(ctx Ctx, kind string, token string) (err error) + func (mmSetACLToken *AgentMock) SetACLTokenAfterCounter() uint64 + func (mmSetACLToken *AgentMock) SetACLTokenBeforeCounter() uint64 + type AgentMockForceLeaveExpectation struct + Counter uint64 + func (e *AgentMockForceLeaveExpectation) Then(err error) *AgentMock + type AgentMockForceLeaveParams struct + type AgentMockForceLeaveResults struct + type AgentMockJoinExpectation struct + Counter uint64 + func (e *AgentMockJoinExpectation) Then(err error) *AgentMock + type AgentMockJoinParams struct + type AgentMockJoinResults struct + type AgentMockLeaveExpectation struct + Counter uint64 + func (e *AgentMockLeaveExpectation) Then(err error) *AgentMock + type AgentMockLeaveParams struct + type AgentMockLeaveResults struct + type AgentMockMaintenanceModeExpectation struct + Counter uint64 + func (e *AgentMockMaintenanceModeExpectation) Then(err error) *AgentMock + type AgentMockMaintenanceModeParams struct + type AgentMockMaintenanceModeResults struct + type AgentMockMembersExpectation struct + Counter uint64 + func (e *AgentMockMembersExpectation) Then(aa1 []AgentInfo, err error) *AgentMock + type AgentMockMembersParams struct + type AgentMockMembersResults struct + type AgentMockMetricsExpectation struct + Counter uint64 + func (e *AgentMockMetricsExpectation) Then(m1 Metrics, err error) *AgentMock + type AgentMockMetricsParams struct + type AgentMockMetricsResults struct + type AgentMockReloadExpectation struct + Counter uint64 + func (e *AgentMockReloadExpectation) Then(err error) *AgentMock + type AgentMockReloadParams struct + type AgentMockReloadResults struct + type AgentMockSelfExpectation struct + Counter uint64 + func (e *AgentMockSelfExpectation) Then(a1 AgentInfo, err error) *AgentMock + type AgentMockSelfParams struct + type AgentMockSelfResults struct + type AgentMockSetACLTokenExpectation struct + Counter uint64 + func (e *AgentMockSetACLTokenExpectation) Then(err error) *AgentMock + type AgentMockSetACLTokenParams struct + type AgentMockSetACLTokenResults struct + type CandidateMock struct + ParticipateMock mCandidateMockParticipate + func NewCandidateMock(t minimock.Tester) *CandidateMock + func (m *CandidateMock) MinimockFinish() + func (m *CandidateMock) MinimockParticipateDone() bool + func (m *CandidateMock) MinimockParticipateInspect() + func (m *CandidateMock) MinimockWait(timeout mm_time.Duration) + func (mmParticipate *CandidateMock) Participate(c1 Ctx, l1 LeadershipConfig, a1 AsLeaderFunc) (l2 LeaderSession, err error) + func (mmParticipate *CandidateMock) ParticipateAfterCounter() uint64 + func (mmParticipate *CandidateMock) ParticipateBeforeCounter() uint64 + type CandidateMockParticipateExpectation struct + Counter uint64 + func (e *CandidateMockParticipateExpectation) Then(l2 LeaderSession, err error) *CandidateMock + type CandidateMockParticipateParams struct + type CandidateMockParticipateResults struct type Catalog + Connect func(Ctx, string, ServiceQuery) ([]Instance, error) + DataCenters func(Ctx) ([]string, error) + type CatalogMock struct + ConnectMock mCatalogMockConnect + DataCentersMock mCatalogMockDataCenters + NodeMock mCatalogMockNode + NodesMock mCatalogMockNodes + ServiceMock mCatalogMockService + ServicesMock mCatalogMockServices + func NewCatalogMock(t minimock.Tester) *CatalogMock + func (m *CatalogMock) MinimockConnectDone() bool + func (m *CatalogMock) MinimockConnectInspect() + func (m *CatalogMock) MinimockDataCentersDone() bool + func (m *CatalogMock) MinimockDataCentersInspect() + func (m *CatalogMock) MinimockFinish() + func (m *CatalogMock) MinimockNodeDone() bool + func (m *CatalogMock) MinimockNodeInspect() + func (m *CatalogMock) MinimockNodesDone() bool + func (m *CatalogMock) MinimockNodesInspect() + func (m *CatalogMock) MinimockServiceDone() bool + func (m *CatalogMock) MinimockServiceInspect() + func (m *CatalogMock) MinimockServicesDone() bool + func (m *CatalogMock) MinimockServicesInspect() + func (m *CatalogMock) MinimockWait(timeout mm_time.Duration) + func (mmConnect *CatalogMock) Connect(c1 Ctx, s1 string, s2 ServiceQuery) (ia1 []Instance, err error) + func (mmConnect *CatalogMock) ConnectAfterCounter() uint64 + func (mmConnect *CatalogMock) ConnectBeforeCounter() uint64 + func (mmDataCenters *CatalogMock) DataCenters(c1 Ctx) (sa1 []string, err error) + func (mmDataCenters *CatalogMock) DataCentersAfterCounter() uint64 + func (mmDataCenters *CatalogMock) DataCentersBeforeCounter() uint64 + func (mmNode *CatalogMock) Node(c1 Ctx, s1 string, n1 NodeQuery) (n2 NodeInfo, err error) + func (mmNode *CatalogMock) NodeAfterCounter() uint64 + func (mmNode *CatalogMock) NodeBeforeCounter() uint64 + func (mmNodes *CatalogMock) Nodes(c1 Ctx, n1 NodesQuery) (na1 []Node, err error) + func (mmNodes *CatalogMock) NodesAfterCounter() uint64 + func (mmNodes *CatalogMock) NodesBeforeCounter() uint64 + func (mmService *CatalogMock) Service(c1 Ctx, s1 string, s2 ServiceQuery) (ia1 []Instance, err error) + func (mmService *CatalogMock) ServiceAfterCounter() uint64 + func (mmService *CatalogMock) ServiceBeforeCounter() uint64 + func (mmServices *CatalogMock) Services(c1 Ctx, s1 ServicesQuery) (m1 map[string][]string, err error) + func (mmServices *CatalogMock) ServicesAfterCounter() uint64 + func (mmServices *CatalogMock) ServicesBeforeCounter() uint64 + type CatalogMockConnectExpectation struct + Counter uint64 + func (e *CatalogMockConnectExpectation) Then(ia1 []Instance, err error) *CatalogMock + type CatalogMockConnectParams struct + type CatalogMockConnectResults struct + type CatalogMockDataCentersExpectation struct + Counter uint64 + func (e *CatalogMockDataCentersExpectation) Then(sa1 []string, err error) *CatalogMock + type CatalogMockDataCentersParams struct + type CatalogMockDataCentersResults struct + type CatalogMockNodeExpectation struct + Counter uint64 + func (e *CatalogMockNodeExpectation) Then(n2 NodeInfo, err error) *CatalogMock + type CatalogMockNodeParams struct + type CatalogMockNodeResults struct + type CatalogMockNodesExpectation struct + Counter uint64 + func (e *CatalogMockNodesExpectation) Then(na1 []Node, err error) *CatalogMock + type CatalogMockNodesParams struct + type CatalogMockNodesResults struct + type CatalogMockServiceExpectation struct + Counter uint64 + func (e *CatalogMockServiceExpectation) Then(ia1 []Instance, err error) *CatalogMock + type CatalogMockServiceParams struct + type CatalogMockServiceResults struct + type CatalogMockServicesExpectation struct + Counter uint64 + func (e *CatalogMockServicesExpectation) Then(m1 map[string][]string, err error) *CatalogMock + type CatalogMockServicesParams struct + type CatalogMockServicesResults struct + type ClientMock struct + ConnectMock mClientMockConnect + CreateSessionMock mClientMockCreateSession + DataCentersMock mClientMockDataCenters + DeleteMock mClientMockDelete + DeleteSessionMock mClientMockDeleteSession + ForceLeaveMock mClientMockForceLeave + GetMock mClientMockGet + JoinMock mClientMockJoin + KeysMock mClientMockKeys + LeaveMock mClientMockLeave + ListSessionsMock mClientMockListSessions + MaintenanceModeMock mClientMockMaintenanceMode + MembersMock mClientMockMembers + MetricsMock mClientMockMetrics + NodeMock mClientMockNode + NodesMock mClientMockNodes + ParticipateMock mClientMockParticipate + PutMock mClientMockPut + ReadSessionMock mClientMockReadSession + RecurseMock mClientMockRecurse + ReloadMock mClientMockReload + RenewSessionMock mClientMockRenewSession + SelfMock mClientMockSelf + ServiceMock mClientMockService + ServicesMock mClientMockServices + SetACLTokenMock mClientMockSetACLToken + func NewClientMock(t minimock.Tester) *ClientMock + func (m *ClientMock) MinimockConnectDone() bool + func (m *ClientMock) MinimockConnectInspect() + func (m *ClientMock) MinimockCreateSessionDone() bool + func (m *ClientMock) MinimockCreateSessionInspect() + func (m *ClientMock) MinimockDataCentersDone() bool + func (m *ClientMock) MinimockDataCentersInspect() + func (m *ClientMock) MinimockDeleteDone() bool + func (m *ClientMock) MinimockDeleteInspect() + func (m *ClientMock) MinimockDeleteSessionDone() bool + func (m *ClientMock) MinimockDeleteSessionInspect() + func (m *ClientMock) MinimockFinish() + func (m *ClientMock) MinimockForceLeaveDone() bool + func (m *ClientMock) MinimockForceLeaveInspect() + func (m *ClientMock) MinimockGetDone() bool + func (m *ClientMock) MinimockGetInspect() + func (m *ClientMock) MinimockJoinDone() bool + func (m *ClientMock) MinimockJoinInspect() + func (m *ClientMock) MinimockKeysDone() bool + func (m *ClientMock) MinimockKeysInspect() + func (m *ClientMock) MinimockLeaveDone() bool + func (m *ClientMock) MinimockLeaveInspect() + func (m *ClientMock) MinimockListSessionsDone() bool + func (m *ClientMock) MinimockListSessionsInspect() + func (m *ClientMock) MinimockMaintenanceModeDone() bool + func (m *ClientMock) MinimockMaintenanceModeInspect() + func (m *ClientMock) MinimockMembersDone() bool + func (m *ClientMock) MinimockMembersInspect() + func (m *ClientMock) MinimockMetricsDone() bool + func (m *ClientMock) MinimockMetricsInspect() + func (m *ClientMock) MinimockNodeDone() bool + func (m *ClientMock) MinimockNodeInspect() + func (m *ClientMock) MinimockNodesDone() bool + func (m *ClientMock) MinimockNodesInspect() + func (m *ClientMock) MinimockParticipateDone() bool + func (m *ClientMock) MinimockParticipateInspect() + func (m *ClientMock) MinimockPutDone() bool + func (m *ClientMock) MinimockPutInspect() + func (m *ClientMock) MinimockReadSessionDone() bool + func (m *ClientMock) MinimockReadSessionInspect() + func (m *ClientMock) MinimockRecurseDone() bool + func (m *ClientMock) MinimockRecurseInspect() + func (m *ClientMock) MinimockReloadDone() bool + func (m *ClientMock) MinimockReloadInspect() + func (m *ClientMock) MinimockRenewSessionDone() bool + func (m *ClientMock) MinimockRenewSessionInspect() + func (m *ClientMock) MinimockSelfDone() bool + func (m *ClientMock) MinimockSelfInspect() + func (m *ClientMock) MinimockServiceDone() bool + func (m *ClientMock) MinimockServiceInspect() + func (m *ClientMock) MinimockServicesDone() bool + func (m *ClientMock) MinimockServicesInspect() + func (m *ClientMock) MinimockSetACLTokenDone() bool + func (m *ClientMock) MinimockSetACLTokenInspect() + func (m *ClientMock) MinimockWait(timeout mm_time.Duration) + func (mmConnect *ClientMock) Connect(c1 Ctx, s1 string, s2 ServiceQuery) (ia1 []Instance, err error) + func (mmConnect *ClientMock) ConnectAfterCounter() uint64 + func (mmConnect *ClientMock) ConnectBeforeCounter() uint64 + func (mmCreateSession *ClientMock) CreateSession(c1 Ctx, s1 SessionConfig) (s2 SessionID, err error) + func (mmCreateSession *ClientMock) CreateSessionAfterCounter() uint64 + func (mmCreateSession *ClientMock) CreateSessionBeforeCounter() uint64 + func (mmDataCenters *ClientMock) DataCenters(c1 Ctx) (sa1 []string, err error) + func (mmDataCenters *ClientMock) DataCentersAfterCounter() uint64 + func (mmDataCenters *ClientMock) DataCentersBeforeCounter() uint64 + func (mmDelete *ClientMock) Delete(c1 Ctx, s1 string, q1 Query) (err error) + func (mmDelete *ClientMock) DeleteAfterCounter() uint64 + func (mmDelete *ClientMock) DeleteBeforeCounter() uint64 + func (mmDeleteSession *ClientMock) DeleteSession(c1 Ctx, s1 SessionQuery) (err error) + func (mmDeleteSession *ClientMock) DeleteSessionAfterCounter() uint64 + func (mmDeleteSession *ClientMock) DeleteSessionBeforeCounter() uint64 + func (mmForceLeave *ClientMock) ForceLeave(ctx Ctx, node string) (err error) + func (mmForceLeave *ClientMock) ForceLeaveAfterCounter() uint64 + func (mmForceLeave *ClientMock) ForceLeaveBeforeCounter() uint64 + func (mmGet *ClientMock) Get(c1 Ctx, s1 string, q1 Query) (s2 string, err error) + func (mmGet *ClientMock) GetAfterCounter() uint64 + func (mmGet *ClientMock) GetBeforeCounter() uint64 + func (mmJoin *ClientMock) Join(ctx Ctx, address string, wan bool) (err error) + func (mmJoin *ClientMock) JoinAfterCounter() uint64 + func (mmJoin *ClientMock) JoinBeforeCounter() uint64 + func (mmKeys *ClientMock) Keys(c1 Ctx, s1 string, q1 Query) (sa1 []string, err error) + func (mmKeys *ClientMock) KeysAfterCounter() uint64 + func (mmKeys *ClientMock) KeysBeforeCounter() uint64 + func (mmLeave *ClientMock) Leave(ctx Ctx) (err error) + func (mmLeave *ClientMock) LeaveAfterCounter() uint64 + func (mmLeave *ClientMock) LeaveBeforeCounter() uint64 + func (mmListSessions *ClientMock) ListSessions(ctx Ctx, dc string, node string) (m1 map[SessionID]SessionConfig, err error) + func (mmListSessions *ClientMock) ListSessionsAfterCounter() uint64 + func (mmListSessions *ClientMock) ListSessionsBeforeCounter() uint64 + func (mmMaintenanceMode *ClientMock) MaintenanceMode(ctx Ctx, enabled bool, reason string) (err error) + func (mmMaintenanceMode *ClientMock) MaintenanceModeAfterCounter() uint64 + func (mmMaintenanceMode *ClientMock) MaintenanceModeBeforeCounter() uint64 + func (mmMembers *ClientMock) Members(ctx Ctx, wan bool) (aa1 []AgentInfo, err error) + func (mmMembers *ClientMock) MembersAfterCounter() uint64 + func (mmMembers *ClientMock) MembersBeforeCounter() uint64 + func (mmMetrics *ClientMock) Metrics(ctx Ctx) (m1 Metrics, err error) + func (mmMetrics *ClientMock) MetricsAfterCounter() uint64 + func (mmMetrics *ClientMock) MetricsBeforeCounter() uint64 + func (mmNode *ClientMock) Node(c1 Ctx, s1 string, n1 NodeQuery) (n2 NodeInfo, err error) + func (mmNode *ClientMock) NodeAfterCounter() uint64 + func (mmNode *ClientMock) NodeBeforeCounter() uint64 + func (mmNodes *ClientMock) Nodes(c1 Ctx, n1 NodesQuery) (na1 []Node, err error) + func (mmNodes *ClientMock) NodesAfterCounter() uint64 + func (mmNodes *ClientMock) NodesBeforeCounter() uint64 + func (mmParticipate *ClientMock) Participate(c1 Ctx, l1 LeadershipConfig, a1 AsLeaderFunc) (l2 LeaderSession, err error) + func (mmParticipate *ClientMock) ParticipateAfterCounter() uint64 + func (mmParticipate *ClientMock) ParticipateBeforeCounter() uint64 + func (mmPut *ClientMock) Put(c1 Ctx, s1 string, s2 string, q1 Query) (err error) + func (mmPut *ClientMock) PutAfterCounter() uint64 + func (mmPut *ClientMock) PutBeforeCounter() uint64 + func (mmReadSession *ClientMock) ReadSession(c1 Ctx, s1 SessionQuery) (s2 SessionConfig, err error) + func (mmReadSession *ClientMock) ReadSessionAfterCounter() uint64 + func (mmReadSession *ClientMock) ReadSessionBeforeCounter() uint64 + func (mmRecurse *ClientMock) Recurse(c1 Ctx, s1 string, q1 Query) (pa1 []Pair, err error) + func (mmRecurse *ClientMock) RecurseAfterCounter() uint64 + func (mmRecurse *ClientMock) RecurseBeforeCounter() uint64 + func (mmReload *ClientMock) Reload(ctx Ctx) (err error) + func (mmReload *ClientMock) ReloadAfterCounter() uint64 + func (mmReload *ClientMock) ReloadBeforeCounter() uint64 + func (mmRenewSession *ClientMock) RenewSession(c1 Ctx, s1 SessionQuery) (d1 time.Duration, err error) + func (mmRenewSession *ClientMock) RenewSessionAfterCounter() uint64 + func (mmRenewSession *ClientMock) RenewSessionBeforeCounter() uint64 + func (mmSelf *ClientMock) Self(ctx Ctx) (a1 AgentInfo, err error) + func (mmSelf *ClientMock) SelfAfterCounter() uint64 + func (mmSelf *ClientMock) SelfBeforeCounter() uint64 + func (mmService *ClientMock) Service(c1 Ctx, s1 string, s2 ServiceQuery) (ia1 []Instance, err error) + func (mmService *ClientMock) ServiceAfterCounter() uint64 + func (mmService *ClientMock) ServiceBeforeCounter() uint64 + func (mmServices *ClientMock) Services(c1 Ctx, s1 ServicesQuery) (m1 map[string][]string, err error) + func (mmServices *ClientMock) ServicesAfterCounter() uint64 + func (mmServices *ClientMock) ServicesBeforeCounter() uint64 + func (mmSetACLToken *ClientMock) SetACLToken(ctx Ctx, kind string, token string) (err error) + func (mmSetACLToken *ClientMock) SetACLTokenAfterCounter() uint64 + func (mmSetACLToken *ClientMock) SetACLTokenBeforeCounter() uint64 + type ClientMockConnectExpectation struct + Counter uint64 + func (e *ClientMockConnectExpectation) Then(ia1 []Instance, err error) *ClientMock + type ClientMockConnectParams struct + type ClientMockConnectResults struct + type ClientMockCreateSessionExpectation struct + Counter uint64 + func (e *ClientMockCreateSessionExpectation) Then(s2 SessionID, err error) *ClientMock + type ClientMockCreateSessionParams struct + type ClientMockCreateSessionResults struct + type ClientMockDataCentersExpectation struct + Counter uint64 + func (e *ClientMockDataCentersExpectation) Then(sa1 []string, err error) *ClientMock + type ClientMockDataCentersParams struct + type ClientMockDataCentersResults struct + type ClientMockDeleteExpectation struct + Counter uint64 + func (e *ClientMockDeleteExpectation) Then(err error) *ClientMock + type ClientMockDeleteParams struct + type ClientMockDeleteResults struct + type ClientMockDeleteSessionExpectation struct + Counter uint64 + func (e *ClientMockDeleteSessionExpectation) Then(err error) *ClientMock + type ClientMockDeleteSessionParams struct + type ClientMockDeleteSessionResults struct + type ClientMockForceLeaveExpectation struct + Counter uint64 + func (e *ClientMockForceLeaveExpectation) Then(err error) *ClientMock + type ClientMockForceLeaveParams struct + type ClientMockForceLeaveResults struct + type ClientMockGetExpectation struct + Counter uint64 + func (e *ClientMockGetExpectation) Then(s2 string, err error) *ClientMock + type ClientMockGetParams struct + type ClientMockGetResults struct + type ClientMockJoinExpectation struct + Counter uint64 + func (e *ClientMockJoinExpectation) Then(err error) *ClientMock + type ClientMockJoinParams struct + type ClientMockJoinResults struct + type ClientMockKeysExpectation struct + Counter uint64 + func (e *ClientMockKeysExpectation) Then(sa1 []string, err error) *ClientMock + type ClientMockKeysParams struct + type ClientMockKeysResults struct + type ClientMockLeaveExpectation struct + Counter uint64 + func (e *ClientMockLeaveExpectation) Then(err error) *ClientMock + type ClientMockLeaveParams struct + type ClientMockLeaveResults struct + type ClientMockListSessionsExpectation struct + Counter uint64 + func (e *ClientMockListSessionsExpectation) Then(m1 map[SessionID]SessionConfig, err error) *ClientMock + type ClientMockListSessionsParams struct + type ClientMockListSessionsResults struct + type ClientMockMaintenanceModeExpectation struct + Counter uint64 + func (e *ClientMockMaintenanceModeExpectation) Then(err error) *ClientMock + type ClientMockMaintenanceModeParams struct + type ClientMockMaintenanceModeResults struct + type ClientMockMembersExpectation struct + Counter uint64 + func (e *ClientMockMembersExpectation) Then(aa1 []AgentInfo, err error) *ClientMock + type ClientMockMembersParams struct + type ClientMockMembersResults struct + type ClientMockMetricsExpectation struct + Counter uint64 + func (e *ClientMockMetricsExpectation) Then(m1 Metrics, err error) *ClientMock + type ClientMockMetricsParams struct + type ClientMockMetricsResults struct + type ClientMockNodeExpectation struct + Counter uint64 + func (e *ClientMockNodeExpectation) Then(n2 NodeInfo, err error) *ClientMock + type ClientMockNodeParams struct + type ClientMockNodeResults struct + type ClientMockNodesExpectation struct + Counter uint64 + func (e *ClientMockNodesExpectation) Then(na1 []Node, err error) *ClientMock + type ClientMockNodesParams struct + type ClientMockNodesResults struct + type ClientMockParticipateExpectation struct + Counter uint64 + func (e *ClientMockParticipateExpectation) Then(l2 LeaderSession, err error) *ClientMock + type ClientMockParticipateParams struct + type ClientMockParticipateResults struct + type ClientMockPutExpectation struct + Counter uint64 + func (e *ClientMockPutExpectation) Then(err error) *ClientMock + type ClientMockPutParams struct + type ClientMockPutResults struct + type ClientMockReadSessionExpectation struct + Counter uint64 + func (e *ClientMockReadSessionExpectation) Then(s2 SessionConfig, err error) *ClientMock + type ClientMockReadSessionParams struct + type ClientMockReadSessionResults struct + type ClientMockRecurseExpectation struct + Counter uint64 + func (e *ClientMockRecurseExpectation) Then(pa1 []Pair, err error) *ClientMock + type ClientMockRecurseParams struct + type ClientMockRecurseResults struct + type ClientMockReloadExpectation struct + Counter uint64 + func (e *ClientMockReloadExpectation) Then(err error) *ClientMock + type ClientMockReloadParams struct + type ClientMockReloadResults struct + type ClientMockRenewSessionExpectation struct + Counter uint64 + func (e *ClientMockRenewSessionExpectation) Then(d1 time.Duration, err error) *ClientMock + type ClientMockRenewSessionParams struct + type ClientMockRenewSessionResults struct + type ClientMockSelfExpectation struct + Counter uint64 + func (e *ClientMockSelfExpectation) Then(a1 AgentInfo, err error) *ClientMock + type ClientMockSelfParams struct + type ClientMockSelfResults struct + type ClientMockServiceExpectation struct + Counter uint64 + func (e *ClientMockServiceExpectation) Then(ia1 []Instance, err error) *ClientMock + type ClientMockServiceParams struct + type ClientMockServiceResults struct + type ClientMockServicesExpectation struct + Counter uint64 + func (e *ClientMockServicesExpectation) Then(m1 map[string][]string, err error) *ClientMock + type ClientMockServicesParams struct + type ClientMockServicesResults struct + type ClientMockSetACLTokenExpectation struct + Counter uint64 + func (e *ClientMockSetACLTokenExpectation) Then(err error) *ClientMock + type ClientMockSetACLTokenParams struct + type ClientMockSetACLTokenResults struct type ClientOptions + HTTPClient *http.Client + type Counter struct + Count int + Labels map[string]string + Max int + Mean float64 + Min int + Name string + Rate float64 + Stddev float64 + Sum int + type Ctx = context.Context + type Gauge struct + Labels map[string]string + Name string + Value int + type Instance struct + Address string + Datacenter string + ID string + Node string + NodeMeta map[string]string + ServiceAddress string + ServiceConnect ServiceConnect + ServiceEnableTagOverride bool + ServiceID string + ServiceMeta map[string]string + ServiceName string + ServicePort int + ServiceProxy Proxy + ServiceProxyDestination string + ServiceTaggedAddresses map[string]Address + ServiceTags []string + TaggedAddresses map[string]string + type KVMock struct + DeleteMock mKVMockDelete + GetMock mKVMockGet + KeysMock mKVMockKeys + PutMock mKVMockPut + RecurseMock mKVMockRecurse + func NewKVMock(t minimock.Tester) *KVMock + func (m *KVMock) MinimockDeleteDone() bool + func (m *KVMock) MinimockDeleteInspect() + func (m *KVMock) MinimockFinish() + func (m *KVMock) MinimockGetDone() bool + func (m *KVMock) MinimockGetInspect() + func (m *KVMock) MinimockKeysDone() bool + func (m *KVMock) MinimockKeysInspect() + func (m *KVMock) MinimockPutDone() bool + func (m *KVMock) MinimockPutInspect() + func (m *KVMock) MinimockRecurseDone() bool + func (m *KVMock) MinimockRecurseInspect() + func (m *KVMock) MinimockWait(timeout mm_time.Duration) + func (mmDelete *KVMock) Delete(c1 Ctx, s1 string, q1 Query) (err error) + func (mmDelete *KVMock) DeleteAfterCounter() uint64 + func (mmDelete *KVMock) DeleteBeforeCounter() uint64 + func (mmGet *KVMock) Get(c1 Ctx, s1 string, q1 Query) (s2 string, err error) + func (mmGet *KVMock) GetAfterCounter() uint64 + func (mmGet *KVMock) GetBeforeCounter() uint64 + func (mmKeys *KVMock) Keys(c1 Ctx, s1 string, q1 Query) (sa1 []string, err error) + func (mmKeys *KVMock) KeysAfterCounter() uint64 + func (mmKeys *KVMock) KeysBeforeCounter() uint64 + func (mmPut *KVMock) Put(c1 Ctx, s1 string, s2 string, q1 Query) (err error) + func (mmPut *KVMock) PutAfterCounter() uint64 + func (mmPut *KVMock) PutBeforeCounter() uint64 + func (mmRecurse *KVMock) Recurse(c1 Ctx, s1 string, q1 Query) (pa1 []Pair, err error) + func (mmRecurse *KVMock) RecurseAfterCounter() uint64 + func (mmRecurse *KVMock) RecurseBeforeCounter() uint64 + type KVMockDeleteExpectation struct + Counter uint64 + func (e *KVMockDeleteExpectation) Then(err error) *KVMock + type KVMockDeleteParams struct + type KVMockDeleteResults struct + type KVMockGetExpectation struct + Counter uint64 + func (e *KVMockGetExpectation) Then(s2 string, err error) *KVMock + type KVMockGetParams struct + type KVMockGetResults struct + type KVMockKeysExpectation struct + Counter uint64 + func (e *KVMockKeysExpectation) Then(sa1 []string, err error) *KVMock + type KVMockKeysParams struct + type KVMockKeysResults struct + type KVMockPutExpectation struct + Counter uint64 + func (e *KVMockPutExpectation) Then(err error) *KVMock + type KVMockPutParams struct + type KVMockPutResults struct + type KVMockRecurseExpectation struct + Counter uint64 + func (e *KVMockRecurseExpectation) Then(pa1 []Pair, err error) *KVMock + type KVMockRecurseParams struct + type KVMockRecurseResults struct + type LeaderSessionMock struct + AbdicateMock mLeaderSessionMockAbdicate + CurrentMock mLeaderSessionMockCurrent + SessionIDMock mLeaderSessionMockSessionID + func NewLeaderSessionMock(t minimock.Tester) *LeaderSessionMock + func (m *LeaderSessionMock) MinimockAbdicateDone() bool + func (m *LeaderSessionMock) MinimockAbdicateInspect() + func (m *LeaderSessionMock) MinimockCurrentDone() bool + func (m *LeaderSessionMock) MinimockCurrentInspect() + func (m *LeaderSessionMock) MinimockFinish() + func (m *LeaderSessionMock) MinimockSessionIDDone() bool + func (m *LeaderSessionMock) MinimockSessionIDInspect() + func (m *LeaderSessionMock) MinimockWait(timeout mm_time.Duration) + func (mmAbdicate *LeaderSessionMock) Abdicate(c1 Ctx) (err error) + func (mmAbdicate *LeaderSessionMock) AbdicateAfterCounter() uint64 + func (mmAbdicate *LeaderSessionMock) AbdicateBeforeCounter() uint64 + func (mmCurrent *LeaderSessionMock) Current(c1 Ctx) (s1 string, err error) + func (mmCurrent *LeaderSessionMock) CurrentAfterCounter() uint64 + func (mmCurrent *LeaderSessionMock) CurrentBeforeCounter() uint64 + func (mmSessionID *LeaderSessionMock) SessionID(c1 Ctx) (s1 string) + func (mmSessionID *LeaderSessionMock) SessionIDAfterCounter() uint64 + func (mmSessionID *LeaderSessionMock) SessionIDBeforeCounter() uint64 + type LeaderSessionMockAbdicateExpectation struct + Counter uint64 + func (e *LeaderSessionMockAbdicateExpectation) Then(err error) *LeaderSessionMock + type LeaderSessionMockAbdicateParams struct + type LeaderSessionMockAbdicateResults struct + type LeaderSessionMockCurrentExpectation struct + Counter uint64 + func (e *LeaderSessionMockCurrentExpectation) Then(s1 string, err error) *LeaderSessionMock + type LeaderSessionMockCurrentParams struct + type LeaderSessionMockCurrentResults struct + type LeaderSessionMockSessionIDExpectation struct + Counter uint64 + func (e *LeaderSessionMockSessionIDExpectation) Then(s1 string) *LeaderSessionMock + type LeaderSessionMockSessionIDParams struct + type LeaderSessionMockSessionIDResults struct + type Metrics struct + Counters []Counter + Gauges []Gauge + Samples []Sample + Timestamp string + type NodeQuery struct + DC string + Filter string + type NodesQuery struct + DC string + Filter string + Near string + NodeMeta []Pair + type Pair struct + Key string + Value string + func (p Pair) String() string + type Proxy struct + DestinationServiceID string + DestinationServiceName string + LocalServiceAddress string + LocalServicePort int + type Query struct + DC string + type Sample struct + Count int + Labels map[string]string + Max float64 + Mean float64 + Min float64 + Name string + Rate float64 + Stddev float64 + Sum float64 + type ServiceConnect struct + Native bool + type ServiceQuery struct + DC string + Filter string + Near string + NodeMeta []Pair + Tags []string + type ServicesQuery struct + DC string + NodeMeta []Pair type SessionConfig + DC string + type SessionMock struct + CreateSessionMock mSessionMockCreateSession + DeleteSessionMock mSessionMockDeleteSession + ListSessionsMock mSessionMockListSessions + ReadSessionMock mSessionMockReadSession + RenewSessionMock mSessionMockRenewSession + func NewSessionMock(t minimock.Tester) *SessionMock + func (m *SessionMock) MinimockCreateSessionDone() bool + func (m *SessionMock) MinimockCreateSessionInspect() + func (m *SessionMock) MinimockDeleteSessionDone() bool + func (m *SessionMock) MinimockDeleteSessionInspect() + func (m *SessionMock) MinimockFinish() + func (m *SessionMock) MinimockListSessionsDone() bool + func (m *SessionMock) MinimockListSessionsInspect() + func (m *SessionMock) MinimockReadSessionDone() bool + func (m *SessionMock) MinimockReadSessionInspect() + func (m *SessionMock) MinimockRenewSessionDone() bool + func (m *SessionMock) MinimockRenewSessionInspect() + func (m *SessionMock) MinimockWait(timeout mm_time.Duration) + func (mmCreateSession *SessionMock) CreateSession(c1 Ctx, s1 SessionConfig) (s2 SessionID, err error) + func (mmCreateSession *SessionMock) CreateSessionAfterCounter() uint64 + func (mmCreateSession *SessionMock) CreateSessionBeforeCounter() uint64 + func (mmDeleteSession *SessionMock) DeleteSession(c1 Ctx, s1 SessionQuery) (err error) + func (mmDeleteSession *SessionMock) DeleteSessionAfterCounter() uint64 + func (mmDeleteSession *SessionMock) DeleteSessionBeforeCounter() uint64 + func (mmListSessions *SessionMock) ListSessions(ctx Ctx, dc string, node string) (m1 map[SessionID]SessionConfig, err error) + func (mmListSessions *SessionMock) ListSessionsAfterCounter() uint64 + func (mmListSessions *SessionMock) ListSessionsBeforeCounter() uint64 + func (mmReadSession *SessionMock) ReadSession(c1 Ctx, s1 SessionQuery) (s2 SessionConfig, err error) + func (mmReadSession *SessionMock) ReadSessionAfterCounter() uint64 + func (mmReadSession *SessionMock) ReadSessionBeforeCounter() uint64 + func (mmRenewSession *SessionMock) RenewSession(c1 Ctx, s1 SessionQuery) (d1 time.Duration, err error) + func (mmRenewSession *SessionMock) RenewSessionAfterCounter() uint64 + func (mmRenewSession *SessionMock) RenewSessionBeforeCounter() uint64 + type SessionMockCreateSessionExpectation struct + Counter uint64 + func (e *SessionMockCreateSessionExpectation) Then(s2 SessionID, err error) *SessionMock + type SessionMockCreateSessionParams struct + type SessionMockCreateSessionResults struct + type SessionMockDeleteSessionExpectation struct + Counter uint64 + func (e *SessionMockDeleteSessionExpectation) Then(err error) *SessionMock + type SessionMockDeleteSessionParams struct + type SessionMockDeleteSessionResults struct + type SessionMockListSessionsExpectation struct + Counter uint64 + func (e *SessionMockListSessionsExpectation) Then(m1 map[SessionID]SessionConfig, err error) *SessionMock + type SessionMockListSessionsParams struct + type SessionMockListSessionsResults struct + type SessionMockReadSessionExpectation struct + Counter uint64 + func (e *SessionMockReadSessionExpectation) Then(s2 SessionConfig, err error) *SessionMock + type SessionMockReadSessionParams struct + type SessionMockReadSessionResults struct + type SessionMockRenewSessionExpectation struct + Counter uint64 + func (e *SessionMockRenewSessionExpectation) Then(d1 time.Duration, err error) *SessionMock + type SessionMockRenewSessionParams struct + type SessionMockRenewSessionResults struct + type SessionQuery struct + DC string + ID SessionID v1.0.0 Apr 3, 2018 Changes in this version + const SessionDelete + const SessionMaximumLockDelay + const SessionMaximumTTL + const SessionMinimumLockDelay + const SessionMinimumTTL + const SessionRelease + type Agent interface + MaintenanceMode func(enabled bool, reason string) error + Members func(wan bool) ([]AgentInfo, error) + Reload func() error + Self func() (AgentInfo, error) + type AgentInfo struct + Address string + Name string + Port int + Tags map[string]string + type AsLeaderFunc func(context.Context) error + type Candidate interface + Participate func(LeadershipConfig, AsLeaderFunc) (LeaderSession, error) + type Catalog interface + Datacenters func() ([]string, error) + Node func(dc, name string) (NodeInfo, error) + Nodes func(dc string) ([]Node, error) + Service func(dc, service string, tags ...string) ([]Service, error) + Services func(dc string) (map[string][]string, error) + type Client interface + func New(opts ClientOptions) Client + type ClientOptions struct + Address string + HTTPTimeout time.Duration + Logger *log.Logger + SkipTLSVerification bool + Token string + type KV interface + Delete func(dc, path string) error + Get func(dc, path string) (string, error) + Keys func(dc, path string) ([]string, error) + Put func(dc, path, value string) error + Recurse func(dc, path string) ([][2]string, error) + type LeaderSession interface + Abdicate func() error + Current func() (string, error) + SessionID func() string + type LeadershipConfig struct + ContactInfo string + Description string + Key string + LockDelay time.Duration + TTL time.Duration + type Node struct + Address string + Name string + TaggedAddresses map[string]string + type NodeInfo struct + Node struct{ ... } + Services map[string]struct{ ... } + type RequestError struct + func (h *RequestError) Error() string + func (h *RequestError) StatusCode() int + type Service struct + Address string + Node string + ServiceAddress string + ServiceID string + ServiceName string + ServicePort int + ServiceTags []string + TaggedAddresses map[string]string + type Session interface + CreateSession func(dc string, config SessionConfig) (SessionID, error) + DeleteSession func(dc string, id SessionID) error + ListSessions func(dc, node string) (map[SessionID]SessionConfig, error) + ReadSession func(dc string, id SessionID) (SessionConfig, error) + RenewSession func(dc string, id SessionID) (time.Duration, error) + type SessionConfig struct + Behavior SessionTerminationBehavior + LockDelay time.Duration + Name string + Node string + TTL time.Duration + type SessionID string + type SessionTerminationBehavior string
Go to main page