xgress_common

Documentation

Index

• Constants
• func CheckForFailureResult(msg *channel.Message, err error, successType edge_ctrl_pb.ContentType) error
• func GetFinHeaders() map[uint8][]byte
• func GetResultOrFailure(msg *channel.Message, err error, result protobufs.TypedMessage) error
• func IsBearerToken(s string) bool
• type XgressConn
  • func NewXgressConn(conn net.Conn, halfClose bool, isTransport bool) *XgressConn
  • func (self *XgressConn) Close() error
  • func (self *XgressConn) CloseWrite() error
  • func (self *XgressConn) HandleControlMsg(controlType xgress.ControlType, headers channel.Headers, ...) 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 (
	DefaultBufferSize = 10 * 1024
)

const JwtExpectedDelimCount = 2

const JwtTokenPrefix = "ey"

const (
	PayloadFlagsHeader uint8 = 0x10
)

Functions

func CheckForFailureResult

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

func GetFinHeaders

func GetFinHeaders() map[uint8][]byte

func GetResultOrFailure

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

func IsBearerToken

func IsBearerToken(s string) bool

IsBearerToken checks to see if a string has the basic structure required of a JWT.

Types

type XgressConn

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

func NewXgressConn

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

func (*XgressConn) Close

func (self *XgressConn) Close() error

func (*XgressConn) CloseWrite

func (self *XgressConn) CloseWrite() error

func (*XgressConn) HandleControlMsg

func (self *XgressConn) HandleControlMsg(controlType xgress.ControlType, headers channel.Headers, responder xgress.ControlReceiver) 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)