boatpb

type BoardcastRoomRequest struct {
	// 房间名称
	Room string `protobuf:"bytes,1,opt,name=room" json:"room,omitempty"`
	// 消息唯一标识
	Seq string `protobuf:"bytes,2,opt,name=seq" json:"seq,omitempty"`
	// 消息体
	Body *google_protobuf.Any `protobuf:"bytes,3,opt,name=body" json:"body,omitempty"`
}

type BoatClient interface {
	// 向某一个会话id下发消息一堆消息
	PushMessages(ctx context.Context, in *PushMessagesRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// 广播消息
	BoardcastRoom(ctx context.Context, in *BoardcastRoomRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
	// 踢出会话
	Kickout(ctx context.Context, in *KickoutRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
}

type BoatServer interface {
	// 向某一个会话id下发消息一堆消息
	PushMessages(context.Context, *PushMessagesRequest) (*google_protobuf1.Empty, error)
	// 广播消息
	BoardcastRoom(context.Context, *BoardcastRoomRequest) (*google_protobuf1.Empty, error)
	// 踢出会话
	Kickout(context.Context, *KickoutRequest) (*google_protobuf1.Empty, error)
}

type KickoutRequest struct {
	// 会话id
	Sid string `protobuf:"bytes,1,opt,name=sid" json:"sid,omitempty"`
	// 踢出原因
	Code errorpb.Code `protobuf:"varint,2,opt,name=code,enum=errorpb.Code" json:"code,omitempty"`
}

type PushMessagesRequest struct {
	// 会话id
	Sid string `protobuf:"bytes,1,opt,name=sid" json:"sid,omitempty"`
	// ack等待时间
	AckWait *google_protobuf2.Duration `protobuf:"bytes,2,opt,name=ack_wait,json=ackWait" json:"ack_wait,omitempty"`
	// 一堆消息
	Msgs []*msgpb.Message `protobuf:"bytes,3,rep,name=msgs" json:"msgs,omitempty"`
}