store

Documentation

Index

• Variables
• type Sink
  • func NewSink[V any](store Storage, enc codec.Encoder[V]) *Sink[V]
  • func (n *Sink[V]) Write(messages ...msg.Message[string, V]) error
• type Storage
• type Unimplemented
  • func (s *Unimplemented) Close() error
  • func (s *Unimplemented) Delete(_ string) error
  • func (s *Unimplemented) Get(_ string) ([]byte, error)
  • func (s *Unimplemented) Has(_ string) (bool, error)
  • func (s *Unimplemented) Open() error
  • func (s *Unimplemented) Set(_ string, value []byte) error

Variables

var (
	// ErrUnimplemented ...
	ErrUnimplemented = errors.New("not implemented")

	// ErrNoNilValue ...
	ErrNoNilValue = errors.New("no nil value")

	// ErrNotExists ...
	ErrNotExists = errors.New("not exists")
)

Types

type Sink

type Sink[V any] struct {
	Storage
	codec.Encoder[V]
}

Sink is a storage sink.

func NewSink

func NewSink[V any](store Storage, enc codec.Encoder[V]) *Sink[V]

NewSink is a new storage sink.

func (*Sink[V]) Write

func (n *Sink[V]) Write(messages ...msg.Message[string, V]) error

Write is a storage sink writer.

type Storage

type Storage interface {
	// Open is called when the storage is opened.
	Open() error

	// Close is called when the storage is closed.
	Close() error

	// Has is called to check if a key exists.
	Has(key string) (bool, error)

	// Get is called to get a value.
	Get(key string) ([]byte, error)

	// Set is called to set a value.
	Set(key string, value []byte) error

	// Delete is called to delete a value.
	Delete(key string) error
}

Storage ...

type Unimplemented

type Unimplemented struct{}

Unimplemented ...

func (*Unimplemented) Close

func (s *Unimplemented) Close() error

Close ...

func (*Unimplemented) Delete

func (s *Unimplemented) Delete(_ string) error

Delete ...

func (*Unimplemented) Get

func (s *Unimplemented) Get(_ string) ([]byte, error)

Get ...

func (*Unimplemented) Has

func (s *Unimplemented) Has(_ string) (bool, error)

Has ...

func (*Unimplemented) Open

func (s *Unimplemented) Open() error

Open ...

func (*Unimplemented) Set

func (s *Unimplemented) Set(_ string, value []byte) error

Set ...