gomicro

Jul 14, 2023

Changes in this version

+ const LOAD_BALANCE_KEY_WEIGTHT

type GoRPCServer

+ func (s *GoRPCServer) Weight() int

type ServerOption

+ Weight int

Apr 19, 2023

Changes in this version

type ServerOption

+ Metadata map[string]string

Dec 19, 2022

Changes in this version

+ func NewContextWithTimeout(md map[string]string, timeout int) (context.Context, context.CancelFunc)

type GoRPCClient

+ func NewClient(strRegistry string) (c *GoRPCClient)

type GoRPCServer

+ func NewServer(strRegistry string, option *ServerOption) (s *GoRPCServer)

+ type ServerOption struct

+ Interval int

+ RpcAddr string

+ ServiceName string

+ TTL int

Dec 9, 2022

Changes in this version

type RegistryType

+ func ParseRegistry(strRegistry string) (typ RegistryType, endpoints []string)

Jul 11, 2022

Changes in this version

+ const DEFAULT_RPC_TIMEOUT

+ const DISCOVERY_DEFAULT_INTERVAL

+ const DISCOVERY_DEFAULT_TTL

+ var DefaultMaxMsgSize = 512 * 1024 * 1024

+ func FromContext(ctx context.Context) (md metadata.Metadata)

+ func NewContext(md map[string]string, timeout int) context.Context

+ type Discovery struct

+ Endpoints []string

+ Interval int

+ RpcAddr string

+ ServiceName string

+ TTL int

+ type GoRPC struct

+ func NewGoRPC(registryType RegistryType, maxSize ...int) (g *GoRPC)

+ func (g *GoRPC) NewClient(endPoints ...string) (c *GoRPCClient)

+ func (g *GoRPC) NewServer(discovery *Discovery) (s *GoRPCServer)

+ type GoRPCClient struct

+ func (c *GoRPCClient) Call(ctx context.Context, req client.Request, rsp interface{}, ...) error

+ func (c *GoRPCClient) Init(opts ...client.Option) error

+ func (c *GoRPCClient) NewMessage(topic string, msg interface{}, opts ...client.MessageOption) client.Message

+ func (c *GoRPCClient) NewRequest(service, endpoint string, req interface{}, reqOpts ...client.RequestOption) client.Request

+ func (c *GoRPCClient) Options() client.Options

+ func (c *GoRPCClient) Publish(ctx context.Context, msg client.Message, opts ...client.PublishOption) error

+ func (c *GoRPCClient) Stream(ctx context.Context, req client.Request, opts ...client.CallOption) (client.Stream, error)

+ func (c *GoRPCClient) String() string

+ type GoRPCServer struct

+ func (s *GoRPCServer) Close() error

+ func (s *GoRPCServer) Handle(h server.Handler) error

+ func (s *GoRPCServer) Init(opts ...server.Option) error

+ func (s *GoRPCServer) NewHandler(h interface{}, opts ...server.HandlerOption) server.Handler

+ func (s *GoRPCServer) NewSubscriber(topic string, sb interface{}, opts ...server.SubscriberOption) server.Subscriber

+ func (s *GoRPCServer) Options() server.Options

+ func (s *GoRPCServer) Start() error

+ func (s *GoRPCServer) Stop() error

+ func (s *GoRPCServer) String() string

+ func (s *GoRPCServer) Subscribe(subscriber server.Subscriber) error

+ type RegistryType int

+ const RegistryType_CONSUL

+ const RegistryType_ETCD

+ const RegistryType_MDNS

+ const RegistryType_ZOOKEEPER

+ func (t RegistryType) String() string