mux

Documentation

Index

• func ReadProxyMessage(conn net.Conn, msg proto.Message) error
• func UpgradeToBindingConnection(log logr.Logger, conn net.Conn, host string, port int) (resp *pb_agent.ConnResponse, err error)
• func WriteProxyMessage(conn net.Conn, msg proto.Message) error
• type BindingUpgradeFailure
  • func (e *BindingUpgradeFailure) Error() string

Functions

func ReadProxyMessage

func ReadProxyMessage(conn net.Conn, msg proto.Message) error

ReadProxyMessage reads a protobuf message from a connection

func UpgradeToBindingConnection

func UpgradeToBindingConnection(log logr.Logger, conn net.Conn, host string, port int) (resp *pb_agent.ConnResponse, err error)

UpgradeToBindingConnection upgrades a connection to a binding connection by exchanging header information with the server. It may return a BindingUpgradeFailure error if the server can't upgrade the connection. The underlying connection may also return an error if the connection is closed or otherwise fails.

func WriteProxyMessage

func WriteProxyMessage(conn net.Conn, msg proto.Message) error

WriteProxyMessage writes a protobuf message to a connection

Types

type BindingUpgradeFailure

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

func (*BindingUpgradeFailure) Error

func (e *BindingUpgradeFailure) Error() string