bbolt

Documentation

Index

• Constants
• type Cfg
  • func DefaultCfg() *Cfg
  • func (t *Cfg) BuildOpts() *bolt.Options
  • func (t *Cfg) Create() *bolt.DB
• type Client
  • func New(db *bolt.DB, log *logging.Logger) *Client
  • func (t *Client) Delete(ctx context.Context, key string, names ...string) error
  • func (t *Client) Get(ctx context.Context, key string, names ...string) (val []byte, err error)
  • func (t *Client) List(ctx context.Context, fn func(k, v []byte) error, names ...string) error
  • func (t *Client) Set(ctx context.Context, key string, val []byte, names ...string) error
  • func (t *Client) Update(ctx context.Context, fn func(*bolt.Bucket) error, names ...string) error
  • func (t *Client) View(ctx context.Context, fn func(*bolt.Bucket) error, names ...string) error

Constants

const Name = "bolt"

Types

type Cfg

type Cfg struct {
	FileMode        fs.FileMode       `json:"file_mode"`
	Timeout         time.Duration     `json:"timeout"`
	NoGrowSync      bool              `json:"no_grow_sync"`
	NoFreelistSync  bool              `json:"no_freelist_sync"`
	FreelistType    bolt.FreelistType `json:"freelist_type"`
	ReadOnly        bool              `json:"read_only"`
	MmapFlags       int               `json:"mmap_flags"`
	InitialMmapSize int               `json:"initial_mmap_size"`
	PageSize        int               `json:"page_size"`
	NoSync          bool              `json:"no_sync"`
	Path            string            `json:"path"`
}

func DefaultCfg

func DefaultCfg() *Cfg

func (*Cfg) BuildOpts

func (t *Cfg) BuildOpts() *bolt.Options

func (*Cfg) Create

func (t *Cfg) Create() *bolt.DB

type Client

type Client struct {
	*bolt.DB
	// contains filtered or unexported fields
}

func New

func New(db *bolt.DB, log *logging.Logger) *Client

func (*Client) Delete

func (t *Client) Delete(ctx context.Context, key string, names ...string) error

func (*Client) Get

func (t *Client) Get(ctx context.Context, key string, names ...string) (val []byte, err error)

func (*Client) List

func (t *Client) List(ctx context.Context, fn func(k, v []byte) error, names ...string) error

func (*Client) Set

func (t *Client) Set(ctx context.Context, key string, val []byte, names ...string) error

func (*Client) Update

func (t *Client) Update(ctx context.Context, fn func(*bolt.Bucket) error, names ...string) error

func (*Client) View

func (t *Client) View(ctx context.Context, fn func(*bolt.Bucket) error, names ...string) error