bidi

Documentation

Index

• Constants
• Variables
• func ErrorfBidiRoutingIdNotCached(ctx *context.T, format string) error
• func ErrorfCannotListenOnBidi(ctx *context.T, format string) error
• func MessageBidiRoutingIdNotCached(ctx *context.T, message string) error
• func MessageCannotListenOnBidi(ctx *context.T, message string) error
• func NewErrBidiRoutingIdNotCached(ctx *context.T) error
• func NewErrCannotListenOnBidi(ctx *context.T) error
• func ParamsErrBidiRoutingIdNotCached(argumentError error) (verrorComponent string, verrorOperation string, returnErr error)
• func ParamsErrCannotListenOnBidi(argumentError error) (verrorComponent string, verrorOperation string, returnErr 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.NewIDAction("v.io/x/ref/runtime/protocols/bidi.CannotListenOnBidi", verror.NoRetry)
	ErrBidiRoutingIdNotCached = verror.NewIDAction("v.io/x/ref/runtime/protocols/bidi.BidiRoutingIdNotCached", verror.NoRetry)
)

Functions

func ErrorfBidiRoutingIdNotCached

func ErrorfBidiRoutingIdNotCached(ctx *context.T, format string) error

ErrorfBidiRoutingIdNotCached calls ErrBidiRoutingIdNotCached.Errorf with the supplied arguments.

func ErrorfCannotListenOnBidi

func ErrorfCannotListenOnBidi(ctx *context.T, format string) error

ErrorfCannotListenOnBidi calls ErrCannotListenOnBidi.Errorf with the supplied arguments.

func MessageBidiRoutingIdNotCached

func MessageBidiRoutingIdNotCached(ctx *context.T, message string) error

MessageBidiRoutingIdNotCached calls ErrBidiRoutingIdNotCached.Message with the supplied arguments.

func MessageCannotListenOnBidi

func MessageCannotListenOnBidi(ctx *context.T, message string) error

MessageCannotListenOnBidi calls ErrCannotListenOnBidi.Message with the supplied arguments.

func NewErrBidiRoutingIdNotCached

func NewErrBidiRoutingIdNotCached(ctx *context.T) error

NewErrBidiRoutingIdNotCached returns an error with the ErrBidiRoutingIdNotCached ID. Deprecated: this function will be removed in the future, use ErrorfBidiRoutingIdNotCached or MessageBidiRoutingIdNotCached instead.

func NewErrCannotListenOnBidi

func NewErrCannotListenOnBidi(ctx *context.T) error

NewErrCannotListenOnBidi returns an error with the ErrCannotListenOnBidi ID. Deprecated: this function will be removed in the future, use ErrorfCannotListenOnBidi or MessageCannotListenOnBidi instead.

func ParamsErrBidiRoutingIdNotCached

func ParamsErrBidiRoutingIdNotCached(argumentError error) (verrorComponent string, verrorOperation string, returnErr error)

ParamsErrBidiRoutingIdNotCached extracts the expected parameters from the error's ParameterList.

func ParamsErrCannotListenOnBidi

func ParamsErrCannotListenOnBidi(argumentError error) (verrorComponent string, verrorOperation string, returnErr error)

ParamsErrCannotListenOnBidi extracts the expected parameters from the error's ParameterList.

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)