kv

README

Docs: link

Documentation

Index

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

Constants

const (
	// PluginName linked to the memory, boltdb, memcached, redis plugins. DO NOT change w/o sync.
	PluginName string = "kv"
)

Types

type Config

type Config struct {
	Data map[string]any `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) Collects

func (p *Plugin) Collects() []any

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 *zap.Logger) error

func (*Plugin) Name

func (p *Plugin) Name() string

func (*Plugin) RPC

func (p *Plugin) RPC() any

RPC returns associated rpc service.

func (*Plugin) Serve

func (p *Plugin) Serve() chan error

func (*Plugin) Stop

func (p *Plugin) Stop() error