receive

Documentation

Index

• Constants
• func GetIngesterLabels(opts IngesterOptions) map[string]string
• func GetRequiredIngesterLabels() map[string]string
• func GetRequiredLabels() map[string]string
• func GetRequiredRouterLabels() map[string]string
• func GetRouterLabels(opts RouterOptions) map[string]string
• func NewIngestorService(opts IngesterOptions) *corev1.Service
• func NewIngestorStatefulSet(opts IngesterOptions) *appsv1.StatefulSet
• func NewRouterDeployment(opts RouterOptions) *appsv1.Deployment
• func NewRouterService(opts RouterOptions) *corev1.Service
• type IngesterOptions
  • func (opts IngesterOptions) Build() []client.Object
  • func (opts IngesterOptions) GetGeneratedResourceName() string
  • func (opts IngesterOptions) GetSelectorLabels() map[string]string
• type RouterOptions
  • func (opts RouterOptions) Build() []client.Object
  • func (opts RouterOptions) GetGeneratedResourceName() string
  • func (opts RouterOptions) GetSelectorLabels() map[string]string
• type TSDBOpts

Constants

const (
	// Name is the name of the Thanos Receive component.
	Name = "thanos-receive"

	// RouterComponentName is the name of the Thanos Receive router component.
	RouterComponentName = "thanos-receive-router"
	// IngestComponentName is the name of the Thanos Receive ingester component.
	IngestComponentName = "thanos-receive-ingester"

	// HTTPPortName is the name of the HTTP port for the Thanos Receive components.
	HTTPPortName = "http"
	// HTTPPort is the port number for the HTTP port for the Thanos Receive components.
	HTTPPort = 10902
	// GRPCPortName is the name of the gRPC port for the Thanos Receive components.
	GRPCPortName = "grpc"
	// GRPCPort is the port number for the gRPC port for the Thanos Receive components.
	GRPCPort = 10901
	// RemoteWritePortName is the name of the remote write port for the Thanos Receive components.
	RemoteWritePortName = "remote-write"
	// RemoteWritePort is the port number for the remote write port for the Thanos Receive components.
	RemoteWritePort = 19291

	// HashringConfigKey is the key in the ConfigMap for the hashring configuration.
	HashringConfigKey = "hashrings.json"
	// EmptyHashringConfig is the empty hashring configuration.
	EmptyHashringConfig = "[{}]"
)

Functions

func GetIngesterLabels

func GetIngesterLabels(opts IngesterOptions) map[string]string

func GetRequiredIngesterLabels

func GetRequiredIngesterLabels() map[string]string

GetRequiredIngesterLabels returns a map of labels that can be used to look up thanos receive ingest resources. These labels are guaranteed to be present on all ingest resources created by this package.

func GetRequiredLabels

func GetRequiredLabels() map[string]string

GetRequiredLabels returns a map of labels that can be used to look up thanos receive resources. These labels are guaranteed to be present on all resources created by this package.

func GetRequiredRouterLabels

func GetRequiredRouterLabels() map[string]string

GetRequiredRouterLabels returns a map of labels that can be used to look up thanos receive router resources. These labels are guaranteed to be present on all resources created by this package.

func GetRouterLabels

func GetRouterLabels(opts RouterOptions) map[string]string

func NewIngestorService

func NewIngestorService(opts IngesterOptions) *corev1.Service

NewIngestorService creates a new Service for the Thanos Receive ingester.

func NewIngestorStatefulSet

func NewIngestorStatefulSet(opts IngesterOptions) *appsv1.StatefulSet

NewIngestorStatefulSet creates a new StatefulSet for the Thanos Receive ingester.

func NewRouterDeployment

func NewRouterDeployment(opts RouterOptions) *appsv1.Deployment

NewRouterDeployment creates a new Deployment for the Thanos Receive router.

func NewRouterService

func NewRouterService(opts RouterOptions) *corev1.Service

NewRouterService creates a new Service for the Thanos Receive router.

Types

type IngesterOptions

type IngesterOptions struct {
	manifests.Options
	TSDBOpts
	StorageSize    resource.Quantity
	ObjStoreSecret corev1.SecretKeySelector
	ExternalLabels map[string]string
	// HashringName is the name of the hashring and is a required field.
	HashringName string
}

IngesterOptions for Thanos Receive components

func (IngesterOptions) Build

func (opts IngesterOptions) Build() []client.Object

Build builds the ingester for Thanos Receive

func (IngesterOptions) GetGeneratedResourceName

func (opts IngesterOptions) GetGeneratedResourceName() string

func (IngesterOptions) GetSelectorLabels

func (opts IngesterOptions) GetSelectorLabels() map[string]string

type RouterOptions

type RouterOptions struct {
	manifests.Options
	ReplicationFactor int32
	ExternalLabels    map[string]string
	HashringConfig    string
	HashringAlgorithm string
}

RouterOptions for Thanos Receive router

func (RouterOptions) Build

func (opts RouterOptions) Build() []client.Object

Build builds the Thanos Receive router components

func (RouterOptions) GetGeneratedResourceName

func (opts RouterOptions) GetGeneratedResourceName() string

func (RouterOptions) GetSelectorLabels

func (opts RouterOptions) GetSelectorLabels() map[string]string

type TSDBOpts

type TSDBOpts struct {
	Retention string
}