Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WorkloadClient ¶
type WorkloadClient interface {
ListWorkloads(ctx context.Context, filter *workloadsvcpb.ListWorkloadsRequest_Filter) ([]*workloadpb.Workload, error)
PublishWorkloads(ctx context.Context) (WorkloadsStream, error)
ListWorkloadEvents(ctx context.Context, filter *workloadsvcpb.ListWorkloadEventsRequest_Filter, requestPagination pagination.Pagination) ([]*workloadpb.WorkloadEvent, pagination.Pagination, error)
PublishWorkloadEvents(ctx context.Context) (WorkloadEventsStream, error)
}
WorkloadClient is an interface for a client for the v1alpha1 version of the Connect WorkloadService.
func New ¶
func New(conn grpc.ClientConnInterface) WorkloadClient
New instantiates a new WorkloadClient for communication with a Connect API.
type WorkloadEventsStream ¶ added in v0.61.0
type WorkloadEventsStream interface {
Send(events []*workloadpb.WorkloadEvent) error
Close() error
}
WorkloadEventsStream is the write end of a PublishWorkloadEvents client stream. The caller is responsible for batching, reconnection, and calling Close when done.
type WorkloadsStream ¶ added in v0.64.0
type WorkloadsStream interface {
Send(workloads []*workloadpb.Workload) error
Close() error
}
WorkloadsStream is the write end of a PublishWorkloads client stream. The caller is responsible for batching, reconnection, and calling Close when done.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.