Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HTTPClient ¶
HTTPClient interface for making HTTP requests (for testing)
type HTTPWatermarkFetcher ¶
type HTTPWatermarkFetcher struct {
// contains filtered or unexported fields
}
HTTPWatermarkFetcher fetches watermarks from vertex pods via HTTP /runtime/watermark endpoint
func NewHTTPWatermarkFetcher ¶
func NewHTTPWatermarkFetcher(ctx context.Context, pipeline *v1alpha1.Pipeline, edge v1alpha1.Edge) *HTTPWatermarkFetcher
NewHTTPWatermarkFetcher creates a new HTTP-based watermark fetcher and starts background fetching
func (*HTTPWatermarkFetcher) GetWatermarks ¶
func (h *HTTPWatermarkFetcher) GetWatermarks() ([]*wrapperspb.Int64Value, error)
GetWatermarks returns cached watermarks for all partitions of the edge
func (*HTTPWatermarkFetcher) Stop ¶
func (h *HTTPWatermarkFetcher) Stop()
Stop stops the background fetching and cleans up resources
type HTTPWatermarkService ¶
type HTTPWatermarkService struct {
// contains filtered or unexported fields
}
HTTPWatermarkService manages HTTP-based watermark fetching for all edges in a pipeline
func NewHTTPWatermarkService ¶
func NewHTTPWatermarkService(ctx context.Context, pipeline *v1alpha1.Pipeline) *HTTPWatermarkService
NewHTTPWatermarkService creates a new HTTP watermark service
func (*HTTPWatermarkService) GetPipelineWatermarks ¶
func (s *HTTPWatermarkService) GetPipelineWatermarks(ctx context.Context, _request *daemon.GetPipelineWatermarksRequest) (*daemon.GetPipelineWatermarksResponse, error)
GetPipelineWatermarks fetches watermarks for all edges in the pipeline
func (*HTTPWatermarkService) Stop ¶
func (s *HTTPWatermarkService) Stop()
Stop stops all background fetching and cleans up resources
type Response ¶ added in v1.7.0
Response represents the JSON response from the /runtime/watermark endpoint Example: {"0": 1752314641078, "1": 1752314641079}
func (*Response) UnmarshalJSON ¶ added in v1.7.0
UnmarshalJSON implements custom JSON unmarshaling for WatermarkResponse
Source Files