dataflow

Sep 12, 2024

Changes in this version

type JobIterator

+ func (it *JobIterator) All() iter.Seq2[*dataflowpb.Job, error]

type JobMessageIterator

+ func (it *JobMessageIterator) All() iter.Seq2[*dataflowpb.JobMessage, error]

type StageSummaryIterator

+ func (it *StageSummaryIterator) All() iter.Seq2[*dataflowpb.StageSummary, error]

type WorkerDetailsIterator

+ func (it *WorkerDetailsIterator) All() iter.Seq2[*dataflowpb.WorkerDetails, error]

Jun 29, 2022

Changes in this version

type FlexTemplatesClient

+ func NewFlexTemplatesRESTClient(ctx context.Context, opts ...option.ClientOption) (*FlexTemplatesClient, error)

type JobsV1Beta3Client

+ func NewJobsV1Beta3RESTClient(ctx context.Context, opts ...option.ClientOption) (*JobsV1Beta3Client, error)

type MessagesV1Beta3Client

+ func NewMessagesV1Beta3RESTClient(ctx context.Context, opts ...option.ClientOption) (*MessagesV1Beta3Client, error)

type MetricsV1Beta3Client

+ func NewMetricsV1Beta3RESTClient(ctx context.Context, opts ...option.ClientOption) (*MetricsV1Beta3Client, error)

type SnapshotsV1Beta3Client

+ func NewSnapshotsV1Beta3RESTClient(ctx context.Context, opts ...option.ClientOption) (*SnapshotsV1Beta3Client, error)

type TemplatesClient

+ func NewTemplatesRESTClient(ctx context.Context, opts ...option.ClientOption) (*TemplatesClient, error)

Aug 16, 2021

Changes in this version

+ func DefaultAuthScopes() []string

+ type FlexTemplatesCallOptions struct

+ LaunchFlexTemplate []gax.CallOption

+ type FlexTemplatesClient struct

+ CallOptions *FlexTemplatesCallOptions

+ func NewFlexTemplatesClient(ctx context.Context, opts ...option.ClientOption) (*FlexTemplatesClient, error)

+ func (c *FlexTemplatesClient) Close() error

+ func (c *FlexTemplatesClient) Connection() *grpc.ClientConn

+ func (c *FlexTemplatesClient) LaunchFlexTemplate(ctx context.Context, req *dataflowpb.LaunchFlexTemplateRequest, ...) (*dataflowpb.LaunchFlexTemplateResponse, error)

+ type JobIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*dataflowpb.Job, nextPageToken string, err error)

+ Response interface{}

+ func (it *JobIterator) Next() (*dataflowpb.Job, error)

+ func (it *JobIterator) PageInfo() *iterator.PageInfo

+ type JobMessageIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*dataflowpb.JobMessage, nextPageToken string, err error)

+ Response interface{}

+ func (it *JobMessageIterator) Next() (*dataflowpb.JobMessage, error)

+ func (it *JobMessageIterator) PageInfo() *iterator.PageInfo

+ type JobsV1Beta3CallOptions struct

+ AggregatedListJobs []gax.CallOption

+ CheckActiveJobs []gax.CallOption

+ CreateJob []gax.CallOption

+ GetJob []gax.CallOption

+ ListJobs []gax.CallOption

+ SnapshotJob []gax.CallOption

+ UpdateJob []gax.CallOption

+ type JobsV1Beta3Client struct

+ CallOptions *JobsV1Beta3CallOptions

+ func NewJobsV1Beta3Client(ctx context.Context, opts ...option.ClientOption) (*JobsV1Beta3Client, error)

+ func (c *JobsV1Beta3Client) AggregatedListJobs(ctx context.Context, req *dataflowpb.ListJobsRequest, opts ...gax.CallOption) *JobIterator

+ func (c *JobsV1Beta3Client) CheckActiveJobs(ctx context.Context, req *dataflowpb.CheckActiveJobsRequest, ...) (*dataflowpb.CheckActiveJobsResponse, error)

+ func (c *JobsV1Beta3Client) Close() error

+ func (c *JobsV1Beta3Client) Connection() *grpc.ClientConn

+ func (c *JobsV1Beta3Client) CreateJob(ctx context.Context, req *dataflowpb.CreateJobRequest, opts ...gax.CallOption) (*dataflowpb.Job, error)

+ func (c *JobsV1Beta3Client) GetJob(ctx context.Context, req *dataflowpb.GetJobRequest, opts ...gax.CallOption) (*dataflowpb.Job, error)

+ func (c *JobsV1Beta3Client) ListJobs(ctx context.Context, req *dataflowpb.ListJobsRequest, opts ...gax.CallOption) *JobIterator

+ func (c *JobsV1Beta3Client) SnapshotJob(ctx context.Context, req *dataflowpb.SnapshotJobRequest, ...) (*dataflowpb.Snapshot, error)

+ func (c *JobsV1Beta3Client) UpdateJob(ctx context.Context, req *dataflowpb.UpdateJobRequest, opts ...gax.CallOption) (*dataflowpb.Job, error)

+ type MessagesV1Beta3CallOptions struct

+ ListJobMessages []gax.CallOption

+ type MessagesV1Beta3Client struct

+ CallOptions *MessagesV1Beta3CallOptions

+ func NewMessagesV1Beta3Client(ctx context.Context, opts ...option.ClientOption) (*MessagesV1Beta3Client, error)

+ func (c *MessagesV1Beta3Client) Close() error

+ func (c *MessagesV1Beta3Client) Connection() *grpc.ClientConn

+ func (c *MessagesV1Beta3Client) ListJobMessages(ctx context.Context, req *dataflowpb.ListJobMessagesRequest, ...) *JobMessageIterator

+ type MetricsV1Beta3CallOptions struct

+ GetJobExecutionDetails []gax.CallOption

+ GetJobMetrics []gax.CallOption

+ GetStageExecutionDetails []gax.CallOption

+ type MetricsV1Beta3Client struct

+ CallOptions *MetricsV1Beta3CallOptions

+ func NewMetricsV1Beta3Client(ctx context.Context, opts ...option.ClientOption) (*MetricsV1Beta3Client, error)

+ func (c *MetricsV1Beta3Client) Close() error

+ func (c *MetricsV1Beta3Client) Connection() *grpc.ClientConn

+ func (c *MetricsV1Beta3Client) GetJobExecutionDetails(ctx context.Context, req *dataflowpb.GetJobExecutionDetailsRequest, ...) *StageSummaryIterator

+ func (c *MetricsV1Beta3Client) GetJobMetrics(ctx context.Context, req *dataflowpb.GetJobMetricsRequest, ...) (*dataflowpb.JobMetrics, error)

+ func (c *MetricsV1Beta3Client) GetStageExecutionDetails(ctx context.Context, req *dataflowpb.GetStageExecutionDetailsRequest, ...) *WorkerDetailsIterator

+ type SnapshotsV1Beta3CallOptions struct

+ DeleteSnapshot []gax.CallOption

+ GetSnapshot []gax.CallOption

+ ListSnapshots []gax.CallOption

+ type SnapshotsV1Beta3Client struct

+ CallOptions *SnapshotsV1Beta3CallOptions

+ func NewSnapshotsV1Beta3Client(ctx context.Context, opts ...option.ClientOption) (*SnapshotsV1Beta3Client, error)

+ func (c *SnapshotsV1Beta3Client) Close() error

+ func (c *SnapshotsV1Beta3Client) Connection() *grpc.ClientConn

+ func (c *SnapshotsV1Beta3Client) DeleteSnapshot(ctx context.Context, req *dataflowpb.DeleteSnapshotRequest, ...) (*dataflowpb.DeleteSnapshotResponse, error)

+ func (c *SnapshotsV1Beta3Client) GetSnapshot(ctx context.Context, req *dataflowpb.GetSnapshotRequest, ...) (*dataflowpb.Snapshot, error)

+ func (c *SnapshotsV1Beta3Client) ListSnapshots(ctx context.Context, req *dataflowpb.ListSnapshotsRequest, ...) (*dataflowpb.ListSnapshotsResponse, error)

+ type StageSummaryIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*dataflowpb.StageSummary, nextPageToken string, err error)

+ Response interface{}

+ func (it *StageSummaryIterator) Next() (*dataflowpb.StageSummary, error)

+ func (it *StageSummaryIterator) PageInfo() *iterator.PageInfo

+ type TemplatesCallOptions struct

+ CreateJobFromTemplate []gax.CallOption

+ GetTemplate []gax.CallOption

+ LaunchTemplate []gax.CallOption

+ type TemplatesClient struct

+ CallOptions *TemplatesCallOptions

+ func NewTemplatesClient(ctx context.Context, opts ...option.ClientOption) (*TemplatesClient, error)

+ func (c *TemplatesClient) Close() error

+ func (c *TemplatesClient) Connection() *grpc.ClientConn

+ func (c *TemplatesClient) CreateJobFromTemplate(ctx context.Context, req *dataflowpb.CreateJobFromTemplateRequest, ...) (*dataflowpb.Job, error)

+ func (c *TemplatesClient) GetTemplate(ctx context.Context, req *dataflowpb.GetTemplateRequest, ...) (*dataflowpb.GetTemplateResponse, error)

+ func (c *TemplatesClient) LaunchTemplate(ctx context.Context, req *dataflowpb.LaunchTemplateRequest, ...) (*dataflowpb.LaunchTemplateResponse, error)

+ type WorkerDetailsIterator struct

+ InternalFetch func(pageSize int, pageToken string) (results []*dataflowpb.WorkerDetails, nextPageToken string, err error)

+ Response interface{}

+ func (it *WorkerDetailsIterator) Next() (*dataflowpb.WorkerDetails, error)

+ func (it *WorkerDetailsIterator) PageInfo() *iterator.PageInfo