storage

Documentation

Index

• Variables
• func WithBus(bus server.Interface) pkgOptions.Option[Options]
• func WithLogger(logger logger.Interface) pkgOptions.Option[Options]
• func WithNKey(nkey nkeys.KeyPair) pkgOptions.Option[Options]
• type Interface
  • func New(opt ...pkgOptions.Option[Options]) (Interface, error)
• type Options
• type WatchCallbackFunc
• type WatchStopFunc
• type WriteData

Variables

var (
	ErrExists = errors.New("attr exists")
)

Functions

func WithBus

func WithBus(bus server.Interface) pkgOptions.Option[Options]

func WithLogger

func WithLogger(logger logger.Interface) pkgOptions.Option[Options]

func WithNKey

func WithNKey(nkey nkeys.KeyPair) pkgOptions.Option[Options]

Types

type Interface

type Interface interface {
	Start() error
	Stop() error

	KeyExists(resource string, namespace string, key string) (bool, error)
	KeyList(resource string, namespace string) []string

	AttrList(resource string, namespace string, key string) []string
	AttrExists(resource string, namespace string, attr string, key string) (bool, error)
	BlobExists(resource string, namespace string, attr string, key string) (bool, error)

	AttrSet(resource string, namespace string, attr string, key string, value []byte, replace bool) error
	AttrGet(resource string, namespace string, attr string, key string) ([]byte, error)

	BlobWrite(resource string, namespace string, attr string, key string, data io.ReadCloser, replace bool) error
	BlobRead(resource string, namespace string, attr string, key string) (io.ReadCloser, error)

	AttrDelete(resource string, namespace string, attr string, key string) error

	AttrWatch(resource string, namespace string, attr string, callback WatchCallbackFunc) (WatchStopFunc, error)
}

func New

func New(opt ...pkgOptions.Option[Options]) (Interface, error)

type Options

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

type WatchCallbackFunc

type WatchCallbackFunc = func(resource string, namespace string, attr string, key string, data []byte, prevData []byte, delete bool)

type WatchStopFunc

type WatchStopFunc = func() error

type WriteData

type WriteData struct {
}