core

Documentation

Index

• Constants
• type BaseCoordinator
  • func NewBaseCoordinator() *BaseCoordinator
  • func (coord *BaseCoordinator) ServiceType() plugins.ServiceType
  • func (coord *BaseCoordinator) SetKeyCoder(coder coordinator.KeyCoder)
• type CoordinatorService

Constants

const (
	CoordinatorObject  = kv.HeaderType('C')
	NotificationObject = kv.HeaderType('N')
)

Types

type BaseCoordinator

type BaseCoordinator struct {
	plugins.Config
	coordinator.KeyCoder
	*time.Ticker
}

func NewBaseCoordinator

func NewBaseCoordinator() *BaseCoordinator

NewBaseCoordinator returns a new base coordinator instance.

func (*BaseCoordinator) ServiceType

func (coord *BaseCoordinator) ServiceType() plugins.ServiceType

ServiceType returns the plug-ing service type.

func (*BaseCoordinator) SetKeyCoder

func (coord *BaseCoordinator) SetKeyCoder(coder coordinator.KeyCoder)

SetKeyCoder sets the key coder.

type CoordinatorService

type CoordinatorService interface {
	coordinator.Store
	plugins.Service
}