service

package
v1.3.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 10, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package service is built for querying metadata and to expose it over daemon service.

Package service is built for querying metadata and to expose it over daemon service.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildUXEdgeWatermarkFetchers added in v0.10.0

func BuildUXEdgeWatermarkFetchers(ctx context.Context, pipeline *v1alpha1.Pipeline, wmStores map[v1alpha1.Edge][]store.WatermarkStore) (map[v1alpha1.Edge][]fetch.HeadFetcher, error)

BuildUXEdgeWatermarkFetchers returns a map of the watermark fetchers, where key is the buffer name, value is a list of fetchers to the buffers.

func BuildWatermarkStores added in v0.10.0

func BuildWatermarkStores(ctx context.Context, pipeline *v1alpha1.Pipeline, isbsvcClient isbsvc.ISBService) (map[v1alpha1.Edge][]store.WatermarkStore, error)

BuildWatermarkStores returns a map of watermark stores per edge.

Types

type HealthChecker added in v1.2.0

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

HealthChecker is the struct type for health checker.

func NewHealthChecker added in v1.2.0

func NewHealthChecker(pipeline *v1alpha1.Pipeline, isbSvcClient isbsvc.ISBService) *HealthChecker

NewHealthChecker creates a new object HealthChecker struct type.

type PipelineMetadataQuery added in v1.2.0

type PipelineMetadataQuery struct {
	daemon.UnimplementedDaemonServiceServer
	// contains filtered or unexported fields
}

PipelineMetadataQuery has the metadata required for the pipeline queries

func NewPipelineMetadataQuery added in v0.5.4

func NewPipelineMetadataQuery(
	isbSvcClient isbsvc.ISBService,
	pipeline *v1alpha1.Pipeline,
	wmFetchers map[v1alpha1.Edge][]fetch.HeadFetcher,
	rater rater.Ratable) (*PipelineMetadataQuery, error)

NewPipelineMetadataQuery returns a new instance of pipelineMetadataQuery

func (*PipelineMetadataQuery) GetBuffer added in v1.2.0

GetBuffer is used to obtain one buffer information of a pipeline

func (*PipelineMetadataQuery) GetPipelineStatus added in v1.2.0

func (*PipelineMetadataQuery) GetPipelineWatermarks added in v1.2.0

GetPipelineWatermarks is used to return the head watermarks for a given pipeline.

func (*PipelineMetadataQuery) GetVertexMetrics added in v1.2.0

GetVertexMetrics is used to query the metrics service and is used to obtain the processing rate of a given vertex for 1m, 5m and 15m. Response contains the metrics for each partition of the vertex. In the future maybe latency will also be added here? Should this method live here or maybe another file?

func (*PipelineMetadataQuery) ListBuffers added in v1.2.0

ListBuffers is used to obtain the all the edge buffers information of a pipeline

func (*PipelineMetadataQuery) StartHealthCheck added in v1.2.0

func (ps *PipelineMetadataQuery) StartHealthCheck(ctx context.Context)

StartHealthCheck starts the health check for the pipeline using the health checker

Directories

Path Synopsis
Package rater provides the functionality to calculate the processing rate of each vertex partition.
Package rater provides the functionality to calculate the processing rate of each vertex partition.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL