pb

type ChatMessage struct {
	From   string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`                    // 发送者 ID/昵称
	Text   string `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`                    // 文本内容
	Seq    int64  `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`                     // 自增序号（客户端或服务端维护均可）
	TsUnix int64  `protobuf:"varint,4,opt,name=ts_unix,json=tsUnix,proto3" json:"ts_unix,omitempty"` // 发送时间
	// contains filtered or unexported fields
}

type CountDownReply struct {
	Current int32 `protobuf:"varint,1,opt,name=current,proto3" json:"current,omitempty"` // 当前数字
	TsUnix  int64 `protobuf:"varint,2,opt,name=ts_unix,json=tsUnix,proto3" json:"ts_unix,omitempty"`
	// contains filtered or unexported fields
}

type CountDownRequest struct {
	From       int32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`                               // 例如 from=5 -> 5,4,3,2,1
	IntervalMs int32 `protobuf:"varint,2,opt,name=interval_ms,json=intervalMs,proto3" json:"interval_ms,omitempty"` // 两次下发间隔，默认可由服务端设定
	// contains filtered or unexported fields
}

type DemoClient interface {
	// 1) Unary：最基础的请求-响应
	SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloReply, error)
	// 2) Server streaming：服务端流式把倒计时发回去
	CountDown(ctx context.Context, in *CountDownRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[CountDownReply], error)
	// 3) Client streaming：客户端连续发数字，服务端汇总
	Sum(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[SumRequest, SumReply], error)
	// 4) Bidirectional streaming：简易聊天室
	Chat(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ChatMessage, ChatMessage], error)
	// 5) 简易健康检查（避免额外引入官方 health proto）
	Health(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

type DemoServer interface {
	// 1) Unary：最基础的请求-响应
	SayHello(context.Context, *HelloRequest) (*HelloReply, error)
	// 2) Server streaming：服务端流式把倒计时发回去
	CountDown(*CountDownRequest, grpc.ServerStreamingServer[CountDownReply]) error
	// 3) Client streaming：客户端连续发数字，服务端汇总
	Sum(grpc.ClientStreamingServer[SumRequest, SumReply]) error
	// 4) Bidirectional streaming：简易聊天室
	Chat(grpc.BidiStreamingServer[ChatMessage, ChatMessage]) error
	// 5) 简易健康检查（避免额外引入官方 health proto）
	Health(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// contains filtered or unexported methods
}

type Demo_ChatClient = grpc.BidiStreamingClient[ChatMessage, ChatMessage]

type Demo_ChatServer = grpc.BidiStreamingServer[ChatMessage, ChatMessage]

type Demo_CountDownClient = grpc.ServerStreamingClient[CountDownReply]

type Demo_CountDownServer = grpc.ServerStreamingServer[CountDownReply]

type Demo_SumClient = grpc.ClientStreamingClient[SumRequest, SumReply]

type Demo_SumServer = grpc.ClientStreamingServer[SumRequest, SumReply]

type HealthCheckRequest struct {
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` // 可传具体服务名，空表示默认
	// contains filtered or unexported fields
}

type HealthCheckResponse struct {
	Status HealthCheckResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=test.HealthCheckResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type HealthCheckResponse_Status int32

type HelloReply struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	TsUnix  int64  `protobuf:"varint,2,opt,name=ts_unix,json=tsUnix,proto3" json:"ts_unix,omitempty"` // 服务器时间戳
	// contains filtered or unexported fields
}

type HelloRequest struct {
	Name string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // 测试字符串
	Meta map[string]string ``                                                              // 测试 map
	/* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SumReply struct {
	Total int64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` // 服务器汇总总和
	Count int32 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` // 接收了多少个包
	// contains filtered or unexported fields
}

type SumRequest struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // 客户端不断发送的数字
	// contains filtered or unexported fields
}

type UnimplementedDemoServer struct{}

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