shared

Aug 30, 2023

Changes in this version

+ var Handshake = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

+ type Counter interface

+ Increment func(key string, value int64, storage Storage) (int64, error)

+ type CounterPlugin struct

+ Impl Counter

+ 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 struct

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

+ type GRPCCounterServer struct

+ Impl Counter

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

+ type GRPCStorageClient struct

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

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

+ type GRPCStorageServer struct

+ Impl Storage

+ 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 interface

+ Get func(key string) (int64, error)

+ Put func(key string, value int64) error