kv

type Bucket interface {
	Name() string
	Get(ctx context.Context, key string) ([]byte, error)
	Set(ctx context.Context, key string, value []byte) error
	Delete(ctx context.Context, key string) error
	WatchAll(ctx context.Context) (Watcher, error)
	Unwatch(w Watcher)
	ListKeys(ctx context.Context) ([]string, error)
}

type Client interface {
	Bucket(ctx context.Context, name string) (Bucket, error)
}

type JSONBucket struct {
	BucketName string            `json:"name"`
	Data       map[string][]byte `json:"data"`
	// contains filtered or unexported fields
}

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

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

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

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

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

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

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

type NATSOptions struct {
	URL string `json:"url"`
}

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

type Operation int

type Value struct {
	Key       string
	Value     []byte
	Operation Operation
}

type Watcher interface {
	Changes() <-chan *Value
	Unwatch()
}