mirror of
https://github.com/hanzoai/o11y.git
synced 2026-10-30 14:56:15 +00:00
Shivanshu Raj ShrivastavaandGitHub
8a07a67636
* fix: use filterset Signed-off-by: Shivanshu Raj Shrivastava <[email protected]>
25 lines
600 B
Go
25 lines
600 B
Go
package kafka
|
|
|
|
const KafkaQueue = "kafka"
|
|
|
|
type MessagingQueue struct {
|
|
Start int64 `json:"start"`
|
|
End int64 `json:"end"`
|
|
EvalTime int64 `json:"eval_time,omitempty"`
|
|
Variables map[string]string `json:"variables,omitempty"`
|
|
}
|
|
|
|
type Clients struct {
|
|
Hash map[string]struct{}
|
|
ClientID []string
|
|
ServiceInstanceID []string
|
|
ServiceName []string
|
|
TopicName []string
|
|
}
|
|
|
|
type OnboardingResponse struct {
|
|
Attribute string `json:"attribute"`
|
|
Message string `json:"error_message"`
|
|
Status string `json:"status"`
|
|
}
|