event

Documentation

Index

• func NewOptions() nutsdb.Options
• func NewRepository() (keyvalue.LoadSaveCloser, func() error, error)
• type Repository
  • func (p *Repository) Close() error
  • func (p *Repository) Load(ctx context.Context, prefix keyvalue.KeyPrefixer) (<-chan keyvalue.KeyValuer, error)
  • func (p *Repository) Save(ctx context.Context, keyvalue keyvalue.KeyValuer) error

Functions

func NewOptions

func NewOptions() nutsdb.Options

func NewRepository

func NewRepository() (keyvalue.LoadSaveCloser, func() error, error)

Types

type Repository

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

func (*Repository) Close

func (p *Repository) Close() error

func (*Repository) Load

func (p *Repository) Load(ctx context.Context, prefix keyvalue.KeyPrefixer) (<-chan keyvalue.KeyValuer, error)

func (*Repository) Save

func (p *Repository) Save(ctx context.Context, keyvalue keyvalue.KeyValuer) error