shipper

Documentation

Overview

Package shipper detects directories on the local file system and uploads them to a block storage.

Index

• Constants
• func WriteMetaFile(logger log.Logger, dir string, meta *Meta) error
• type Meta
  • func ReadMetaFile(dir string) (*Meta, error)
• type Shipper
  • func New(logger log.Logger, r prometheus.Registerer, dir string, bucket objstore.Bucket, ...) *Shipper
  • func NewWithCompacted(ctx context.Context, logger log.Logger, r prometheus.Registerer, dir string, ...) (*Shipper, error)
  • func (s *Shipper) Sync(ctx context.Context) (uploaded int, err error)
  • func (s *Shipper) Timestamps() (minTime, maxSyncTime int64, err error)

Constants

const MetaFilename = "thanos.shipper.json"

MetaFilename is the known JSON filename for meta information.

Functions

func WriteMetaFile

func WriteMetaFile(logger log.Logger, dir string, meta *Meta) error

WriteMetaFile writes the given meta into <dir>/thanos.shipper.json.

Types

type Meta

type Meta struct {
	Version  int         `json:"version"`
	Uploaded []ulid.ULID `json:"uploaded"`
}

Meta defines the fomart thanos.shipper.json file that the shipper places in the data directory.

func ReadMetaFile

func ReadMetaFile(dir string) (*Meta, error)

ReadMetaFile reads the given meta from <dir>/thanos.shipper.json.

type Shipper

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

Shipper watches a directory for matching files and directories and uploads them to a remote data store.

func New

func New(
	logger log.Logger,
	r prometheus.Registerer,
	dir string,
	bucket objstore.Bucket,
	lbls func() labels.Labels,
	source metadata.SourceType,
) *Shipper

New creates a new shipper that detects new TSDB blocks in dir and uploads them to remote if necessary. It attaches the Thanos metadata section in each meta JSON file.

func NewWithCompacted

func NewWithCompacted(
	ctx context.Context,
	logger log.Logger,
	r prometheus.Registerer,
	dir string,
	bucket objstore.Bucket,
	lbls func() labels.Labels,
	source metadata.SourceType,
	prometheusURL *url.URL,
) (*Shipper, error)

NewWithCompacted creates a new shipper that detects new TSDB blocks in dir and uploads them to remote if necessary, including compacted blocks which are already in filesystem. It attaches the Thanos metadata section in each meta JSON file.

func (*Shipper) Sync

func (s *Shipper) Sync(ctx context.Context) (uploaded int, err error)

Sync performs a single synchronization, which ensures all non-compacted local blocks have been uploaded to the object bucket once.

If updload

It is not concurrency-safe, however it is compactor-safe (running concurrently with compactor is ok)

func (*Shipper) Timestamps

func (s *Shipper) Timestamps() (minTime, maxSyncTime int64, err error)

Timestamps returns the minimum timestamp for which data is available and the highest timestamp of blocks that were successfully uploaded.