rpcplatform

Dec 5, 2025

Changes in this version

+ var ErrInvalidEtcdPrefix = errors.New("invalid etcd prefix")

+ var ErrInvalidServerName = errors.New("invalid server name")

+ var ErrInvalidTargetName = errors.New("invalid target name")

Oct 30, 2025

Changes in this version

+ var ClientOptions = options.Client

+ var PlatformOptions = options.Platform

+ var ServerOptions = options.Server

type Attributes

+ func NewAttributes() *Attributes

type Client

+ func (c *Client) ID() string

+ type ClientOption = func(*config.Client)

+ type PlatformOption = func(*config.Platform)

+ type ServerInfo struct

+ Address string

+ Attributes *Attributes

+ type ServerOption = func(*config.Server)

Oct 29, 2025

Changes in this version

type RPCPlatform

+ func (p *RPCPlatform) Lookup(ctx context.Context, name string, watch bool) (<-chan map[string]*serverinfo.ServerInfo, error)

type Server

+ func (s *Server) ID() string

May 24, 2024

Changes in this version

+ type ClientAttributes struct

+ func (ca *ClientAttributes) SetMaxActiveServers(count int)

type ServerAttributes

+ func (sa *ServerAttributes) SetBalancerPriority(priority int)

Dec 6, 2023

Changes in this version

+ func Attributes() attributes

+ type Client struct

+ func (c *Client) Client() *grpc.ClientConn

+ type RPCPlatform struct

+ func New(etcdPrefix string, etcdClient *etcd.Client, opts ...options.Option) (*RPCPlatform, error)

+ func (p *RPCPlatform) NewClient(target string) (*Client, error)

+ func (p *RPCPlatform) NewServer(name, addr string, attributes *ServerAttributes) (*Server, error)

+ type Server struct

+ func (s *Server) Serve() error

+ func (s *Server) Server() *grpc.Server

+ type ServerAttributes struct

+ func (sa *ServerAttributes) SetBalancerWeight(weight int)