bidi

Documentation

Index

• Constants
• Variables
• func NewErrBidiRoutingIdNotCached(ctx *context.T) error
• func NewErrCannotListenOnBidi(ctx *context.T) error
• type Bidi
  • func (Bidi) Dial(ctx *context.T, network, address string, timeout time.Duration) (flow.Conn, error)
  • func (Bidi) Listen(ctx *context.T, network, address string) (flow.Listener, error)
  • func (Bidi) Resolve(ctx *context.T, network, address string) (string, []string, error)

Constants

const Name = "bidi"

Variables

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)