rpc

package

v0.1.4 Latest Latest Go to latest Published: Sep 3, 2019 License: BSD-3-Clause Imports: 40 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 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)
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 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)

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 Command benchmark runs the benchmark client.	Command benchmark runs the benchmark client.
benchmarkd Command benchmarkd runs the benchmark server.	Command benchmarkd runs the benchmark server.
internal
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: mtstress [flags] <command> The mtstress commands are: mount Measure latency of the Mount RPC at a fixed request rate resolve Measure latency of the Resolve RPC at a fixed request rate help Display help for commands or topics The global flags are: -duration=10s Duration for sending test traffic and measuring latency -rate=1 Rate, in RPCs per second, to send to the test server -reauthenticate=false If true, establish a new authenticated connection for each RPC, simulating load from a distinct process -alsologtostderr=true log to standard error as well as files -log_backtrace_at=:0 when logging hits line file:N, emit a stack trace -log_dir= if non-empty, write log files to this directory -logtostderr=false log to standard error instead of files -max_stack_buf_size=4292608 max size in bytes of the buffer to use for logging stack traces -metadata=<just specify -metadata to activate> Displays metadata for the program and exits.	Usage: mtstress [flags] <command> The mtstress commands are: mount Measure latency of the Mount RPC at a fixed request rate resolve Measure latency of the Resolve RPC at a fixed request rate help Display help for commands or topics The global flags are: -duration=10s Duration for sending test traffic and measuring latency -rate=1 Rate, in RPCs per second, to send to the test server -reauthenticate=false If true, establish a new authenticated connection for each RPC, simulating load from a distinct process -alsologtostderr=true log to standard error as well as files -log_backtrace_at=:0 when logging hits line file:N, emit a stack trace -log_dir= if non-empty, write log files to this directory -logtostderr=false log to standard error instead of files -max_stack_buf_size=4292608 max size in bytes of the buffer to use for logging stack traces -metadata=<just specify -metadata to activate> Displays metadata for the program and exits.
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