net

type Conn struct {
	// Stream is the stream to wrap into a Conn. This is duplex stream.
	Stream *websocket.Conn

	// InMsg is the type to use for reading request data from the streaming
	// endpoint. This must be a non-nil allocated value and must NOT point to
	// the same value as OutMsg since they may be used concurrently.
	//
	// The Reset method will be called on InMsg during Reads so data you
	// set initially will be lost.
	InMsg proto.Message

	// OutMsg is the type to use for sending data to streaming endpoint. This must be
	// a non-nil allocated value and must NOT point to the same value as InMsg
	// since they may be used concurrently.
	//
	// The Reset method is never called on OutMsg so they will be sent for every request
	// unless the Encode field changes it.
	OutMsg proto.Message

	// WriteLock, if non-nil, will be locked while calling SendMsg
	// on the Stream. This can be used to prevent concurrent access to
	// SendMsg which is unsafe.
	WriteLock *sync.Mutex

	// Encode encodes messages into the Request. See Encoder for more information.
	Encode common.Encoder

	// Decode decodes messages from the Response into a byte slice. See
	// Decoder for more information.
	Decode common.Decoder
	// contains filtered or unexported fields
}

type Connect struct {
	Version             uint8
	InsecureFlag        bool
	ClientID            []byte
	KeepAlive           uint16
	CleanSessFlag       bool
	SessKey             uint32
	Username            string
	Password            []byte
	BatchDuration       int32
	BatchByteThreshold  int32
	BatchCountThreshold int32

	LineProtocol
}

type ConnectAcknowledge struct {
	ReturnCode uint8
	Epoch      uint32
	ConnID     uint32

	LineProtocol
}

type ControlMessage struct {
	MessageID   uint16
	MessageType MessageType
	FlowControl FlowControl
	Message     LineProtocol
}

type DeliveryMode uint8

type Disconnect struct {
	LineProtocol
}

type FixedHeader struct {
	MessageType    uint8
	FlowControl    uint8
	MesssageLength int
}

type FlowControl uint8

type GrpcServer server

type Handler func(c net.Conn)

type HttpServer server

type Info struct {
	DeliveryMode uint8
	MessageID    uint16
}

type LineProtocol interface {
	Type() MessageType
	Info() Info
}

type MessageType uint8

type Options interface {
	// contains filtered or unexported methods
}

type Pingreq struct {
	LineProtocol
}

type Proto int

type ProtoAdapter interface {
	Read(r io.Reader) (LineProtocol, error)
	Encode(msg LineProtocol) (bytes.Buffer, error)
}

type Publish struct {
	IsForwarded  bool
	MessageID    uint16
	DeliveryMode uint8
	Messages     []*PublishMessage

	LineProtocol
}

type PublishMessage struct {
	Topic   []byte
	Payload []byte
	Ttl     string
}

type Server interface {
	// Serve serve the requests if type tcp, websocket or grpc stream
	Serve(net.Listener) error
}

type Subscribe struct {
	IsForwarded   bool
	MessageID     uint16
	Subscriptions []*Subscription

	LineProtocol
}

type Subscription struct {
	DeliveryMode uint8
	Delay        int32
	Topic        []byte
	Last         string
}

type TcpServer server

type Unsubscribe struct {
	IsForwarded   bool
	MessageID     uint16
	Subscriptions []*Subscription

	LineProtocol
}