rpc

package

v0.2.0 Latest Latest Go to latest Published: Apr 17, 2023 License: BSD-3-Clause Imports: 41 Imported by: 0

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/vanadium/core

Links

Open Source Insights

Documentation ¶

Index ¶

func NewClient(ctx *context.T, opts ...rpc.ClientOpt) rpc.Client
func RequestID(ctx *context.T) uuid.UUID
func WithNewDispatchingServer(ctx *context.T, name string, dispatcher rpc.Dispatcher, ...) (*context.T, rpc.Server, error)
func WithNewServer(ctx *context.T, name string, object interface{}, ...) (*context.T, rpc.Server, error)
func WithRequestID(ctx *context.T, requestID uuid.UUID) *context.T
type IdleConnectionExpiry
- func (IdleConnectionExpiry) RPCClientOpt()
- func (IdleConnectionExpiry) RPCServerOpt()
type PreferredProtocols
- func (PreferredProtocols) RPCClientOpt()
type PreferredServerResolveProtocols
- func (PreferredServerResolveProtocols) RPCServerOpt()
type ReservedNameDispatcher
- func (ReservedNameDispatcher) RPCServerOpt()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewClient ¶

func NewClient(ctx *context.T, opts ...rpc.ClientOpt) rpc.Client

func RequestID ¶ added in v0.1.14

func RequestID(ctx *context.T) uuid.UUID

func WithNewDispatchingServer ¶

func WithNewDispatchingServer(ctx *context.T,
	name string, dispatcher rpc.Dispatcher,
	settingsPublisher *pubsub.Publisher,
	opts ...rpc.ServerOpt) (*context.T, rpc.Server, error)

func WithNewServer ¶

func WithNewServer(ctx *context.T,
	name string, object interface{}, authorizer security.Authorizer,
	settingsPublisher *pubsub.Publisher,
	opts ...rpc.ServerOpt) (*context.T, rpc.Server, error)

func WithRequestID ¶ added in v0.1.14

func WithRequestID(ctx *context.T, requestID uuid.UUID) *context.T

Types ¶

type IdleConnectionExpiry ¶

type IdleConnectionExpiry time.Duration

IdleConnectionExpiry is the amount of the time after which the connection cache will close idle connections.

func (IdleConnectionExpiry) RPCClientOpt ¶

func (IdleConnectionExpiry) RPCClientOpt()

func (IdleConnectionExpiry) RPCServerOpt ¶

func (IdleConnectionExpiry) RPCServerOpt()

type PreferredProtocols ¶

type PreferredProtocols []string

PreferredProtocols instructs the Runtime implementation to select endpoints with the specified protocols when a Client makes a call and to order them in the specified order.

func (PreferredProtocols) RPCClientOpt ¶

func (PreferredProtocols) RPCClientOpt()

type PreferredServerResolveProtocols ¶

type PreferredServerResolveProtocols []string

This option is used to sort and filter the endpoints when resolving the proxy name from a mounttable.

func (PreferredServerResolveProtocols) RPCServerOpt ¶

func (PreferredServerResolveProtocols) RPCServerOpt()

type ReservedNameDispatcher ¶

type ReservedNameDispatcher struct {
	Dispatcher rpc.Dispatcher
}

ReservedNameDispatcher specifies the dispatcher that controls access to framework managed portion of the namespace.

func (ReservedNameDispatcher) RPCServerOpt ¶

func (ReservedNameDispatcher) RPCServerOpt()

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
benchmark module
stress Command stress is a tool to stress/load test RPC by issuing randomly generated requests.	Command stress is a tool to stress/load test RPC by issuing randomly generated requests.
internal
mtstress Usage:	Usage:
stressd Command stressd runs the stress-test server.	Command stressd runs the stress-test server.
test package test contains test for rpc code that do not rely on unexposed rpc declarations.	package test contains test for rpc code that do not rely on unexposed rpc declarations.
version

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