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 ¶
View Source
const ( PipelineStatusOK = "OK" PipelineStatusError = "Error" PipelineStatusUnknown = "Unknown" )
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.
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
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.