shared

Documentation

Index

• Variables
• type AddHelper
• type AddHelperImpl
  • func (*AddHelperImpl) Sum(a, b string) (string, error)
• type GRPCAddHelperClient
  • func (m *GRPCAddHelperClient) Sum(a, b string) (string, error)
• type GRPCAddHelperServer
  • func (m *GRPCAddHelperServer) Sum(ctx context.Context, req *proto.SumRequest) (resp *proto.SumResponse, err error)
• type GRPCClient
  • func (m *GRPCClient) Decode(data model.DataReq) model.JsonRes
  • func (m *GRPCClient) Encode(args string) model.JsonRes
  • func (m *GRPCClient) Get(key string) (string, error)
  • func (m *GRPCClient) Info(args string) model.PluginInfo
  • func (m *GRPCClient) Put(key string, value string, a AddHelper) error
• type GRPCServer
  • func (m *GRPCServer) Decode(ctx context.Context, req *proto.DecodeRequest) (*proto.DecodeResponse, error)
  • func (m *GRPCServer) Encode(ctx context.Context, req *proto.EncodeRequest) (*proto.EncodeResponse, error)
  • func (m *GRPCServer) Get(ctx context.Context, req *proto.GetRequest) (*proto.GetResponse, error)
  • func (m *GRPCServer) Info(ctx context.Context, req *proto.InfoRequest) (*proto.InfoResponse, error)
  • func (m *GRPCServer) Put(ctx context.Context, req *proto.PutRequest) (*proto.Empty, error)
• type Protocol

Variables

var Logger *zap.Logger

Types

type AddHelper

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

除了标准的Protocol接口（自动注册） AddHelper 提供了额外的接口，用来自定义额外处理逻辑及调用时机

type AddHelperImpl

type AddHelperImpl struct{}

func (*AddHelperImpl) Sum

func (*AddHelperImpl) Sum(a, b string) (string, error)

type GRPCAddHelperClient

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

GRPCClient is an implementation of KV that talks over RPC.

func (*GRPCAddHelperClient) Sum

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

type GRPCAddHelperServer

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

Here is the gRPC server that GRPCClient talks to.

func (*GRPCAddHelperServer) Sum

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

type GRPCClient

type GRPCClient struct {
	Broker *plugin.GRPCBroker
	Client proto.PluginClient
	Logger *zap.Logger
}

GRPCClient is an implementation of KV that talks over RPC.

func (*GRPCClient) Decode

func (m *GRPCClient) Decode(data model.DataReq) model.JsonRes

func (*GRPCClient) Encode

func (m *GRPCClient) Encode(args string) model.JsonRes

func (*GRPCClient) Get

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

func (*GRPCClient) Info

func (m *GRPCClient) Info(args string) model.PluginInfo

func (*GRPCClient) Put

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

type GRPCServer

type GRPCServer struct {
	// This is the real implementation
	Impl Protocol

	Broker *plugin.GRPCBroker
}

Here is the gRPC server that GRPCClient talks to.

func (*GRPCServer) Decode

func (m *GRPCServer) Decode(ctx context.Context, req *proto.DecodeRequest) (*proto.DecodeResponse, error)

func (*GRPCServer) Encode

func (m *GRPCServer) Encode(ctx context.Context, req *proto.EncodeRequest) (*proto.EncodeResponse, error)

func (*GRPCServer) Get

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

func (*GRPCServer) Info

func (m *GRPCServer) Info(ctx context.Context, req *proto.InfoRequest) (*proto.InfoResponse, error)

func (*GRPCServer) Put

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

type Protocol

type Protocol interface {
	Put(key string, value string, a AddHelper) error
	Get(key string) (string, error)
	Info(args string) model.PluginInfo
	Encode(args string) model.JsonRes
	Decode(data model.DataReq) model.JsonRes
}

GRPC协议插件接口.