xgress_common

Documentation

Index

• Constants
• func CheckForFailureResult(msg *channel2.Message, err error, successType edge_ctrl_pb.ContentType) error
• func GetFinHeaders() map[uint8][]byte
• func GetResultOrFailure(msg *channel2.Message, err error, result channel2.TypedMessage) error
• type XgressConn
  • func NewXgressConn(conn net.Conn, halfClose bool) *XgressConn
  • func (self *XgressConn) Close() error
  • func (self *XgressConn) CloseWrite() error
  • func (self *XgressConn) IsClosed() bool
  • func (self *XgressConn) IsWriteClosed() bool
  • func (self *XgressConn) LogContext() string
  • func (self *XgressConn) ReadPayload() ([]byte, map[uint8][]byte, error)
  • func (self *XgressConn) SetupClientCrypto(keyPair *kx.KeyPair, peerKey []byte) error
  • func (self *XgressConn) SetupServerCrypto(peerKey []byte) ([]byte, error)
  • func (self *XgressConn) WritePayload(p []byte, headers map[uint8][]byte) (int, error)

Constants

const (
	PayloadFlagsHeader uint8 = 0x10
)

Functions

func CheckForFailureResult

func CheckForFailureResult(msg *channel2.Message, err error, successType edge_ctrl_pb.ContentType) error

func GetFinHeaders

func GetFinHeaders() map[uint8][]byte

func GetResultOrFailure

func GetResultOrFailure(msg *channel2.Message, err error, result channel2.TypedMessage) error

Types

type XgressConn

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

func NewXgressConn

func NewXgressConn(conn net.Conn, halfClose bool) *XgressConn

func (*XgressConn) Close

func (self *XgressConn) Close() error

func (*XgressConn) CloseWrite

func (self *XgressConn) CloseWrite() error

func (*XgressConn) IsClosed

func (self *XgressConn) IsClosed() bool

func (*XgressConn) IsWriteClosed

func (self *XgressConn) IsWriteClosed() bool

func (*XgressConn) LogContext

func (self *XgressConn) LogContext() string

func (*XgressConn) ReadPayload

func (self *XgressConn) ReadPayload() ([]byte, map[uint8][]byte, error)

func (*XgressConn) SetupClientCrypto

func (self *XgressConn) SetupClientCrypto(keyPair *kx.KeyPair, peerKey []byte) error

func (*XgressConn) SetupServerCrypto

func (self *XgressConn) SetupServerCrypto(peerKey []byte) ([]byte, error)

func (*XgressConn) WritePayload

func (self *XgressConn) WritePayload(p []byte, headers map[uint8][]byte) (int, error)