plugin

Documentation

Index

• Variables
• type CacheServer
  • func (c *CacheServer) Delete(ctx context.Context, r *proto.DeleteRequest) (*proto.Empty, error)
  • func (c *CacheServer) Get(ctx context.Context, r *proto.GetRequest) (*proto.GetResponse, error)
  • func (c *CacheServer) Init(ctx context.Context, r *proto.SettingRequest) (*proto.Empty, error)
  • func (c *CacheServer) Put(ctx context.Context, r *proto.PutRequest) (*proto.Empty, error)
• type GRPCCache
  • func (p *GRPCCache) Close() error
  • func (p *GRPCCache) Delete(ctx context.Context, key string) error
  • func (p *GRPCCache) Get(ctx context.Context, key string) (string, error)
  • func (p *GRPCCache) Put(ctx context.Context, key string, value string) error
  • func (p *GRPCCache) Setting(ctx context.Context, setting cache.CacheSetting)
• type GRPCCachePlugin
  • func (p *GRPCCachePlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
  • func (p *GRPCCachePlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

Variables

var Handshake = plugin.HandshakeConfig{
	MagicCookieKey:   "CACHE_PLUGIN",
	MagicCookieValue: "m9erzlkcuac9gy4a2szc19j7xjleo4s4epwiio9opv8tjv9sid0qetl7cjo6ulkiskorqyg26pcsfyf979pgn28s5a7byfbq0n66",
}

var VersionedPlugins = map[int]plugin.PluginSet{
	1: {
		"cache": &GRPCCachePlugin{},
	},
}

Types

type CacheServer

type CacheServer struct {
	Impl cache.Cache
	proto.UnimplementedCacheServer
}

func (*CacheServer) Delete

func (c *CacheServer) Delete(ctx context.Context, r *proto.DeleteRequest) (*proto.Empty, error)

func (*CacheServer) Get

func (c *CacheServer) Get(ctx context.Context, r *proto.GetRequest) (*proto.GetResponse, error)

func (*CacheServer) Init

func (c *CacheServer) Init(ctx context.Context, r *proto.SettingRequest) (*proto.Empty, error)

func (*CacheServer) Put

func (c *CacheServer) Put(ctx context.Context, r *proto.PutRequest) (*proto.Empty, error)

type GRPCCache

type GRPCCache struct {
	PluginClient *plugin.Client
	TestServer   *grpc.Server
	// contains filtered or unexported fields
}

func (*GRPCCache) Close

func (p *GRPCCache) Close() error

func (*GRPCCache) Delete

func (p *GRPCCache) Delete(ctx context.Context, key string) error

func (*GRPCCache) Get

func (p *GRPCCache) Get(ctx context.Context, key string) (string, error)

func (*GRPCCache) Put

func (p *GRPCCache) Put(ctx context.Context, key string, value string) error

func (*GRPCCache) Setting

func (p *GRPCCache) Setting(ctx context.Context, setting cache.CacheSetting)

type GRPCCachePlugin

type GRPCCachePlugin struct {
	plugin.Plugin
	GRPCCache func() *CacheServer
}

func (*GRPCCachePlugin) GRPCClient

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

func (*GRPCCachePlugin) GRPCServer

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