pb

type Event struct {
	Name       string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                // 事件名称
	AggId      string                 `protobuf:"bytes,2,opt,name=agg_id,json=aggId,proto3" json:"agg_id,omitempty"`                 // 聚合ID
	AggName    string                 `protobuf:"bytes,3,opt,name=agg_name,json=aggName,proto3" json:"agg_name,omitempty"`           // 聚合名称
	AggVersion uint64                 `protobuf:"varint,4,opt,name=agg_version,json=aggVersion,proto3" json:"agg_version,omitempty"` // 聚合版本
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`     // 创建时间
	Uuid       string                 `protobuf:"bytes,6,opt,name=uuid,proto3" json:"uuid,omitempty"`                                // uuid
	Payload    *anypb.Any             `protobuf:"bytes,10,opt,name=payload,proto3" json:"payload,omitempty"`                         // 有效数据
	// contains filtered or unexported fields
}

type PublishRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Event *Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}