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

Constants

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

Functions

func GetEdgeWatermarkFetchers

func GetEdgeWatermarkFetchers(ctx context.Context, pipeline *v1alpha1.Pipeline, isbSvcClient isbsvc.ISBService) (map[v1alpha1.Edge][]fetch.Fetcher, error)

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

func NewPipelineMetadataQuery

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

NewPipelineMetadataQuery returns a new instance of pipelineMetadataQuery