Documentation ¶
Index ¶
- Variables
- func NewClient(cmd *exec.Cmd, loglevel string, writer io.Writer) *plugin.Client
- type GRPCSessionClient
- 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
- type GRPCSessionServer
- 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)
Constants ¶
This section is empty.
Variables ¶
View Source
var Handshake = plugin.HandshakeConfig{
MagicCookieKey: "SESSION_PLUGIN",
MagicCookieValue: "m9erzlkcuac9gy4a2szc19j7xjleo4s4epwiio9opv8tjv9sid0qetl7cjo6ulkiskorqyg26pcsfyf979pgn28s5a7byfbq0n66",
}
View Source
var VersionedPlugins = map[int]plugin.PluginSet{ 1: { "session": &GRPCSessionPlugin{}, }, }
Functions ¶
Types ¶
type GRPCSessionClient ¶
type GRPCSessionClient struct { PluginClient *plugin.Client TestServer *grpc.Server // contains filtered or unexported fields }
func (*GRPCSessionClient) Delete ¶
func (p *GRPCSessionClient) Delete(ctx context.Context, key string) error
type GRPCSessionPlugin ¶
func (*GRPCSessionPlugin) GRPCClient ¶
func (p *GRPCSessionPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
func (*GRPCSessionPlugin) GRPCServer ¶
func (p *GRPCSessionPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error
type GRPCSessionServer ¶
type GRPCSessionServer struct { Impl session.Session proto.UnimplementedSessionServer }
func (*GRPCSessionServer) Delete ¶
func (c *GRPCSessionServer) Delete(ctx context.Context, r *proto.DeleteRequest) (*proto.Empty, error)
func (*GRPCSessionServer) Get ¶
func (c *GRPCSessionServer) Get(ctx context.Context, r *proto.GetRequest) (*proto.GetResponse, error)
func (*GRPCSessionServer) Init ¶
func (c *GRPCSessionServer) Init(ctx context.Context, r *proto.SettingRequest) (*proto.Empty, error)
func (*GRPCSessionServer) Put ¶
func (c *GRPCSessionServer) Put(ctx context.Context, r *proto.PutRequest) (*proto.Empty, error)
Click to show internal directories.
Click to hide internal directories.