api

type BaseTransportClient struct {
	EventChan chan ConnectEvent
	Watchers  []ConnectEventListener
	Filters   []func(req *ServerRequest)
	CancelFs  []context.CancelFunc
	// contains filtered or unexported fields
}

type ChannelHandler func(cxt context.Context, rpcCtx RpcServerContext)

type ClientOption struct {
	ConnectType ConnectType
	OpenTSL     bool
}

type ClientOptions func(opt *ClientOption)

type ConnectEvent struct {
	EventType ConnectEventType
	Conn      net.Conn
}

type ConnectEventListener func(eventType ConnectEventType, con net.Conn)

type ConnectEventType int8

type ConnectType string

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

type Dispatcher struct {
	Label string
	// contains filtered or unexported fields
}

type Endpoint struct {
	Key  string
	Host string
	Port int32
	// contains filtered or unexported fields
}

type EndpointRepository interface {
	//SelectOne 选择一个服务的实例进行随机访问
	SelectOne(name string) (bool, Endpoint)
	//Put 为某个服务添加一个服务实例
	Put(name string, endpoint Endpoint)
	//Remove 从某个服务中移除实例
	Remove(name string, endpoint Endpoint)
}

type ProxyConn struct {
	Target  net.Conn
	OnClose func(conn net.Conn)
}

type RpcClientContext interface {
	io.Closer

	Send(resp *ServerRequest)

	Receive() (<-chan *ServerResponse, <-chan error)
}

type RpcServerContext interface {
	io.Closer

	GetReq() *ServerRequest

	Send(resp *ServerResponse) error
}

type ServerOption struct {
	ConnectType ConnectType
	Label       string
	Port        int32
	OpenTSL     bool
}

type ServerOptions func(opt *ServerOption)

type ServerRequest struct {
	FunName   string            `protobuf:"bytes,1,opt,name=FunName,proto3" json:"FunName,omitempty"`
	Body      *anypb.Any        `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	RequestId string            `protobuf:"bytes,3,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Header    map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ServerResponse struct {
	FunName   string            `protobuf:"bytes,1,opt,name=FunName,proto3" json:"FunName,omitempty"`
	RequestId string            `protobuf:"bytes,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Header    map[string]string `` /* 153-byte string literal not displayed */
	Code      int32             `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	Body      *anypb.Any        `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	Msg       string            `protobuf:"bytes,6,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

type SimpleHandler func(cxt context.Context, rpcCtx RpcServerContext)

type TransportClient interface {
	//RegisterConnectEventWatcher 客户端监听和服务端的会话的状态
	RegisterConnectEventWatcher(watcher func(eventType ConnectEventType, conn net.Conn))
	//CheckConnection 检查链接
	CheckConnection(endpoint Endpoint) (bool, error)
	//AddChain 添加请求处理链
	AddChain(filter func(req *ServerRequest))
	//Request 发起 request-response 请求
	Request(ctx context.Context, endpoint Endpoint, req *ServerRequest) (*ServerResponse, error)
	//RequestChannel 发起 request-channel 请求
	RequestChannel(ctx context.Context, endpoint Endpoint) (RpcClientContext, error)
	//Close 关闭客户端
	Close() error
}

type TransportServer interface {
	//AddConnectEventListener 服务端的监听和客户端的会话的状态
	AddConnectEventListener(listener ConnectEventListener)
	//RemoveConnectEventListener
	RemoveConnectEventListener(listener ConnectEventListener)
	//RegisterSimpleHandler 注册一个 Request-Response的Server端处理者，名称为name
	RegisterSimpleHandler(funName string, handler SimpleHandler)
	//RegisterChannelHandler 注册一个 Request-Channel的Server端处理者，名称为name
	RegisterChannelHandler(funName string, handler ChannelHandler)
}

type UserCall func(resp *ServerResponse, err error)