rumour

type ClusterConfig struct {
	Name          string        `ignored:"true"`
	Brokers       []string      `required:"true"`
	MetaRefresh   time.Duration `default:"180s"`
	OffsetRefresh time.Duration `default:"30s"`
}

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

type ConsumerOffset struct {
	Offset int64 `json:"offset"`
	Lag    int64 `json:"lag"`
}

type ConsumerTopic struct {
	Topic     string           `json:"topic"`
	Timestamp int64            `json:"timestamp"`
	Offsets   []ConsumerOffset `json:"offsets"`
}

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

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