client

Documentation

Index

• type DaemonClient
  • func NewDaemonServiceClient(address string) (*DaemonClient, error)
  • func (dc *DaemonClient) Close() error
  • func (dc *DaemonClient) GetPipelineBuffer(ctx context.Context, pipeline, buffer string) (*daemon.BufferInfo, error)
  • func (dc *DaemonClient) GetVertexMetrics(ctx context.Context, pipeline, vertex string) (*daemon.VertexMetrics, error)
  • func (dc *DaemonClient) GetVertexWatermark(ctx context.Context, pipeline, vertex string) (*daemon.VertexWatermark, error)
  • func (dc *DaemonClient) IsDrained(ctx context.Context, pipeline string) (bool, error)
  • func (dc *DaemonClient) ListPipelineBuffers(ctx context.Context, pipeline string) ([]*daemon.BufferInfo, error)

Types

type DaemonClient

type DaemonClient struct {
	// contains filtered or unexported fields
}

func NewDaemonServiceClient

func NewDaemonServiceClient(address string) (*DaemonClient, error)

func (*DaemonClient) Close

func (dc *DaemonClient) Close() error

Close function closes the gRPC connection, it has to be called after a daemon client has finished all its jobs.

func (*DaemonClient) GetPipelineBuffer

func (dc *DaemonClient) GetPipelineBuffer(ctx context.Context, pipeline, buffer string) (*daemon.BufferInfo, error)

func (*DaemonClient) GetVertexMetrics

func (dc *DaemonClient) GetVertexMetrics(ctx context.Context, pipeline, vertex string) (*daemon.VertexMetrics, error)

func (*DaemonClient) GetVertexWatermark

func (dc *DaemonClient) GetVertexWatermark(ctx context.Context, pipeline, vertex string) (*daemon.VertexWatermark, error)

GetVertexWatermark returns the VertexWatermark response instance for GetVertexWatermarkRequest

func (*DaemonClient) IsDrained

func (dc *DaemonClient) IsDrained(ctx context.Context, pipeline string) (bool, error)

func (*DaemonClient) ListPipelineBuffers

func (dc *DaemonClient) ListPipelineBuffers(ctx context.Context, pipeline string) ([]*daemon.BufferInfo, error)