package
1.3.2
Repository: https://github.com/numaproj/numaflow.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
RegisterDaemonServiceHandler registers the http handlers for service DaemonService to "mux".
RegisterDaemonServiceHandlerClient registers the http handlers for service DaemonService to "mux".
RegisterDaemonServiceHandlerFromEndpoint is same as RegisterDaemonServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
RegisterDaemonServiceHandlerServer registers the http handlers for service DaemonService to "mux".
No description provided by the author

# Constants

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Variables

DaemonService_ServiceDesc is the grpc.ServiceDesc for DaemonService service.
No description provided by the author

# Structs

BufferInfo is used to provide information about the buffer including pending messages count, if it has unprocessed data etc which helps in pipeline/buffer deletion etc.
EdgeWatermark has edge to watermark mapping.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
GetPipelineWatermarksRequest requests for the watermark for a pipeline.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
PipelineStatus.
UnimplementedDaemonServiceServer must be embedded to have forward compatible implementations.
VertexMetrics is used to provide information about the vertex including processing rate.

# Interfaces

DaemonServiceClient is the client API for DaemonService service.
DaemonServiceServer is the server API for DaemonService service.
UnsafeDaemonServiceServer may be embedded to opt out of forward compatibility for this service.