boltdb

Documentation

Index

• Constants
• type Config
  • func (s *Config) InitDefaults()
• type Plugin
  • func (s *Plugin) Close() error
  • func (s *Plugin) Delete(keys ...string) error
  • func (s *Plugin) Get(key string) ([]byte, error)
  • func (s *Plugin) Has(keys ...string) (map[string]bool, error)
  • func (s *Plugin) Init(log logger.Logger, cfg config.Configurer) error
  • func (s *Plugin) MExpire(items ...kv.Item) error
  • func (s *Plugin) MGet(keys ...string) (map[string]interface{}, error)
  • func (s *Plugin) Name() string
  • func (s *Plugin) RPC() interface{}
  • func (s *Plugin) Serve() chan error
  • func (s *Plugin) Set(items ...kv.Item) error
  • func (s *Plugin) Stop() error
  • func (s *Plugin) TTL(keys ...string) (map[string]interface{}, error)

Constants

const PluginName = "boltdb"

Types

type Config

type Config struct {
	// Dir is a directory to store the DB files
	Dir string
	// File is boltDB file. No need to create it by your own,
	// boltdb driver is able to create the file, or read existing
	File string
	// Bucket to store data in boltDB
	Bucket string
	// db file permissions
	Permissions int
	// timeout
	Interval uint `mapstructure:"interval"`
}

func (*Config) InitDefaults

func (s *Config) InitDefaults()

InitDefaults initializes default values for the boltdb

type Plugin

type Plugin struct {
	// db instance
	DB *bolt.DB
	// contains filtered or unexported fields
}

BoltDB K/V storage.

func (*Plugin) Close

func (s *Plugin) Close() error

Close the DB connection

func (*Plugin) Delete

func (s *Plugin) Delete(keys ...string) error

Delete all keys from DB

func (*Plugin) Get

func (s *Plugin) Get(key string) ([]byte, error)

Get retrieves the value for a key in the bucket. Returns a nil value if the key does not exist or if the key is a nested bucket. The returned value is only valid for the life of the transaction.

func (*Plugin) Has

func (s *Plugin) Has(keys ...string) (map[string]bool, error)

func (*Plugin) Init

func (s *Plugin) Init(log logger.Logger, cfg config.Configurer) error

func (*Plugin) MExpire

func (s *Plugin) MExpire(items ...kv.Item) error

MExpire sets the expiration time to the key If key already has the expiration time, it will be overwritten

func (*Plugin) MGet

func (s *Plugin) MGet(keys ...string) (map[string]interface{}, error)

func (*Plugin) Name

func (s *Plugin) Name() string

Name returns plugin name

func (*Plugin) RPC

func (s *Plugin) RPC() interface{}

RPCService returns associated rpc service.

func (*Plugin) Serve

func (s *Plugin) Serve() chan error

func (*Plugin) Set

func (s *Plugin) Set(items ...kv.Item) error

Set puts the K/V to the bolt

func (*Plugin) Stop

func (s *Plugin) Stop() error

func (*Plugin) TTL

func (s *Plugin) TTL(keys ...string) (map[string]interface{}, error)