netinsert

package

v0.7.1 Latest Latest Go to latest Published: Jan 24, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Details

View Source

const ProtocolVersion = "v1"

ProtocolVersion is the version of the data ingestion protocol.

It must be changed every time the data encoding at /internal/insert HTTP endpoint is changed.

This section is empty.

This section is empty.

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

Storage is a network storage for sending data to remote storage nodes in the cluster.

func NewStorage(addrs []string, authCfgs []*promauth.Config, isTLSs []bool, concurrency int, disableCompression bool) *Storage

NewStorage returns new Storage for the given addrs with the given authCfgs.

The concurrency is the average number of concurrent connections per every addr.

If disableCompression is set, then the data is sent uncompressed to the remote storage.

Call MustStop on the returned storage when it is no longer needed.

func (s *Storage) AddRow(streamHash uint64, r *logstorage.InsertRow)

AddRow adds the given log row into s.

func (s *Storage) MustStop()

MustStop stops the s.