kv

Documentation

Index

• Constants
• type Config
• type Plugin
  • func (p *Plugin) Available()
  • func (p *Plugin) Collects() []interface{}
  • func (p *Plugin) GetAllStorageDrivers(name endure.Named, constructor kv.Constructor)
  • func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error
  • func (p *Plugin) Name() string
  • func (p *Plugin) RPC() interface{}
  • func (p *Plugin) Serve() chan error
  • func (p *Plugin) Stop() error

Constants

const PluginName string = "kv"

PluginName linked to the memory, boltdb, memcached, redis plugins. DO NOT change w/o sync.

Types

type Config

type Config struct {
	Data map[string]interface{} `mapstructure:"kv"`
}

Config represents general storage configuration with keys as the user defined kv-names and values as the constructors

type Plugin

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

Plugin for the unified storage

func (*Plugin) Available

func (p *Plugin) Available()

Available interface implementation

func (*Plugin) Collects

func (p *Plugin) Collects() []interface{}

Collects will get all plugins which implement Storage interface

func (*Plugin) GetAllStorageDrivers

func (p *Plugin) GetAllStorageDrivers(name endure.Named, constructor kv.Constructor)

func (*Plugin) Init

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

func (*Plugin) Name

func (p *Plugin) Name() string

func (*Plugin) RPC

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

RPC returns associated rpc service.

func (*Plugin) Serve

func (p *Plugin) Serve() chan error

func (*Plugin) Stop

func (p *Plugin) Stop() error