pktline

type ConnParams struct {
	Method       string
	URL          string
	Service      string
	ContentType  string // the request content-type
	SecurityOnly bool
}

type Connection interface {
	io.Closer

	GetGroup() ConnectionGroup

	GetAttribute(name string) any

	SetAttribute(name string, value any)

	GetParams() *ConnParams

	GetService() string

	// @return (reader,contentType,error)
	OpenReader() (ReaderCloser, string, error)

	OpenWriter(contentType string) (WriterCloser, error)

	// 创建新的附加连接
	NewConnection(p *ConnParams) (Connection, error)
}

type ConnectionGroup interface {
	GetAttribute(name string) any

	SetAttribute(name string, value any)
}

type Connector interface {
	Connect(p *ConnParams) (Connection, error)

	Accept(p *ConnParams) bool
}

type ConnectorManager interface {
	Connector
}

type ConnectorRegistration struct {
	Connector Connector
}

type ConnectorRegistry interface {
	GetRegistration() *ConnectorRegistration
}

type Packet struct {

	// * '0000' Flush Packet (flush-pkt) - indicates the end of a message
	// * '0001' Delimiter Packet (delim-pkt) - separates sections of a message
	// * '0002' Response End Packet (response-end-pkt) - indicates the end of a response for stateless connections
	Special bool

	Length int
	Head   string
	Body   []byte
}

type Reader interface {
	Read() (*Packet, error)
}

type ReaderCloser interface {
	Reader
	io.Closer
}

type ReaderRaw interface {
	GetReader() io.Reader
}

type Writer interface {
	Write(p *Packet) error
}

type WriterCloser interface {
	io.Closer
	Writer
}

type WriterRaw interface {
	GetWriter() io.Writer
}