shared

type AddHelper ¶

type AddHelper interface {
	Sum(int64, int64) (int64, error)
}

type Counter ¶

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

KV is the interface that we're exposing as a plugin.

type CounterPlugin ¶

type CounterPlugin struct {
	plugin.NetRPCUnsupportedPlugin
	// Concrete implementation, written in Go. This is only used for plugins
	// that are written in Go.
	Impl Counter
}

This is the implementation of plugin.Plugin so we can serve/consume this. We also implement GRPCPlugin so that this plugin can be served over gRPC.

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

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

type GRPCAddHelperClient ¶

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

GRPCClient is an implementation of KV that talks over RPC.

func (m *GRPCAddHelperClient) Sum(a, b int64) (int64, error)

type GRPCAddHelperServer ¶

type GRPCAddHelperServer struct {
	// This is the real implementation
	Impl AddHelper
}

Here is the gRPC server that GRPCClient talks to.

func (m *GRPCAddHelperServer) Sum(ctx context.Context, req *proto.SumRequest) (resp *proto.SumResponse, err error)

type GRPCClient ¶

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

GRPCClient is an implementation of KV that talks over RPC.

func (m *GRPCClient) Get(key string) (int64, error)

func (m *GRPCClient) Put(key string, value int64, a AddHelper) error

type GRPCServer ¶

type GRPCServer struct {
	// This is the real implementation
	Impl Counter
	// contains filtered or unexported fields
}

Here is the gRPC server that GRPCClient talks to.

func (m *GRPCServer) Get(ctx context.Context, req *proto.GetRequest) (*proto.GetResponse, error)

func (m *GRPCServer) Put(ctx context.Context, req *proto.PutRequest) (*proto.Empty, error)