pluginapi

Documentation

Index

• Variables
• type Cluster
• type ClusterMutex
• type ClusterMutexMock
  • func NewClusterMutexMock() *ClusterMutexMock
  • func (m *ClusterMutexMock) LockWithContext(ctx context.Context) error
  • func (m *ClusterMutexMock) Unlock()
• type ClusterService
  • func NewClusterService(api plugin.API) *ClusterService
  • func (c *ClusterService) NewMutex(key string) (ClusterMutex, error)

Variables

var (
	ErrLockTimeout = errors.New("timeout")
)

Types

type Cluster

type Cluster interface {
	NewMutex(key string) (ClusterMutex, error)
}

type ClusterMutex

type ClusterMutex interface {
	LockWithContext(ctx context.Context) error
	Unlock()
}

type ClusterMutexMock

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

func NewClusterMutexMock

func NewClusterMutexMock() *ClusterMutexMock

func (*ClusterMutexMock) LockWithContext

func (m *ClusterMutexMock) LockWithContext(ctx context.Context) error

func (*ClusterMutexMock) Unlock

func (m *ClusterMutexMock) Unlock()

type ClusterService

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

ClusterService exposes methods from the mm server cluster package.

func NewClusterService

func NewClusterService(api plugin.API) *ClusterService

func (*ClusterService) NewMutex

func (c *ClusterService) NewMutex(key string) (ClusterMutex, error)

NewMutex creates a mutex with the given key name.