Versions in this module Expand all Collapse all v0 v0.1.0 Mar 26, 2025 Changes in this version + const DefaultMaxConcurrentStreams + const Name + func CreateClientServerPair(ctx context.Context, endpoint string) (*Stream, *Stream) + func New(serviceName string, serviceVersion string, epName string, acfg any, ...) (orbserver.Entrypoint, error) + func Provide(serviceName string, serviceVersion string, epName string, ...) (orbserver.Entrypoint, error) + func WithHandlers(h ...server.RegistrationFunc) server.Option + func WithLogLevel(level string) server.Option + func WithLogPlugin(plugin string) server.Option + func WithMaxConcurrentStreams(n int) server.Option + type Config struct + Logger log.Config + MaxConcurrentStreams int + func NewConfig(options ...server.Option) *Config + type Mux struct + func (m *Mux) HandleRPC(stream drpc.Stream, rpc string) (err error) + func (m *Mux) Register(srv interface{}, desc drpc.Description) error + type Server struct + func (s *Server) AddEndpoint(name string) + func (s *Server) AddHandler(handler orbserver.RegistrationFunc) + func (s *Server) Address() string + func (s *Server) Enabled() bool + func (s *Server) Name() string + func (s *Server) Network() string + func (s *Server) Register(register orbserver.RegistrationFunc) + func (s *Server) Request(ctx context.Context, infos client.RequestInfos, req any, result any, ...) error + func (s *Server) Router() *Mux + func (s *Server) Start(ctx context.Context) error + func (s *Server) Stop(_ context.Context) error + func (s *Server) Stream(ctx context.Context, infos client.RequestInfos, opts *client.CallOptions) (client.StreamIface[any, any], error) + func (s *Server) String() string + func (s *Server) Transport() string + func (s *Server) Type() string + type Stream struct + func (s *Stream) Close() error + func (s *Stream) CloseSend() error + func (s *Stream) Context() context.Context + func (s *Stream) MsgRecv(msg drpc.Message, _ drpc.Encoding) error + func (s *Stream) MsgSend(msg drpc.Message, _ drpc.Encoding) error + func (s *Stream) Recv(msg any) error + func (s *Stream) Send(msg any) error
Go to main page