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.