api

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, address string) (*Client, error)
  • func (c *Client) CheckHealth(ctx context.Context, address string) error
  • func (c *Client) Close() error
• type ConnectorService
• type PipelineService
• type ProcessorService

Types

type Client

type Client struct {
	PipelineServiceClient  PipelineService
	ConnectorServiceClient ConnectorService
	ProcessorServiceClient ProcessorService
	healthgrpc.HealthClient
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, address string) (*Client, error)

func (*Client) CheckHealth

func (c *Client) CheckHealth(ctx context.Context, address string) error

func (*Client) Close

func (c *Client) Close() error

type ConnectorService

type ConnectorService interface {
	ListConnectors(ctx context.Context, in *apiv1.ListConnectorsRequest, opts ...grpc.CallOption) (*apiv1.ListConnectorsResponse, error)
	GetConnector(ctx context.Context, in *apiv1.GetConnectorRequest, opts ...grpc.CallOption) (*apiv1.GetConnectorResponse, error)
	ListConnectorPlugins(ctx context.Context, in *apiv1.ListConnectorPluginsRequest, opts ...grpc.CallOption) (*apiv1.ListConnectorPluginsResponse, error)
}

ConnectorService defines the methods of the ConnectorServiceClient that are currently used by the CLI.

type PipelineService

type PipelineService interface {
	ListPipelines(ctx context.Context, in *apiv1.ListPipelinesRequest, opts ...grpc.CallOption) (*apiv1.ListPipelinesResponse, error)
	GetPipeline(ctx context.Context, in *apiv1.GetPipelineRequest, opts ...grpc.CallOption) (*apiv1.GetPipelineResponse, error)
	GetDLQ(ctx context.Context, in *apiv1.GetDLQRequest, opts ...grpc.CallOption) (*apiv1.GetDLQResponse, error)
}

PipelineService defines the methods of the PipelineServiceClient that are currently used by the CLI.

type ProcessorService

type ProcessorService interface {
	ListProcessors(ctx context.Context, in *apiv1.ListProcessorsRequest, opts ...grpc.CallOption) (*apiv1.ListProcessorsResponse, error)
	GetProcessor(ctx context.Context, in *apiv1.GetProcessorRequest, opts ...grpc.CallOption) (*apiv1.GetProcessorResponse, error)
	ListProcessorPlugins(ctx context.Context, in *apiv1.ListProcessorPluginsRequest, opts ...grpc.CallOption) (*apiv1.ListProcessorPluginsResponse, error)
}

ProcessorService defines the methods of the ProcessorServiceClient that are currently used by the CLI.