Versions in this module Expand all Collapse all v0 v0.7.1 Aug 16, 2018 v0.5.1 May 31, 2018 Changes in this version + const DefaultPoolSize + func GetProtocolSpec(p string) model.Protocol + func InstallPlugin(protocol string, f NewFunc) + type NewFunc func(Options) ProtocolClient + func GetClientNewFunc(name string) (NewFunc, error) + type Options struct + Failure map[string]bool + PoolSize int + PoolTTL time.Duration + TLSConfig *tls.Config + type ProtocolClient interface + Call func(ctx context.Context, addr string, req *Request, rsp interface{}) error + String func() string + func CreateClient(protocol, service string) (ProtocolClient, error) + func GetClient(protocol, service string) (ProtocolClient, error) + type Request struct + Arg interface{} + ID int + Metadata map[string]interface{} + MicroServiceName string + Operation string + Schema string + func NewRequest(service, schemaID, operationID string, arg interface{}) *Request + type Response struct + Error string + ID int + Metadata map[string]interface{} + Reply interface{}
Go to main page