relay

Documentation

Index

• type AbstractDuplexRelay
  • func (r *AbstractDuplexRelay) Relay(ctx context.Context) error
• type DeadlineConnection
  • func NewDeadlineConnection(conn net.Conn, writeDeadlineTimeout, readDeadlineTimeout time.Duration) *DeadlineConnection
  • func (d *DeadlineConnection) Read(b []byte) (int, error)
  • func (d *DeadlineConnection) Write(b []byte) (int, error)
• type Relayer
• type TCPtoUnixsocket
  • func NewTCPtoUnixSocket(logger logger.Logger, healthCheckInterval time.Duration, ...) (*TCPtoUnixsocket, error)
• type UnixSocketTCP
  • func NewUnixSocketTCP(logger logger.Logger, healthCheckInterval time.Duration, ...) (*UnixSocketTCP, error)

Types

type AbstractDuplexRelay

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

func (*AbstractDuplexRelay) Relay

func (r *AbstractDuplexRelay) Relay(ctx context.Context) error

type DeadlineConnection

type DeadlineConnection struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewDeadlineConnection

func NewDeadlineConnection(conn net.Conn, writeDeadlineTimeout, readDeadlineTimeout time.Duration) *DeadlineConnection

func (*DeadlineConnection) Read

func (d *DeadlineConnection) Read(b []byte) (int, error)

func (*DeadlineConnection) Write

func (d *DeadlineConnection) Write(b []byte) (int, error)

type Relayer

type Relayer interface {
	Relay() error
}

type TCPtoUnixsocket

type TCPtoUnixsocket struct {
	AbstractDuplexRelay
}

func NewTCPtoUnixSocket

func NewTCPtoUnixSocket(
	logger logger.Logger,
	healthCheckInterval time.Duration,
	tcpAddress,
	unixSocketPath string,
	bufferSize int,
) (*TCPtoUnixsocket, error)

type UnixSocketTCP

type UnixSocketTCP struct {
	AbstractDuplexRelay
}

func NewUnixSocketTCP

func NewUnixSocketTCP(
	logger logger.Logger,
	healthCheckInterval time.Duration,
	unixSocketPath,
	tcpAddress string,
	bufferSize int,
) (*UnixSocketTCP, error)