hub

type Conf struct {
	Ingest     IngestConf `yaml:"ingest" conf:",ignore"`
	local.Conf `yaml:",inline"`
}

type ErrIngestBackoff struct {
	Backoff time.Duration
	// contains filtered or unexported fields
}

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

type IngestConf struct {
	// Credentials holds bundle source credentials.
	Credentials *hub.CredentialsConf `yaml:"credentials" conf:",ignore"`
	// Connection defines settings for the remote server connection.
	Connection *hub.ConnectionConf `yaml:"connection" conf:",ignore"`
	// MaxBatchSize defines the max number of log entries to send in each Ingest request.
	MaxBatchSize uint `yaml:"maxBatchSize" conf:",example=32"`
	// MinFlushInterval is the minimal duration between Ingest requests.
	MinFlushInterval time.Duration `yaml:"minFlushInterval" conf:",example=3s"`
	// FlushTimeout defines the max allowable timeout for each Ingest request.
	FlushTimeout time.Duration `yaml:"flushTimeout" conf:",example=5s"`
	// NumGoRoutines defines the max number of goroutines used when streaming log entries from the local DB.
	NumGoRoutines uint `yaml:"numGoRoutines" conf:",example=8"`
}

type IngestSyncer interface {
	Sync(context.Context, *logsv1.IngestBatch) error
}

type Log struct {
	*local.Log
}