relay

package module
v0.0.0-...-30f6e04 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 30, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 Logger

type Logger interface {
	Debug(args ...interface{})
	Print(args ...interface{})
	Info(args ...interface{})
	Warn(args ...interface{})
	Warning(args ...interface{})
	Error(args ...interface{})
	Panic(args ...interface{})
	Fatal(args ...interface{})
	Debugf(format string, args ...interface{})
	Printf(format string, args ...interface{})
	Infof(format string, args ...interface{})
	Warnf(format string, args ...interface{})
	Warningf(format string, args ...interface{})
	Errorf(format string, args ...interface{})
	Panicf(format string, args ...interface{})
	Fatalf(format string, args ...interface{})
}

type Relayer

type Relayer interface {
	Relay() error
}

type TCPtoUnixsocket

type TCPtoUnixsocket struct {
	AbstractDuplexRelay
}

func NewTCPtoUnixSocket

func NewTCPtoUnixSocket(
	logger Logger,
	tcpAddress,
	unixSocketPath string,
	bufferSize int,
) (*TCPtoUnixsocket, error)

type UnixSocketTCP

type UnixSocketTCP struct {
	AbstractDuplexRelay
}

func NewUnixSocketTCP

func NewUnixSocketTCP(
	logger Logger,
	unixSocketPath,
	tcpAddress string,
	bufferSize int,
) (*UnixSocketTCP, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL