bidi

package
v0.0.0-...-3dadef2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 11, 2016 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const Name = "bidi"

Variables

View Source
var (
	ErrCannotListenOnBidi     = verror.Register("v.io/x/ref/runtime/protocols/bidi.CannotListenOnBidi", verror.NoRetry, "{1:}{2:} cannot listen on bidi protocol")
	ErrBidiRoutingIdNotCached = verror.Register("v.io/x/ref/runtime/protocols/bidi.BidiRoutingIdNotCached", verror.NoRetry, "{1:}{2:} bidi routing id not in cache")
)

Functions

func NewErrBidiRoutingIdNotCached

func NewErrBidiRoutingIdNotCached(ctx *context.T) error

NewErrBidiRoutingIdNotCached returns an error with the ErrBidiRoutingIdNotCached ID.

func NewErrCannotListenOnBidi

func NewErrCannotListenOnBidi(ctx *context.T) error

NewErrCannotListenOnBidi returns an error with the ErrCannotListenOnBidi ID.

Types

type Bidi

type Bidi struct{}

Bidi protocol represents the protocol to make a bidirectional RPC. Dial, Resolve, and Listen all fail on the Bidi protocol because the RoutingID of the end server must already be in the flow.Manager's cache for the bidirectional call to succeed.

func (Bidi) Dial

func (Bidi) Dial(ctx *context.T, network, address string, timeout time.Duration) (flow.Conn, error)

func (Bidi) Listen

func (Bidi) Listen(ctx *context.T, network, address string) (flow.Listener, error)

func (Bidi) Resolve

func (Bidi) Resolve(ctx *context.T, network, address string) (string, []string, error)

Jump to

Keyboard shortcuts

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