subscriber

type BalanceMode int

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

	HTTPTimeout toml.Duration `toml:"http-timeout"`

	// InsecureSkipVerify gets passed to the http client, if true, it will
	// skip https certificate verification. Defaults to false
	InsecureSkipVerify bool `toml:"insecure-skip-verify"`

	// configure the path to the PEM encoded CA certs file. If the
	// empty string, the default system certs will be used
	CaCerts string `toml:"ca-certs"`

	// RootCA configures the CA pool used to verify subscription endpoint server
	// certificates. It is combined with the legacy CaCerts (ca-certs) setting,
	// which continues to work on its own for backwards compatibility.
	RootCA *tlsconfig.CAConfig `toml:"root-ca"`

	// Certificate and PrivateKey are the client certificate the subscriber
	// presents to HTTPS endpoints for mutual TLS. Empty means no client
	// certificate is presented.
	Certificate string `toml:"certificate"`
	PrivateKey  string `toml:"private-key"`

	// InsecureCertificate is true if the client certificate's file permissions
	// should be ignored when it is loaded.
	InsecureCertificate bool `toml:"insecure-certificate"`

	// IgnoreCertSanityChecks loads the certificate even when it fails the
	// checks that decide whether it can be used at all. The checks currently
	// only cover server certificates, so this has no effect on the subscriber's
	// client certificate today.
	IgnoreCertSanityChecks bool `toml:"ignore-cert-sanity-checks"`

	// The number of writer goroutines processing the write channel.
	WriteConcurrency int `toml:"write-concurrency"`

	// The number of in-flight writes buffered in the write channel.
	WriteBufferSize int `toml:"write-buffer-size"`

	// TotalBufferBytes is the total size in bytes allocated to buffering across all subscriptions.
	// Each named subscription will receive an even division of the total.
	TotalBufferBytes toml.SSize `toml:"total-buffer-bytes"`

	// TLS is a base tls config to use for https clients.
	TLS *tls.Config `toml:"-"`
}

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

type PointsWriter interface {
	WritePointsContext(ctx context.Context, request WriteRequest) (destination string, err error)
}

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

type Statistics struct {
	CreateFailures int64
	PointsWritten  int64
	WriteFailures  int64
}

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

type WriteRequest struct {
	Database        string
	RetentionPolicy string
	// contains filtered or unexported fields
}