gateway

type Context struct {
	Writer  http.ResponseWriter
	Request *http.Request

	Param       map[string]string //传递参数
	IsWebsocket bool              //是否是ws请求
	ServiceId   string            //业务ID
	RemoteIp    string            //远程请求IP
	FullPath    string            //路径地址

	ServerType    string              //服务类型
	InstanceId    register.InstanceId //实例id
	ServerBase    *register.ServerBase
	ProxyInstance *ProxyInstance

	GrpcCtx      context.Context //rpc接口上下文
	MD           metadata.MD     //grpc 头部数据
	ServerStream grpc.ServerStream
	Conn         *grpc.ClientConn
	Error        error
	// contains filtered or unexported fields
}

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

type ForwardLogParam struct {
	Protocol     string //协议类型
	InstanceId   string //实例Id
	RemoteIp     string //远程ip
	RequestTime  int64  //响应时间
	ResponseTime int64
	RequestPath  string //请求地址
	// contains filtered or unexported fields
}

type HandlerFunc func(*Context)

type HandlersChain []HandlerFunc

type HttpProxyInstance struct {
	ReverseProxy *httputil.ReverseProxy //http服务反向代理
	Addr         *url.URL               //服务url
}

type Message struct {
	ServiceId string `protobuf:"bytes,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	SessionId string `protobuf:"bytes,2,opt,name=sessionId,proto3" json:"sessionId,omitempty"`
	UserId    string `protobuf:"bytes,3,opt,name=userId,proto3" json:"userId,omitempty"`
	Message   []byte `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type MessageReq struct {
	ServiceId  string `protobuf:"bytes,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	SessionId  string `protobuf:"bytes,2,opt,name=sessionId,proto3" json:"sessionId,omitempty"`
	UserId     string `protobuf:"bytes,3,opt,name=userId,proto3" json:"userId,omitempty"`
	Message    []byte `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	MethodName string `protobuf:"bytes,5,opt,name=methodName,proto3" json:"methodName,omitempty"`
	// contains filtered or unexported fields
}

type Options struct {
	RedisOption       *redis.Options //redis配置项
	GlobalTime        int            //注册中心全局健康检查间隔
	MemberPort        int            //注册中心集群本地实例端口号
	RequestFailResult string         //异常返回
	LogPath           string         //日志地址
}

type Proxy struct {
	RegisterCenter *register.RegisterCenter //服务注册中心

	UnimplementedWsServiceServer
	// contains filtered or unexported fields
}

type ProxyInstance struct {
	HttpTable     map[register.InstanceId]*HttpProxyInstance //http代理实例表
	HttpTableLock sync.RWMutex                               //http代理表读写锁
	GrpcTable     map[register.InstanceId]*grpc.ClientConn
	GrpcTableLock sync.RWMutex
	AtomicNum     uint64 //请求计数
	LoadType      int    //负载类型 0 轮训 1 故障转移
}

type SessionReq struct {
	ServiceId string `protobuf:"bytes,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	SessionId string `protobuf:"bytes,2,opt,name=sessionId,proto3" json:"sessionId,omitempty"`
	UserId    string `protobuf:"bytes,3,opt,name=userId,proto3" json:"userId,omitempty"`
	// contains filtered or unexported fields
}

type SessionRes struct {
	Exist bool `protobuf:"varint,1,opt,name=exist,proto3" json:"exist,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedWsServiceServer struct {
}

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

type WsServiceClient interface {
	//  会话是否存在
	ExistSession(ctx context.Context, in *SessionReq, opts ...grpc.CallOption) (*SessionRes, error)
	//  发送消息
	SendMessage(ctx context.Context, in *MessageReq, opts ...grpc.CallOption) (*Empty, error)
}

type WsServiceServer interface {
	//  会话是否存在
	ExistSession(context.Context, *SessionReq) (*SessionRes, error)
	//  发送消息
	SendMessage(context.Context, *MessageReq) (*Empty, error)
	// contains filtered or unexported methods
}