hallpb

type CallMessageRequest struct {
	UserId string `protobuf:"bytes,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	Method string `protobuf:"bytes,2,opt,name=Method,proto3" json:"Method,omitempty"`
	Data   []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

type CallMessageResponse struct {
	UserId string `protobuf:"bytes,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	Method string `protobuf:"bytes,2,opt,name=Method,proto3" json:"Method,omitempty"`
	Data   []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

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

type ClientMessageRequest struct {
	MemberId  string `protobuf:"bytes,1,opt,name=MemberId,proto3" json:"MemberId,omitempty"`
	SessionId uint64 `protobuf:"varint,2,opt,name=SessionId,proto3" json:"SessionId,omitempty"`
	ReqId     uint64 `protobuf:"varint,3,opt,name=ReqId,proto3" json:"ReqId,omitempty"`
	Data      []byte `protobuf:"bytes,4,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

type ClientMessageResponse struct {
	Type      PacketType `protobuf:"varint,1,opt,name=Type,proto3,enum=hallpb.PacketType" json:"Type,omitempty"`
	SessionId uint64     `protobuf:"varint,2,opt,name=SessionId,proto3" json:"SessionId,omitempty"`
	ReqId     uint64     `protobuf:"varint,3,opt,name=ReqId,proto3" json:"ReqId,omitempty"`
	Data      []byte     `protobuf:"bytes,4,opt,name=Data,proto3" json:"Data,omitempty"`
	Route     string     `protobuf:"bytes,5,opt,name=Route,proto3" json:"Route,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

type HallClient interface {
	// client消息流
	ClientStream(ctx context.Context, opts ...grpc.CallOption) (Hall_ClientStreamClient, error)
	// 网关消息流
	GateStream(ctx context.Context, opts ...grpc.CallOption) (Hall_GateStreamClient, error)
	// 状态
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	// 心跳
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// rpc PushStream (stream PushStreamNotify) returns (PushStreamPush) {}
	MustPush(ctx context.Context, in *MustPushRequest, opts ...grpc.CallOption) (*MustPushResponse, error)
	// 发送消息
	SendMessage(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*SendMessageResponse, error)
	// 发送消息
	CallMessage(ctx context.Context, in *CallMessageRequest, opts ...grpc.CallOption) (*CallMessageResponse, error)
	// 顶号下线
	UserInstead(ctx context.Context, in *UserInsteadRequest, opts ...grpc.CallOption) (*UserInsteadResponse, error)
	// 踢人下线
	Kick(ctx context.Context, in *KickRequest, opts ...grpc.CallOption) (*KickResponse, error)
}

type HallClients interface {
	WithServiceName(serviceName string) HallClients
	// 发送到一个节点
	Unicast() HallClientsUnicast
	Multicast(count int) HallClientsMulticast
	// 广播给所有节点
	Broadcast() HallClientsMulticast

	// client消息流
	ClientStream(ctx context.Context, address string, opts ...grpc.CallOption) (Hall_ClientStreamClient, error)
	// 网关消息流
	GateStream(ctx context.Context, address string, opts ...grpc.CallOption) (Hall_GateStreamClient, error)
	// 状态
	Info(ctx context.Context, address string, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	// 心跳
	HealthCheck(ctx context.Context, address string, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// rpc PushStream (stream PushStreamNotify) returns (PushStreamPush) {}
	MustPush(ctx context.Context, address string, in *MustPushRequest, opts ...grpc.CallOption) (*MustPushResponse, error)
	// 发送消息
	SendMessage(ctx context.Context, address string, in *SendMessageRequest, opts ...grpc.CallOption) (*SendMessageResponse, error)
	// 发送消息
	CallMessage(ctx context.Context, address string, in *CallMessageRequest, opts ...grpc.CallOption) (*CallMessageResponse, error)
	// 顶号下线
	UserInstead(ctx context.Context, address string, in *UserInsteadRequest, opts ...grpc.CallOption) (*UserInsteadResponse, error)
	// 踢人下线
	Kick(ctx context.Context, address string, in *KickRequest, opts ...grpc.CallOption) (*KickResponse, error)
}

type HallClientsMulticast interface {
	WhereRegex(regex string) HallClientsMulticast
	WherePrefix(prefix bool) HallClientsMulticast
	Local() HallClientsMulticast
	// client消息流
	ClientStream(ctx context.Context, opts ...grpc.CallOption) (*Hall_ClientStreamClient_MulticastResult, error)
	// 网关消息流
	GateStream(ctx context.Context, opts ...grpc.CallOption) (*Hall_GateStreamClient_MulticastResult, error)
	// 状态
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse_MulticastResult, error)
	// 心跳
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse_MulticastResult, error)
	// rpc PushStream (stream PushStreamNotify) returns (PushStreamPush) {}
	MustPush(ctx context.Context, in *MustPushRequest, opts ...grpc.CallOption) (*MustPushResponse_MulticastResult, error)
	// 发送消息
	SendMessage(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*SendMessageResponse_MulticastResult, error)
	// 发送消息
	CallMessage(ctx context.Context, in *CallMessageRequest, opts ...grpc.CallOption) (*CallMessageResponse_MulticastResult, error)
	// 顶号下线
	UserInstead(ctx context.Context, in *UserInsteadRequest, opts ...grpc.CallOption) (*UserInsteadResponse_MulticastResult, error)
	// 踢人下线
	Kick(ctx context.Context, in *KickRequest, opts ...grpc.CallOption) (*KickResponse_MulticastResult, error)
}

type HallClientsUnicast interface {
	Where(serviceName string) HallClientsUnicast
	WherePeer(peer *gira.Peer) HallClientsUnicast
	WherePeerFullName(appFullName string) HallClientsUnicast
	WhereAddress(address string) HallClientsUnicast
	WhereUser(userId string) HallClientsUnicast
	Local() HallClientsUnicast

	// client消息流
	ClientStream(ctx context.Context, opts ...grpc.CallOption) (Hall_ClientStreamClient, error)
	// 网关消息流
	GateStream(ctx context.Context, opts ...grpc.CallOption) (Hall_GateStreamClient, error)
	// 状态
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	// 心跳
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// rpc PushStream (stream PushStreamNotify) returns (PushStreamPush) {}
	MustPush(ctx context.Context, in *MustPushRequest, opts ...grpc.CallOption) (*MustPushResponse, error)
	// 发送消息
	SendMessage(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*SendMessageResponse, error)
	// 发送消息
	CallMessage(ctx context.Context, in *CallMessageRequest, opts ...grpc.CallOption) (*CallMessageResponse, error)
	// 顶号下线
	UserInstead(ctx context.Context, in *UserInsteadRequest, opts ...grpc.CallOption) (*UserInsteadResponse, error)
	// 踢人下线
	Kick(ctx context.Context, in *KickRequest, opts ...grpc.CallOption) (*KickResponse, error)
}

type HallServer interface {
	// client消息流
	ClientStream(Hall_ClientStreamServer) error
	// 网关消息流
	GateStream(Hall_GateStreamServer) error
	// 状态
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	// 心跳
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// rpc PushStream (stream PushStreamNotify) returns (PushStreamPush) {}
	MustPush(context.Context, *MustPushRequest) (*MustPushResponse, error)
	// 发送消息
	SendMessage(context.Context, *SendMessageRequest) (*SendMessageResponse, error)
	// 发送消息
	CallMessage(context.Context, *CallMessageRequest) (*CallMessageResponse, error)
	// 顶号下线
	UserInstead(context.Context, *UserInsteadRequest) (*UserInsteadResponse, error)
	// 踢人下线
	Kick(context.Context, *KickRequest) (*KickResponse, error)
	// contains filtered or unexported methods
}

type HallStatus int32

type Hall_ClientStreamClient interface {
	Send(*ClientMessageRequest) error
	Recv() (*ClientMessageResponse, error)
	grpc.ClientStream
}

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

type Hall_ClientStreamServer interface {
	Send(*ClientMessageResponse) error
	Recv() (*ClientMessageRequest, error)
	grpc.ServerStream
}

type Hall_GateStreamClient interface {
	Send(*GateStreamRequest) error
	Recv() (*GateStreamResponse, error)
	grpc.ClientStream
}

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

type Hall_GateStreamServer interface {
	Send(*GateStreamResponse) error
	Recv() (*GateStreamRequest, error)
	grpc.ServerStream
}

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

type HealthCheckResponse struct {
	PlayerCount int64      `protobuf:"varint,1,opt,name=PlayerCount,proto3" json:"PlayerCount,omitempty"`
	Status      HallStatus `protobuf:"varint,2,opt,name=Status,proto3,enum=hallpb.HallStatus" json:"Status,omitempty"`
	// contains filtered or unexported fields
}

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

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

type InfoResponse struct {
	BuildTime  int64  `protobuf:"varint,1,opt,name=BuildTime,proto3" json:"BuildTime,omitempty"`
	AppVersion string `protobuf:"bytes,2,opt,name=AppVersion,proto3" json:"AppVersion,omitempty"`
	// 在线人数
	SessionCount int64 `protobuf:"varint,3,opt,name=SessionCount,proto3" json:"SessionCount,omitempty"`
	// contains filtered or unexported fields
}

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

type KickRequest struct {
	UserId string `protobuf:"bytes,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=Reason,proto3" json:"Reason,omitempty"`
	// contains filtered or unexported fields
}

type KickResponse struct {
	ErrorCode int32  `protobuf:"varint,1,opt,name=ErrorCode,proto3" json:"ErrorCode,omitempty"`
	ErrorMsg  string `protobuf:"bytes,2,opt,name=ErrorMsg,proto3" json:"ErrorMsg,omitempty"`
	// contains filtered or unexported fields
}

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

type MustPushRequest struct {
	UserId string `protobuf:"bytes,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	Data   []byte `protobuf:"bytes,4,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

type MustPushResponse struct {
	ErrorCode int32  `protobuf:"varint,1,opt,name=ErrorCode,proto3" json:"ErrorCode,omitempty"`
	ErrorMsg  string `protobuf:"bytes,2,opt,name=ErrorMsg,proto3" json:"ErrorMsg,omitempty"`
	// contains filtered or unexported fields
}

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

type PacketType int32

type SendMessageRequest struct {
	UserId string `protobuf:"bytes,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	Method string `protobuf:"bytes,2,opt,name=Method,proto3" json:"Method,omitempty"`
	Data   []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

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

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

type UnimplementedHallServer struct {
}

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

type UserInsteadRequest struct {
	UserId  string `protobuf:"bytes,1,opt,name=UserId,proto3" json:"UserId,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
	// contains filtered or unexported fields
}

type UserInsteadResponse struct {
	ErrorCode int32  `protobuf:"varint,1,opt,name=ErrorCode,proto3" json:"ErrorCode,omitempty"`
	ErrorMsg  string `protobuf:"bytes,2,opt,name=ErrorMsg,proto3" json:"ErrorMsg,omitempty"`
	// contains filtered or unexported fields
}

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