transport

type Bom [12]byte

type CompressType byte

type Config struct {
	config.Config
	Name       string `field:"-"` // config name/path in config file
	PrefixName string `field:"-"` // config prefix name
	Listener   IListener
	// Addrs is the list of intermediary addresses to connect to
	Addrs []string

	// 证书
	EnableACME   bool          `field:"enable_acme"`
	ACMEHosts    []string      `field:"acme_hosts"`
	ACMEProvider acme.Provider `field:"-"`
	// Secure tells the transport to secure the connection.
	// In the case TLSConfig is not specified best effort self-signed
	// certs should be used
	Secure bool
	// TLSConfig to secure the connection. The assumption is that this
	// is mTLS keypair
	TlsConfig *tls.Config

	//DialTimeout sets timeout for dialing
	DialTimeout time.Duration
	// ReadTimeout sets readdeadline for underlying net.Conns
	ReadTimeout time.Duration
	// WriteTimeout sets writedeadline for underlying net.Conns
	WriteTimeout time.Duration

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type ContextKeyHeader struct{}

type Cookie struct {
	Name  string `json:"name"`
	Value string `json:"value"`

	Path        string `json:"path"`   // optional
	Domain      string `json:"domain"` // optional
	Expires     time.Time
	JSONExpires Time   `json:"expires"`    // optional
	RawExpires  string `json:"rawExpires"` // for reading cookies only

	// MaxAge=0 means no 'Max-Age' attribute specified.
	// MaxAge<0 means delete cookie now, equivalently 'Max-Age: 0'
	// MaxAge>0 means Max-Age attribute present and given in seconds
	MaxAge   int           `json:"maxAge"`
	Secure   bool          `json:"secure"`
	HTTPOnly bool          `json:"httpOnly"`
	SameSite http.SameSite `json:"sameSite"`
	Raw      string
	Unparsed []string `json:"unparsed"` // Raw text of unparsed attribute-value pairs
}

type DialConfig struct {
	// Tells the transport this is a streaming connection with
	// multiple calls to send/recv and that send may not even be called
	Stream bool
	// Other options for implementations of the interface
	// can be stored in a context
	Secure      bool
	DialTimeout time.Duration
	// ReadTimeout sets readdeadline for underlying net.Conns
	ReadTimeout time.Duration
	// WriteTimeout sets writedeadline for underlying net.Conns
	WriteTimeout time.Duration

	// TODO: add tls options when dialling
	// Currently set in global options
	Ja3      Ja3 // TODO 添加加缓存
	ProxyURL string

	Network string

	Context context.Context
	// contains filtered or unexported fields
}

type DialOption func(*DialConfig)

type ErrExtensionNotExist string

type Handler interface {
	String() string
	Handler() interface{}
}

type HttpConn struct {
	// contains filtered or unexported fields
}

type HttpTransport struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type IBody interface {
	Read(interface{}) error
	Write(interface{}) error
}

type IClient interface {
	ISocket
	Transport() ITransport
}

type IHeader interface {
	Add(key, value string)
	Set(key, value string)
	Get(key string) string
	//has(key string) bool
	Del(key string)
}

type IListener interface {
	Addr() net.Addr
	Close() error
	Accept() (net.Conn, error)
	//Serve(func(ISocket)) error // 阻塞监听
	Serve(Handler) error // 阻塞监听

}

type IRequest interface {
	// The service to call
	Service() string
	// The action to take
	Method() string
	// The content type
	ContentType() string
	// write a response directly to the client
	Body() IBody // *body.TBody

	Codec() codec.ICodec
}

type IResponse interface {
	// write a response directly to the client
	Write([]byte) (int, error)
	WriteStream(interface{}) error
	Body() *body.TBody
}

type IResponseWriter interface {
	http.ResponseWriter
	// Status returns the status code of the response or 0 if the response has not been written.
	Status() int
	// Written returns whether or not the ResponseWriter has been written.
	Written() bool
	// Size returns the size of the response body.
	Size() int
}

type ISocket interface {
	Recv(*Message) error
	Send(*Message) error
	Close() error
	Local() string  // Local IP
	Remote() string // Remote IP
	Conn() net.Conn // 接口提供更灵活扩展
}

type ITransport interface {
	Init(...Option) error
	Config() *Config
	Dial(addr string, opts ...DialOption) (IClient, error)       // for client 详细查看pool.NewPool
	Listen(addr string, opts ...ListenOption) (IListener, error) // for server
	String() string
	Protocol() string
}

type Ja3 struct {
	Ja3       string
	UserAgent string
	Hash      string
}

type ListenConfig struct {

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type ListenOption func(*ListenConfig)

type Message struct {
	*Bom // 字节码
	//Service  string            // service path
	//Endpoint string            // method path
	Path    string            // the path
	Header  map[string]string // 消息头
	Body    []byte            // 消息主体
	Payload []byte            // 消息主体中的内容

}

type MessageStatusType byte

type MessageType byte

type Option func(*Config)

type Pool struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type RpcRequest struct {
	Message    *Message
	RemoteAddr string

	// Context is either the client or server context. It should only
	// be modified via copying the whole Request using WithContext.
	// It is unexported to prevent people from using Context wrong
	// and mutating the contexts held by callers of the same request.
	Context context.Context
	// contains filtered or unexported fields
}

type RpcResponse struct {
	Request *RpcRequest // request for this response
	// contains filtered or unexported fields
}

type Socket struct {
	// contains filtered or unexported fields
}

type THttpRequest struct {
	*http.Request
	Transport ITransport
	// contains filtered or unexported fields
}

type THttpResponse struct {
	http.ResponseWriter

	Val reflect.Value
	// contains filtered or unexported fields
}

type Time struct {
	time.Time
}