shared

package

v0.0.0-...-3e35c70 Latest Latest Go to latest Published: Oct 5, 2021 License: BSD-3-Clause Imports: 4 Imported by: 0

Details

This section is empty.

View Source

var Handshake = plugin.HandshakeConfig{
	ProtocolVersion:  1,
	MagicCookieKey:   "BASIC_PLUGIN",
	MagicCookieValue: "hello",
}

View Source

var PluginMap = map[string]plugin.Plugin{
	"counter": &CounterPlugin{},
}

PluginMap is the map of plugins we can dispense.

This section is empty.

type Add interface {
	Sum(a, b int64) (int64, error)
}

type AddGRPCClient struct {
	// contains filtered or unexported fields
}

func (a *AddGRPCClient) Sum(x, y int64) (int64, error)

type AddGRPCServer struct {
	Impl Add
}

func (a *AddGRPCServer) Sum(c context.Context, request *proto.SumRequest) (*proto.SumResponse, error)

type Counter interface {
	Put(key string, value int64, a Add) error
	Get(key string) (int64, error)
}

type CounterGRPCClient struct {
	// contains filtered or unexported fields
}

func (c *CounterGRPCClient) Get(key string) (int64, error)

func (c *CounterGRPCClient) Put(key string, value int64, a Add) error

type CounterGRPCServer struct {
	Impl Counter
	// contains filtered or unexported fields
}

func (c *CounterGRPCServer) Get(ctx context.Context, request *proto.GetRequest) (*proto.GetResponse, error)

func (c *CounterGRPCServer) Put(ctx context.Context, request *proto.PutRequest) (*proto.Empty, error)

type CounterPlugin struct {
	plugin.NetRPCUnsupportedPlugin
	Impl Counter
}

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

func (c *CounterPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error