api

type Fields struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type LogLevel int32

type LogRequest struct {
	Level     LogLevel  `protobuf:"varint,1,opt,name=level,proto3,enum=lmoudle.LogLevel" json:"level,omitempty"` // 日志级别
	Message   string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                    // 日志消息
	Service   string    `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`                    // 服务名称
	Timestamp int64     `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`               // 时间戳
	Fields    []*Fields `protobuf:"bytes,5,rep,name=fields,proto3" json:"fields,omitempty"`                      // 结构化字段
	Tags      []string  `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`                          // 标签
	// contains filtered or unexported fields
}

type LogServiceClient interface {
	// 记录日志
	Log(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*Response, error)
	// 批量记录日志
	BatchLog(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[LogRequest, Response], error)
}

type LogServiceServer interface {
	// 记录日志
	Log(context.Context, *LogRequest) (*Response, error)
	// 批量记录日志
	BatchLog(grpc.ClientStreamingServer[LogRequest, Response]) error
	// contains filtered or unexported methods
}

type LogService_BatchLogClient = grpc.ClientStreamingClient[LogRequest, Response]

type LogService_BatchLogServer = grpc.ClientStreamingServer[LogRequest, Response]

type MessageRequest struct {
	Content   string `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`      // 消息内容
	Sender    string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`        // 发送者
	Receiver  string `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"`    // 接收者
	Timestamp int64  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // 时间戳
	// contains filtered or unexported fields
}

type MessageServiceClient interface {
	// 发送消息
	SendMessage(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*Response, error)
	// 批量发送消息
	BatchSendMessage(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[MessageRequest, Response], error)
}

type MessageServiceServer interface {
	// 发送消息
	SendMessage(context.Context, *MessageRequest) (*Response, error)
	// 批量发送消息
	BatchSendMessage(grpc.ClientStreamingServer[MessageRequest, Response]) error
	// contains filtered or unexported methods
}

type MessageService_BatchSendMessageClient = grpc.ClientStreamingClient[MessageRequest, Response]

type MessageService_BatchSendMessageServer = grpc.ClientStreamingServer[MessageRequest, Response]

type Response struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // 是否成功
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`  // 响应消息
	Code    int32  `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`       // 响应码
	// contains filtered or unexported fields
}

type UnimplementedLogServiceServer struct{}

type UnimplementedMessageServiceServer struct{}

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

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