pktline

type ConnParams struct {
	Method  string
	URL     string
	Service string
}

type Connection interface {
	io.Closer

	GetGroup() ConnectionGroup

	GetAttribute(name string) any

	SetAttribute(name string, value any)

	GetParams() *ConnParams

	GetService() string

	Reader() Reader

	Writer() Writer

	// 创建新的附加连接
	NewConnection(service string) (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 {
	Length int
	Flush  bool
	Head   string
	Body   []byte
}

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

type ReaderCloser interface {
	Reader
	io.Closer
}

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

type WriterCloser interface {
	io.Closer
	Writer
}