client

Documentation

Overview

Package client is used to create the daemon service client.

There are 2 clients available for daemon service.

1. gRPC client func NewGRPCDaemonServiceClient(address string) (DaemonClient, error)

2. RESTful client func NewRESTfulDaemonServiceClient(address string) (DaemonClient, error)

Index

• type DaemonClient
  • func NewGRPCDaemonServiceClient(address string) (DaemonClient, error)
  • func NewRESTfulDaemonServiceClient(address string) (DaemonClient, error)

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)
}

func NewGRPCDaemonServiceClient

func NewGRPCDaemonServiceClient(address string) (DaemonClient, error)

func NewRESTfulDaemonServiceClient

func NewRESTfulDaemonServiceClient(address string) (DaemonClient, error)