shared

Documentation

Index

• Variables
• type Counter
• type CounterPlugin
  • 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 GRPCCounterClient
  • func (m *GRPCCounterClient) Increment(key string, value int64, storage Storage) (int64, error)
• type GRPCCounterServer
  • func (m *GRPCCounterServer) Increment(ctx context.Context, req *proto.IncrementRequest) (*proto.IncrementResponse, error)
• type GRPCStorageClient
  • func (m *GRPCStorageClient) Get(key string) (int64, error)
  • func (m *GRPCStorageClient) Put(key string, value int64) error
• type GRPCStorageServer
  • func (m *GRPCStorageServer) Get(ctx context.Context, req *proto.GetRequest) (*proto.GetResponse, error)
  • func (m *GRPCStorageServer) Put(ctx context.Context, req *proto.PutRequest) (*proto.PutResponse, error)
• type Storage

Variables

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

Handshake is a common handshake that is shared by plugin and host.

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

PluginMap is the map of plugins we can dispense.

Types

type Counter

type Counter interface {
	Increment(key string, value int64, storage Storage) (int64, error)
}

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 (*CounterPlugin) GRPCClient

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

func (*CounterPlugin) GRPCServer

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

type GRPCCounterClient

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

func (*GRPCCounterClient) Increment

func (m *GRPCCounterClient) Increment(key string, value int64, storage Storage) (int64, error)

type GRPCCounterServer

type GRPCCounterServer struct {
	proto.UnimplementedCounterServer
	Impl Counter
	// contains filtered or unexported fields
}

func (*GRPCCounterServer) Increment

func (m *GRPCCounterServer) Increment(ctx context.Context, req *proto.IncrementRequest) (*proto.IncrementResponse, error)

type GRPCStorageClient

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

func (*GRPCStorageClient) Get

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

func (*GRPCStorageClient) Put

func (m *GRPCStorageClient) Put(key string, value int64) error

type GRPCStorageServer

type GRPCStorageServer struct {
	proto.UnimplementedStorageServer
	Impl Storage
}

func (*GRPCStorageServer) Get

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

func (*GRPCStorageServer) Put

func (m *GRPCStorageServer) Put(ctx context.Context, req *proto.PutRequest) (*proto.PutResponse, error)

type Storage

type Storage interface {
	Put(key string, value int64) error
	Get(key string) (int64, error)
}