consul

package
v0.4.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 6, 2020 License: MPL-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewStateBackend

func NewStateBackend(log zerolog.Logger, path string, client *api.Client) cluster.Backend

Types

type ClusterBackend

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

func (ClusterBackend) DeleteLeaderEntries

func (c ClusterBackend) DeleteLeaderEntries(uuid uuid.UUID)

func (ClusterBackend) DeleteLeaderEntry

func (c ClusterBackend) DeleteLeaderEntry(uuid uuid.UUID) error

func (ClusterBackend) GetClusterInfo

func (c ClusterBackend) GetClusterInfo() (*state.ClusterInfo, error)

func (ClusterBackend) GetClusterLeader

func (c ClusterBackend) GetClusterLeader(id string) (*state.ClusterMember, error)

func (ClusterBackend) Lock

func (c ClusterBackend) Lock(value string) (cluster.BackendLock, error)

func (ClusterBackend) PutClusterInfo

func (c ClusterBackend) PutClusterInfo(info *state.ClusterInfo) error

func (ClusterBackend) PutClusterLeader

func (c ClusterBackend) PutClusterLeader(leader *state.ClusterMember) error

func (ClusterBackend) SupportsHA

func (c ClusterBackend) SupportsHA() bool

type ClusterLock

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

func (ClusterLock) Acquire

func (c ClusterLock) Acquire(stopCh <-chan struct{}) (<-chan struct{}, error)

func (ClusterLock) Release

func (c ClusterLock) Release() error

func (ClusterLock) Value

func (c ClusterLock) Value() (bool, string, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL