README
¶
This directory and all of its subdirectories contain an implementation of the public APIs defined in v23.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AsyncCloudAddressChoser ¶ added in v0.1.10
func AsyncCloudAddressChoser(ctx context.Context, logger logging.Logger, fl *flags.VirtualizedFlags) rpc.AddressChooser
AsyncCloudAddressChoser asynchronously initializes the cloud vm environment and returns an rpc.AddressChooser that will wait for the environment to be determined.
Types ¶
type CloudVM ¶ added in v0.1.10
type CloudVM struct {
// contains filtered or unexported fields
}
func InitCloudVM ¶
func InitCloudVM(ctx context.Context, logger logging.Logger, fl *flags.VirtualizedFlags) (*CloudVM, error)
InitCloudVM initializes the CloudVM metadata using the configuration provided by VirtualizedFlags. It implements rpc.AddressChooser and provides a RefreshAddress method to update addresses based on current metadata settings. If PublicAddress is set it is used, then PublicDNSName and finally, if a VirtualizationProvider is defined its metadata service will be used. If the AdvertisePrivateAddresses flag is set then the private addresses and the candidate addresses supplied to the address chooser will also be returned by ChoseAddresses, otherwise only the public/external ones will be returned.
func (*CloudVM) ChooseAddresses ¶ added in v0.1.10
ChooseAddresses implements rpc.AddressChooser.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package cloudvm provides functions to test whether the current process is running on Google Compute Engine or Amazon Web Services, and to extract settings from this environment.
|
Package cloudvm provides functions to test whether the current process is running on Google Compute Engine or Amazon Web Services, and to extract settings from this environment. |
|
cmd
|
|
|
lib
|
|
|
bqueue
Package bqueue implements several kinds of buffer queues, as a N-writer, 1-reader queue.
|
Package bqueue implements several kinds of buffer queues, as a N-writer, 1-reader queue. |
|
bqueue/drrqueue
Package drrqueue implements a deficit round-robin buffer queue.
|
Package drrqueue implements a deficit round-robin buffer queue. |
|
dependency
Package dependency keeps track of a dependency graph.
|
Package dependency keeps track of a dependency graph. |
|
deque
Package deque implements a deque using a circular array.
|
Package deque implements a deque using a circular array. |
|
iobuf
Package iobuf performs explicit memory management for data buffers used to perform network IO.
|
Package iobuf performs explicit memory management for data buffers used to perform network IO. |
|
pcqueue
A producer/consumer queue is a concurrent bounded buffer supporting multiple concurrent producers and consumers, with timeouts.
|
A producer/consumer queue is a concurrent bounded buffer supporting multiple concurrent producers and consumers, with timeouts. |
|
sync
Package sync provides synchronization primitives.
|
Package sync provides synchronization primitives. |
|
upcqueue
Package upcqueue implements an unbounded producer/consumer queue.
|
Package upcqueue implements an unbounded producer/consumer queue. |
|
Package naming provides an implementation of the interfaces in v.io/v23/naming.
|
Package naming provides an implementation of the interfaces in v.io/v23/naming. |
|
benchmark
package benchmark provides simple tools to measure the performance of the IPC system.
|
package benchmark provides simple tools to measure the performance of the IPC system. |
|
benchmark/benchmark
Command benchmark runs the benchmark client.
|
Command benchmark runs the benchmark client. |
|
benchmark/benchmarkd
Command benchmarkd runs the benchmark server.
|
Command benchmarkd runs the benchmark server. |
|
stress/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. |
|
stress/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. |
|
stress/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. |
|
testing
|
|
|
concurrency
Package concurrency implements a framework for systematic testing of concurrent vanadium Go programs.
|
Package concurrency implements a framework for systematic testing of concurrent vanadium Go programs. |
Click to show internal directories.
Click to hide internal directories.