memory

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: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewStateBackend

func NewStateBackend() 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