plugins

package
v0.0.0-...-f163260 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 8, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.