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) GetPipelineStatus(ctx context.Context, pipeline string) (*daemon.PipelineStatus, error)
  • func (dc *DaemonClient) GetPipelineWatermarks(ctx context.Context, pipeline string) ([]*daemon.EdgeWatermark, error)
  • func (dc *DaemonClient) GetVertexMetrics(ctx context.Context, pipeline, vertex string) ([]*daemon.VertexMetrics, 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) GetPipelineStatus

func (dc *DaemonClient) GetPipelineStatus(ctx context.Context, pipeline string) (*daemon.PipelineStatus, error)

func (*DaemonClient) GetPipelineWatermarks

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

GetPipelineWatermarks returns the []EdgeWatermark response instance for GetPipelineWatermarksRequest

func (*DaemonClient) GetVertexMetrics

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

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)