service

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
• func BuildUXEdgeWatermarkFetchers(ctx context.Context, pipeline *v1alpha1.Pipeline, ...) (map[v1alpha1.Edge][]fetch.HeadFetcher, error)
• func BuildWatermarkStores(ctx context.Context, pipeline *v1alpha1.Pipeline, ...) (map[v1alpha1.Edge][]store.WatermarkStore, error)
• func NewPipelineMetadataQuery(isbSvcClient isbsvc.ISBService, pipeline *v1alpha1.Pipeline, ...) (*pipelineMetadataQuery, error)

Constants

const (
	PipelineStatusOK      = "OK"
	PipelineStatusError   = "Error"
	PipelineStatusUnknown = "Unknown"
)

Functions

func BuildUXEdgeWatermarkFetchers

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

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.

func NewPipelineMetadataQuery

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