metadata

Documentation

Index

• Constants
• Variables
• type Memory
  • func (m *Memory) Clean() error
  • func (m *Memory) Close() error
  • func (m *Memory) Delete(key []byte, cb callback.Callback[any])
  • func (m *Memory) DeleteAll(parentKey []byte, cb callback.Callback[any])
  • func (m *Memory) Get(key []byte, cb callback.Callback[*proto.Meta])
  • func (m *Memory) ListChildren(parentKey []byte, callback callback.Callback[[]string])
  • func (m *Memory) Notification() <-chan *proto.MetaNotification
  • func (m *Memory) Put(key []byte, value []byte, ephemeral bool, ...)
  • func (m *Memory) Swap(key []byte, value []byte, ephemeral bool, expectVersion int64, ...)
• type Metadata
  • func NewMemoryMetadata(ctx context.Context) Metadata
  • func NewMetadata(ctx context.Context, option Options) (Metadata, error)
• type Options

Constants

const (
	NameMemory = "memory"
)

Variables

var (
	ErrUnknownMetadataName = errors.New("unknown metadata name")
	ErrInvalidVersion      = errors.New("invalid version")
	ErrNotFound            = errors.New("not found")
)

Types

type Memory

type Memory struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

func (*Memory) Clean

func (m *Memory) Clean() error

func (*Memory) Close

func (m *Memory) Close() error

func (*Memory) Delete

func (m *Memory) Delete(key []byte, cb callback.Callback[any])

func (*Memory) DeleteAll

func (m *Memory) DeleteAll(parentKey []byte, cb callback.Callback[any])

func (*Memory) Get

func (m *Memory) Get(key []byte, cb callback.Callback[*proto.Meta])

func (*Memory) ListChildren

func (m *Memory) ListChildren(parentKey []byte, callback callback.Callback[[]string])

func (*Memory) Notification

func (m *Memory) Notification() <-chan *proto.MetaNotification

func (*Memory) Put

func (m *Memory) Put(key []byte, value []byte, ephemeral bool, callback callback.Callback[*proto.MetaInfo])

func (*Memory) Swap

func (m *Memory) Swap(key []byte, value []byte, ephemeral bool, expectVersion int64, cb callback.Callback[*proto.MetaInfo])

type Metadata

type Metadata interface {
	io.Closer
	lifecycle.Cleanup

	Put(key []byte, value []byte, ephemeral bool, cb callback.Callback[*proto.MetaInfo])

	Swap(key []byte, value []byte, ephemeral bool, expectVersion int64, cb callback.Callback[*proto.MetaInfo])

	Get(key []byte, cb callback.Callback[*proto.Meta])

	Delete(key []byte, cb callback.Callback[any])

	ListChildren(parentKey []byte, cb callback.Callback[[]string])

	DeleteAll(parentKey []byte, cb callback.Callback[any])

	Notification() <-chan *proto.MetaNotification
}

func NewMemoryMetadata

func NewMemoryMetadata(ctx context.Context) Metadata

func NewMetadata

func NewMetadata(ctx context.Context, option Options) (Metadata, error)

type Options

type Options struct {
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
}