Versions in this module Expand all Collapse all v0 v0.0.1 May 19, 2021 Changes in this version + var Handshake = plugin.HandshakeConfig + var VersionedPlugins = map[int]plugin.PluginSet + func NewClient(cmd *exec.Cmd, loglevel string, writer io.Writer) *plugin.Client + type GRPCSessionClient struct + PluginClient *plugin.Client + TestServer *grpc.Server + func (p *GRPCSessionClient) Close(ctx context.Context) error + func (p *GRPCSessionClient) Delete(ctx context.Context, key string) error + func (p *GRPCSessionClient) Get(ctx context.Context, key string) (string, error) + func (p *GRPCSessionClient) Init(ctx context.Context, setting map[string]interface{}) error + func (p *GRPCSessionClient) Put(ctx context.Context, key string, value string) error + type GRPCSessionPlugin struct + Impl session.Session + func (p *GRPCSessionPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error) + func (p *GRPCSessionPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error + type GRPCSessionServer struct + Impl session.Session + func (c *GRPCSessionServer) Close(ctx context.Context, e *proto.Empty) (*proto.Empty, error) + func (c *GRPCSessionServer) Delete(ctx context.Context, r *proto.DeleteRequest) (*proto.Empty, error) + func (c *GRPCSessionServer) Get(ctx context.Context, r *proto.GetRequest) (*proto.GetResponse, error) + func (c *GRPCSessionServer) Init(ctx context.Context, r *proto.SettingRequest) (*proto.Empty, error) + func (c *GRPCSessionServer) Put(ctx context.Context, r *proto.PutRequest) (*proto.Empty, error)
Go to main page