pb

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

type BindRequest struct {
	CID int64 `protobuf:"varint,1,opt,name=CID,proto3" json:"CID,omitempty"` // 连接ID
	UID int64 `protobuf:"varint,2,opt,name=UID,proto3" json:"UID,omitempty"` // 用户ID
	// contains filtered or unexported fields
}

type BroadcastReply struct {
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"Total,omitempty"` // 广播数量
	// contains filtered or unexported fields
}

type BroadcastRequest struct {
	NID    string `protobuf:"bytes,1,opt,name=NID,proto3" json:"NID,omitempty"`       // 节点ID
	Kind   int32  `protobuf:"varint,2,opt,name=Kind,proto3" json:"Kind,omitempty"`    // 推送类型 1：CID 2：UID
	Route  int32  `protobuf:"varint,3,opt,name=Route,proto3" json:"Route,omitempty"`  // 路由
	Buffer []byte `protobuf:"bytes,4,opt,name=Buffer,proto3" json:"Buffer,omitempty"` // 消息内容
	// contains filtered or unexported fields
}

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

type DeliverRequest struct {
	GID    string `protobuf:"bytes,1,opt,name=GID,proto3" json:"GID,omitempty"`       // 网关ID
	NID    string `protobuf:"bytes,2,opt,name=NID,proto3" json:"NID,omitempty"`       // 节点ID
	CID    int64  `protobuf:"varint,3,opt,name=CID,proto3" json:"CID,omitempty"`      // 连接ID
	UID    int64  `protobuf:"varint,4,opt,name=UID,proto3" json:"UID,omitempty"`      // 用户ID
	Route  int32  `protobuf:"varint,5,opt,name=Route,proto3" json:"Route,omitempty"`  // 路由ID
	Buffer []byte `protobuf:"bytes,6,opt,name=Buffer,proto3" json:"Buffer,omitempty"` // 消息内容
	// contains filtered or unexported fields
}

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

type DisconnectRequest struct {
	NID     string `protobuf:"bytes,1,opt,name=NID,proto3" json:"NID,omitempty"`          // 节点ID
	Kind    int32  `protobuf:"varint,2,opt,name=Kind,proto3" json:"Kind,omitempty"`       // 推送类型 1：CID 2：UID
	Target  int64  `protobuf:"varint,3,opt,name=Target,proto3" json:"Target,omitempty"`   // 推送目标
	IsForce bool   `protobuf:"varint,4,opt,name=IsForce,proto3" json:"IsForce,omitempty"` // 是否强制断开连接
	// contains filtered or unexported fields
}

type GateClient interface {
	// 绑定用户与连接
	Bind(ctx context.Context, in *BindRequest, opts ...grpc.CallOption) (*BindReply, error)
	// 解绑用户与连接
	Unbind(ctx context.Context, in *UnbindRequest, opts ...grpc.CallOption) (*UnbindReply, error)
	// 获取客户端IP
	GetIP(ctx context.Context, in *GetIPRequest, opts ...grpc.CallOption) (*GetIPReply, error)
	// 断开连接
	Disconnect(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectReply, error)
	// 推送消息
	Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushReply, error)
	// 推送组播消息
	Multicast(ctx context.Context, in *MulticastRequest, opts ...grpc.CallOption) (*MulticastReply, error)
	// 推送广播消息
	Broadcast(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (*BroadcastReply, error)
}

type GateServer interface {
	// 绑定用户与连接
	Bind(context.Context, *BindRequest) (*BindReply, error)
	// 解绑用户与连接
	Unbind(context.Context, *UnbindRequest) (*UnbindReply, error)
	// 获取客户端IP
	GetIP(context.Context, *GetIPRequest) (*GetIPReply, error)
	// 断开连接
	Disconnect(context.Context, *DisconnectRequest) (*DisconnectReply, error)
	// 推送消息
	Push(context.Context, *PushRequest) (*PushReply, error)
	// 推送组播消息
	Multicast(context.Context, *MulticastRequest) (*MulticastReply, error)
	// 推送广播消息
	Broadcast(context.Context, *BroadcastRequest) (*BroadcastReply, error)
	// contains filtered or unexported methods
}

type GetIPReply struct {
	IP string `protobuf:"bytes,1,opt,name=IP,proto3" json:"IP,omitempty"` // IP地址
	// contains filtered or unexported fields
}

type GetIPRequest struct {
	NID    string `protobuf:"bytes,1,opt,name=NID,proto3" json:"NID,omitempty"`        // 节点ID
	Kind   int32  `protobuf:"varint,2,opt,name=Kind,proto3" json:"Kind,omitempty"`     // 推送类型 1：CID 2：UID
	Target int64  `protobuf:"varint,3,opt,name=Target,proto3" json:"Target,omitempty"` // 推送目标
	// contains filtered or unexported fields
}

type MulticastReply struct {
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"Total,omitempty"` // 组播数量
	// contains filtered or unexported fields
}

type MulticastRequest struct {
	NID     string  `protobuf:"bytes,1,opt,name=NID,proto3" json:"NID,omitempty"`                 // 节点ID
	Kind    int32   `protobuf:"varint,2,opt,name=Kind,proto3" json:"Kind,omitempty"`              // 推送类型 1：CID 2：UID
	Targets []int64 `protobuf:"varint,3,rep,packed,name=Targets,proto3" json:"Targets,omitempty"` // 推送目标
	Route   int32   `protobuf:"varint,4,opt,name=Route,proto3" json:"Route,omitempty"`            // 路由
	Buffer  []byte  `protobuf:"bytes,5,opt,name=Buffer,proto3" json:"Buffer,omitempty"`           // 消息内容
	// contains filtered or unexported fields
}

type NodeClient interface {
	// 触发事件
	Trigger(ctx context.Context, in *TriggerRequest, opts ...grpc.CallOption) (*TriggerReply, error)
	// 投递消息
	Deliver(ctx context.Context, in *DeliverRequest, opts ...grpc.CallOption) (*DeliverReply, error)
}

type NodeServer interface {
	// 触发事件
	Trigger(context.Context, *TriggerRequest) (*TriggerReply, error)
	// 投递消息
	Deliver(context.Context, *DeliverRequest) (*DeliverReply, error)
	// contains filtered or unexported methods
}

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

type PushRequest struct {
	NID    string `protobuf:"bytes,1,opt,name=NID,proto3" json:"NID,omitempty"`        // 节点ID
	Kind   int32  `protobuf:"varint,2,opt,name=Kind,proto3" json:"Kind,omitempty"`     // 推送类型 1：CID 2：UID
	Target int64  `protobuf:"varint,3,opt,name=Target,proto3" json:"Target,omitempty"` // 推送目标
	Route  int32  `protobuf:"varint,4,opt,name=Route,proto3" json:"Route,omitempty"`   // 路由
	Buffer []byte `protobuf:"bytes,5,opt,name=Buffer,proto3" json:"Buffer,omitempty"`  // 消息内容
	// contains filtered or unexported fields
}

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

type TriggerRequest struct {
	Event int32  `protobuf:"varint,1,opt,name=Event,proto3" json:"Event,omitempty"` // 事件
	GID   string `protobuf:"bytes,2,opt,name=GID,proto3" json:"GID,omitempty"`      // 网关ID
	UID   int64  `protobuf:"varint,3,opt,name=UID,proto3" json:"UID,omitempty"`     // 用户ID
	// contains filtered or unexported fields
}

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

type UnbindRequest struct {
	UID int64 `protobuf:"varint,1,opt,name=UID,proto3" json:"UID,omitempty"` // 用户ID
	// contains filtered or unexported fields
}

type UnimplementedGateServer struct {
}

type UnimplementedNodeServer struct {
}

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

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