memdb

Documentation

Index

• func NewCoordinator() core.CoordinatorService
• type BinaryFieldIndexer
  • func (indexer *BinaryFieldIndexer) FromArgs(args ...any) ([]byte, error)
  • func (indexer *BinaryFieldIndexer) FromObject(obj any) (bool, []byte, error)
  • func (indexer *BinaryFieldIndexer) PrefixFromArgs(args ...any) ([]byte, error)
• type Coordinator
  • func (coord *Coordinator) ServiceName() string
  • func (coord *Coordinator) Start() error
  • func (coord *Coordinator) Stop() error
  • func (coord *Coordinator) Transact() (coordinator.Transaction, error)
• type Document

Functions

func NewCoordinator

func NewCoordinator() core.CoordinatorService

NewCoordinator returns a new etcd coordinator instance.

Types

type BinaryFieldIndexer

type BinaryFieldIndexer struct {
}

BinaryFieldIndexer is a custom field indexer for binary keys.

func (*BinaryFieldIndexer) FromArgs

func (indexer *BinaryFieldIndexer) FromArgs(args ...any) ([]byte, error)

FromArgs extracts the binary key from the arguments.

func (*BinaryFieldIndexer) FromObject

func (indexer *BinaryFieldIndexer) FromObject(obj any) (bool, []byte, error)

FromObject extracts the binary key from the object.

func (*BinaryFieldIndexer) PrefixFromArgs

func (indexer *BinaryFieldIndexer) PrefixFromArgs(args ...any) ([]byte, error)

PrefixFromArgs returns the prefix of the key.

type Coordinator

type Coordinator struct {
	*core.BaseCoordinator
	*memdb.MemDB
}

func (*Coordinator) ServiceName

func (coord *Coordinator) ServiceName() string

ServiceName returns the plug-in service name.

func (*Coordinator) Start

func (coord *Coordinator) Start() error

Start starts this etcd coordinator.

func (*Coordinator) Stop

func (coord *Coordinator) Stop() error

Stop stops this etcd coordinator.

func (*Coordinator) Transact

func (coord *Coordinator) Transact() (coordinator.Transaction, error)

type Document

type Document struct {
	Key   []byte
	Value []byte
}