server

package

v0.5.2 Latest Latest Go to latest Published: Nov 18, 2023 License: Apache-2.0 Imports: 17 Imported by: 4

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/livekit/psrpc

Links

Open Source Insights

Documentation ¶

Index ¶

func RegisterHandler[RequestType proto.Message, ResponseType proto.Message](s *RPCServer, rpc string, topic []string, ...) error
func RegisterStreamHandler[RequestType proto.Message, ResponseType proto.Message](s *RPCServer, rpc string, topic []string, ...) error
type AffinityFunc
type RPCServer
- func NewRPCServer(sd *info.ServiceDefinition, b bus.MessageBus, opts ...psrpc.ServerOption) *RPCServer
type Registerer
- func NewRegisterer(register, deregister any) Registerer
type RegistererSlice
- func (rs RegistererSlice) Deregister(params ...any)
- func (rs RegistererSlice) Register(params ...any) error
type StreamAffinityFunc

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func RegisterHandler ¶

func RegisterHandler[RequestType proto.Message, ResponseType proto.Message](
	s *RPCServer,
	rpc string,
	topic []string,
	svcImpl func(context.Context, RequestType) (ResponseType, error),
	affinityFunc AffinityFunc[RequestType],
) error

func RegisterStreamHandler ¶

func RegisterStreamHandler[RequestType proto.Message, ResponseType proto.Message](
	s *RPCServer,
	rpc string,
	topic []string,
	svcImpl func(psrpc.ServerStream[ResponseType, RequestType]) error,
	affinityFunc StreamAffinityFunc,
) error

Types ¶

type AffinityFunc ¶

type AffinityFunc[RequestType proto.Message] func(context.Context, RequestType) float32

type RPCServer ¶

type RPCServer struct {
	*info.ServiceDefinition
	psrpc.ServerOpts
	// contains filtered or unexported fields
}

func NewRPCServer ¶

func NewRPCServer(sd *info.ServiceDefinition, b bus.MessageBus, opts ...psrpc.ServerOption) *RPCServer

func (*RPCServer) Close ¶

func (s *RPCServer) Close(force bool)

func (*RPCServer) DeregisterHandler ¶

func (s *RPCServer) DeregisterHandler(rpc string, topic []string)

func (*RPCServer) Publish ¶

func (s *RPCServer) Publish(ctx context.Context, rpc string, topic []string, msg proto.Message) error

type Registerer ¶

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

func NewRegisterer ¶

func NewRegisterer(register, deregister any) Registerer

type RegistererSlice ¶

type RegistererSlice []Registerer

func (RegistererSlice) Deregister ¶

func (rs RegistererSlice) Deregister(params ...any)

func (RegistererSlice) Register ¶

func (rs RegistererSlice) Register(params ...any) error

type StreamAffinityFunc ¶

type StreamAffinityFunc func(ctx context.Context) float32

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL