v.io: v.io/x/ref/services/xproxy/xproxy Index | Files

package xproxy

import "v.io/x/ref/services/xproxy/xproxy"

Package xproxy contains the implementation of the proxy service.

Design document at https://docs.google.com/document/d/1ONrnxGhOrA8pd0pK0aN5Ued2Q1Eju4zn7vlLt9nzIRA/edit?usp=sharing

nolint:golint

Index

Package Files

proxy.go util.go xproxy.vdl.go

Variables

var (
    ErrNotListening              = verror.NewIDAction("v.io/x/ref/services/xproxy/xproxy.NotListening", verror.NoRetry)
    ErrUnexpectedMessage         = verror.NewIDAction("v.io/x/ref/services/xproxy/xproxy.UnexpectedMessage", verror.NoRetry)
    ErrFailedToResolveToEndpoint = verror.NewIDAction("v.io/x/ref/services/xproxy/xproxy.FailedToResolveToEndpoint", verror.NoRetry)
    ErrProxyAlreadyClosed        = verror.NewIDAction("v.io/x/ref/services/xproxy/xproxy.ProxyAlreadyClosed", verror.NoRetry)
    ErrProxyResponse             = verror.NewIDAction("v.io/x/ref/services/xproxy/xproxy.ProxyResponse", verror.NoRetry)
)

func ErrorfFailedToResolveToEndpoint Uses

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

ErrorfFailedToResolveToEndpoint calls ErrFailedToResolveToEndpoint.Errorf with the supplied arguments.

func ErrorfNotListening Uses

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

ErrorfNotListening calls ErrNotListening.Errorf with the supplied arguments.

func ErrorfProxyAlreadyClosed Uses

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

ErrorfProxyAlreadyClosed calls ErrProxyAlreadyClosed.Errorf with the supplied arguments.

func ErrorfProxyResponse Uses

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

ErrorfProxyResponse calls ErrProxyResponse.Errorf with the supplied arguments.

func ErrorfUnexpectedMessage Uses

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

ErrorfUnexpectedMessage calls ErrUnexpectedMessage.Errorf with the supplied arguments.

func MessageFailedToResolveToEndpoint Uses

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

MessageFailedToResolveToEndpoint calls ErrFailedToResolveToEndpoint.Message with the supplied arguments.

func MessageNotListening Uses

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

MessageNotListening calls ErrNotListening.Message with the supplied arguments.

func MessageProxyAlreadyClosed Uses

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

MessageProxyAlreadyClosed calls ErrProxyAlreadyClosed.Message with the supplied arguments.

func MessageProxyResponse Uses

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

MessageProxyResponse calls ErrProxyResponse.Message with the supplied arguments.

func MessageUnexpectedMessage Uses

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

MessageUnexpectedMessage calls ErrUnexpectedMessage.Message with the supplied arguments.

func NewErrFailedToResolveToEndpoint Uses

func NewErrFailedToResolveToEndpoint(ctx *context.T, name string) error

NewErrFailedToResolveToEndpoint returns an error with the ErrFailedToResolveToEndpoint ID. Deprecated: this function will be removed in the future, use ErrorfFailedToResolveToEndpoint or MessageFailedToResolveToEndpoint instead.

func NewErrNotListening Uses

func NewErrNotListening(ctx *context.T) error

NewErrNotListening returns an error with the ErrNotListening ID. Deprecated: this function will be removed in the future, use ErrorfNotListening or MessageNotListening instead.

func NewErrProxyAlreadyClosed Uses

func NewErrProxyAlreadyClosed(ctx *context.T) error

NewErrProxyAlreadyClosed returns an error with the ErrProxyAlreadyClosed ID. Deprecated: this function will be removed in the future, use ErrorfProxyAlreadyClosed or MessageProxyAlreadyClosed instead.

func NewErrProxyResponse Uses

func NewErrProxyResponse(ctx *context.T, msg string) error

NewErrProxyResponse returns an error with the ErrProxyResponse ID. Deprecated: this function will be removed in the future, use ErrorfProxyResponse or MessageProxyResponse instead.

func NewErrUnexpectedMessage Uses

func NewErrUnexpectedMessage(ctx *context.T, msgType string) error

NewErrUnexpectedMessage returns an error with the ErrUnexpectedMessage ID. Deprecated: this function will be removed in the future, use ErrorfUnexpectedMessage or MessageUnexpectedMessage instead.

func ParamsErrFailedToResolveToEndpoint Uses

func ParamsErrFailedToResolveToEndpoint(argumentError error) (verrorComponent string, verrorOperation string, name string, returnErr error)

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

func ParamsErrNotListening Uses

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

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

func ParamsErrProxyAlreadyClosed Uses

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

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

func ParamsErrProxyResponse Uses

func ParamsErrProxyResponse(argumentError error) (verrorComponent string, verrorOperation string, msg string, returnErr error)

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

func ParamsErrUnexpectedMessage Uses

func ParamsErrUnexpectedMessage(argumentError error) (verrorComponent string, verrorOperation string, msgType string, returnErr error)

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

type Proxy Uses

type Proxy struct {
    // contains filtered or unexported fields
}

Proxy represents an instance of a proxy service.

func New Uses

func New(ctx *context.T, name string, auth security.Authorizer) (*Proxy, error)

New returns a new instance of Proxy.

func (*Proxy) Closed Uses

func (p *Proxy) Closed() <-chan struct{}

Closed returns a channel that will be closed when the proxy is shutdown.

func (*Proxy) ListeningEndpoints Uses

func (p *Proxy) ListeningEndpoints() []naming.Endpoint

ListeningEndpoints returns the endpoints the proxy is listening on.

Package xproxy imports 17 packages (graph) and is imported by 5 packages. Updated 2020-10-22. Refresh now. Tools for package owners.