rest

type MessagesLastMinute struct {
	Topic          string `json:"topic"`
	ProducedCount  int64  `json:"produced_count"`
	ConsumedCount  int64  `json:"consumed_count"`
	ProducedPerSec int64  `json:"produced_per_sec"`
	ConsumedPerSec int64  `json:"consumed_per_sec"`
}

type OffsetHistoryEntry struct {
	Offset    int64
	Timestamp time.Time
}

type Response struct {
	Status  string      `json:"status"`
	Message string      `json:"message,omitempty"`
	Data    interface{} `json:"data,omitempty"`
}

type Server struct {
	// contains filtered or unexported fields
}

type TopicRequest struct {
	Name              string `json:"name"`
	Partitions        int32  `json:"partitions"`
	ReplicationFactor int16  `json:"replication_factor"`
}