subscriber

type BalanceMode int

type Config struct {
	// Whether to enable to Subscriber service
	Enabled bool `toml:"enabled"`
}

type PointsWriter interface {
	WritePoints(p *cluster.WritePointsRequest) error
}

type Service struct {
	MetaStore interface {
		Databases() ([]meta.DatabaseInfo, error)
		WaitForDataChanged() error
	}
	NewPointsWriter func(u url.URL) (PointsWriter, error)
	Logger          *log.Logger
	// contains filtered or unexported fields
}

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