Documentation
¶
Overview ¶
Package client is used to create the daemon service client.
There are 2 clients available for daemon service.
gRPC client func NewGRPCDaemonServiceClient(address string) (DaemonClient, error)
RESTful client func NewRESTfulDaemonServiceClient(address string) (DaemonClient, error)
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DaemonClient ¶
type DaemonClient interface {
io.Closer
IsDrained(ctx context.Context, pipeline string) (bool, error)
ListPipelineBuffers(ctx context.Context, pipeline string) ([]*daemon.BufferInfo, error)
GetPipelineBuffer(ctx context.Context, pipeline, buffer string) (*daemon.BufferInfo, error)
GetVertexMetrics(ctx context.Context, pipeline, vertex string) ([]*daemon.VertexMetrics, error)
GetPipelineWatermarks(ctx context.Context, pipeline string) ([]*daemon.EdgeWatermark, error)
GetPipelineStatus(ctx context.Context, pipeline string) (*daemon.PipelineStatus, error)
GetVertexErrors(ctx context.Context, pipeline, vertex string) ([]*daemon.ReplicaErrors, error)
}
func NewGRPCDaemonServiceClient ¶ added in v1.3.0
func NewGRPCDaemonServiceClient(address string) (DaemonClient, error)
func NewRESTfulDaemonServiceClient ¶ added in v1.3.0
func NewRESTfulDaemonServiceClient(address string) (DaemonClient, error)
Source Files
Click to show internal directories.
Click to hide internal directories.