tunnel

Documentation

Index

• Constants
• Variables
• type Client
  • func (d *Client) Close() error
  • func (d *Client) Read() chan *events.Outbound
  • func (d *Client) Start(ctx context.Context, bus string, errorCh chan<- *records.ErrorRecord) error
• type ITunnel
  • func New(opts *opts.TunnelOptions, plumberClusterID string) (ITunnel, error)

Constants

const (
	// DefaultTunnelAddress is the default address that the tunnel pkg will
	// use if an alternate address is not specified
	DefaultTunnelAddress = "dproxy.batch.sh:443"

	// ReconnectSleep determines the length of time to wait between reconnect attempts to dProxy
	ReconnectSleep = time.Second * 5

	DefaultGRPCTimeoutSeconds = 5
)

Variables

var (
	ErrNotAuthorized = errors.New("not authorized")
)

Types

type Client

type Client struct {
	Client services.DProxyClient
	Conn   *grpc.ClientConn
	Token  string

	PlumberClusterID  string
	OutboundMessageCh chan *events.Outbound

	Options *opts.TunnelOptions
	// contains filtered or unexported fields
}

func (*Client) Close

func (d *Client) Close() error

func (*Client) Read

func (d *Client) Read() chan *events.Outbound

func (*Client) Start

func (d *Client) Start(ctx context.Context, bus string, errorCh chan<- *records.ErrorRecord) error

Start is called by a backend's Tunnel() method. It authorizes the connection and begins reading a GRPC stream of responses consisting of Tunnel protobuf messages.

type ITunnel

type ITunnel interface {
	Start(ctx context.Context, bus string, errorCh chan<- *records.ErrorRecord) error
	Read() chan *events.Outbound
	Close() error
}

func New

func New(opts *opts.TunnelOptions, plumberClusterID string) (ITunnel, error)

New validates CLI options and returns a new Client struct