plugins

Documentation

Index

• func NewLevelDB() store.Storage
• type LevelDB
  • func (ldb *LevelDB) Client(broker *plugin.MuxBroker, client *rpc.Client) (interface{}, error)
  • func (ldb *LevelDB) Get(key string) (value *store.Entry)
  • func (ldb *LevelDB) GetWithPrefix(prefix, key string) (value *store.Entry)
  • func (ldb *LevelDB) Initialize()
  • func (ldb *LevelDB) Open() (interface{}, error)
  • func (ldb *LevelDB) Put(key string, value string) error
  • func (ldb *LevelDB) PutWithPrefix(prefix, key string, value string) error
  • func (ldb *LevelDB) Server(broker *plugin.MuxBroker) (interface{}, error)
• type LevelDBGrpc
  • func (p *LevelDBGrpc) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
  • func (p *LevelDBGrpc) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error
• type LevelDBGrpcClient
  • func (l *LevelDBGrpcClient) Get(key []byte) (*proto.GetResponse, error)
  • func (l *LevelDBGrpcClient) Put(key []byte, value []byte) (*proto.PutResponse, error)
• type LevelDBGrpcServer
  • func (ls *LevelDBGrpcServer) Get(ctx context.Context, key []byte) (*proto.GetResponse, error)
  • func (ls *LevelDBGrpcServer) Put(ctx context.Context, key []byte, value []byte) (*proto.PutResponse, error)
• type LevelDBPluginInterface
• type RPCClient
  • func (m *RPCClient) Get(key string) ([]byte, error)
  • func (m *RPCClient) Put(key string, value []byte) error
• type RPCServer
  • func (m *RPCServer) Get(key string, resp *interface{}) error
  • func (m *RPCServer) Put(args map[string]interface{}, resp *interface{}) error

Functions

func NewLevelDB

func NewLevelDB() store.Storage

Types

type LevelDB

type LevelDB struct {
	Impl LevelDBPluginInterface
	// contains filtered or unexported fields
}

var DB *LevelDB

DB contains the LevelDB pointer

func (*LevelDB) Client

func (ldb *LevelDB) Client(broker *plugin.MuxBroker, client *rpc.Client) (interface{}, error)

func (*LevelDB) Get

func (ldb *LevelDB) Get(key string) (value *store.Entry)

func (*LevelDB) GetWithPrefix

func (ldb *LevelDB) GetWithPrefix(prefix, key string) (value *store.Entry)

func (*LevelDB) Initialize

func (ldb *LevelDB) Initialize()

func (*LevelDB) Open

func (ldb *LevelDB) Open() (interface{}, error)

func (*LevelDB) Put

func (ldb *LevelDB) Put(key string, value string) error

func (*LevelDB) PutWithPrefix

func (ldb *LevelDB) PutWithPrefix(prefix, key string, value string) error

func (*LevelDB) Server

func (ldb *LevelDB) Server(broker *plugin.MuxBroker) (interface{}, error)

type LevelDBGrpc

type LevelDBGrpc struct {
	plugin.Plugin
	Impl LevelDBPluginInterface
}

func (*LevelDBGrpc) GRPCClient

func (p *LevelDBGrpc) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (*LevelDBGrpc) GRPCServer

func (p *LevelDBGrpc) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type LevelDBGrpcClient

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

func (*LevelDBGrpcClient) Get

func (l *LevelDBGrpcClient) Get(key []byte) (*proto.GetResponse, error)

func (*LevelDBGrpcClient) Put

func (l *LevelDBGrpcClient) Put(key []byte, value []byte) (*proto.PutResponse, error)

type LevelDBGrpcServer

type LevelDBGrpcServer struct {
	Impl LevelDBPluginInterface
}

func (*LevelDBGrpcServer) Get

func (ls *LevelDBGrpcServer) Get(ctx context.Context, key []byte) (*proto.GetResponse, error)

func (*LevelDBGrpcServer) Put

func (ls *LevelDBGrpcServer) Put(ctx context.Context, key []byte, value []byte) (*proto.PutResponse, error)

type LevelDBPluginInterface

type LevelDBPluginInterface interface {
	store.Storage
	store.Query
	store.Iterator
}

type RPCClient

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

func (*RPCClient) Get

func (m *RPCClient) Get(key string) ([]byte, error)

func (*RPCClient) Put

func (m *RPCClient) Put(key string, value []byte) error

type RPCServer

type RPCServer struct {
	Impl LevelDBPluginInterface
}

func (*RPCServer) Get

func (m *RPCServer) Get(key string, resp *interface{}) error

func (*RPCServer) Put

func (m *RPCServer) Put(args map[string]interface{}, resp *interface{}) error