batchv1

package
v0.0.0-...-3fe0de6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 27, 2025 License: MIT Imports: 26 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-resource. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var (
	BatchJobStateChangedEvent_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "QUEUED",
		2: "SCHEDULED",
		3: "RUNNING",
		4: "SUCCEEDED",
		5: "FAILED",
		6: "DELETION_IN_PROGRESS",
	}
	BatchJobStateChangedEvent_State_value = map[string]int32{
		"STATE_UNSPECIFIED":    0,
		"QUEUED":               1,
		"SCHEDULED":            2,
		"RUNNING":              3,
		"SUCCEEDED":            4,
		"FAILED":               5,
		"DELETION_IN_PROGRESS": 6,
	}
)

Enum value maps for BatchJobStateChangedEvent_State.

View Source 
var (
	BatchTaskStateChangedEvent_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		2: "ASSIGNED",
		3: "RUNNING",
		4: "FAILED",
		5: "SUCCEEDED",
		6: "UNEXECUTED",
	}
	BatchTaskStateChangedEvent_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"ASSIGNED":          2,
		"RUNNING":           3,
		"FAILED":            4,
		"SUCCEEDED":         5,
		"UNEXECUTED":        6,
	}
)

Enum value maps for BatchTaskStateChangedEvent_State.

View Source 
var (
	BatchJobStatus_STATE_UNSPECIFIED = batchpb.JobStatus_STATE_UNSPECIFIED
	// Notify users that the job state has changed.
	BatchJobNotification_JOB_STATE_CHANGED = batchpb.JobNotification_JOB_STATE_CHANGED
)
View Source 
var (
	BatchTaskStatus_STATE_UNSPECIFIED = batchpb.TaskStatus_STATE_UNSPECIFIED
	// Notify users that the task state has changed.
	BatchJobNotification_TASK_STATE_CHANGED = batchpb.JobNotification_TASK_STATE_CHANGED
)
View Source 
var ErrBatchEventTypeUnknown = errors.New("unknown batch event type")

The error occurs when the event is unknown.

View Source 
var File_connect_batch_v1_batch_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BatchJob 

type BatchJob = batchpb.Job

type BatchJobEvent 

type BatchJobEvent interface {
	ParseJobName() (ParsedJobName, error)
	GetJobName() string
	SetJobName(string)
	GetJobUid() string
	SetJobUid(string)
}

BatchJobEvent is the interface for batch job event type BatchJobEvent interface {

type BatchJobEventHandler 

type BatchJobEventHandler interface {
	// HandleBatchJobEvent handles connect.batch.v1.BatchJobEvent event.
	HandleBatchJobEvent(context.Context, BatchJobEvent) error
}

BatchJobEventHandler handles connect.batch.v1.BatchJobEvent event.

type BatchJobIterator 

type BatchJobIterator interface {
	Next() (*batchpb.Job, error)
	PageInfo() BatchPageInfo
}

type BatchJobStateChangedEvent 

type BatchJobStateChangedEvent struct {

	// Output only. Job name.
	// For example: "projects/123456/locations/us-central1/jobs/job01".
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// Output only. Job UID.
	JobUid string `protobuf:"bytes,2,opt,name=job_uid,json=jobUid,proto3" json:"job_uid,omitempty"`
	// Output only. Job's old state.
	OldJobState BatchJobStateChangedEvent_State `` /* 151-byte string literal not displayed */
	// Output only. Job's new state.
	NewJobState BatchJobStateChangedEvent_State `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

BatchJobStateChangedEvent is emitted when a job's state changes.

func (*BatchJobStateChangedEvent) Default 

func (x *BatchJobStateChangedEvent) Default()

func (*BatchJobStateChangedEvent) Descriptor deprecated 

func (*BatchJobStateChangedEvent) Descriptor() ([]byte, []int)

Deprecated: Use BatchJobStateChangedEvent.ProtoReflect.Descriptor instead.

func (*BatchJobStateChangedEvent) GetJobName 

func (x *BatchJobStateChangedEvent) GetJobName() string

func (*BatchJobStateChangedEvent) GetJobUid 

func (x *BatchJobStateChangedEvent) GetJobUid() string

func (*BatchJobStateChangedEvent) GetNewJobState 

func (x *BatchJobStateChangedEvent) GetNewJobState() BatchJobStateChangedEvent_State

func (*BatchJobStateChangedEvent) GetOldJobState 

func (x *BatchJobStateChangedEvent) GetOldJobState() BatchJobStateChangedEvent_State

func (*BatchJobStateChangedEvent) MarshalJSON 

func (msg *BatchJobStateChangedEvent) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*BatchJobStateChangedEvent) ParseJobName 

func (x *BatchJobStateChangedEvent) ParseJobName() (ParsedJobName, error)

func (*BatchJobStateChangedEvent) ProtoMessage 

func (*BatchJobStateChangedEvent) ProtoMessage()

func (*BatchJobStateChangedEvent) ProtoReflect 

func (x *BatchJobStateChangedEvent) ProtoReflect() protoreflect.Message

func (*BatchJobStateChangedEvent) Reset 

func (x *BatchJobStateChangedEvent) Reset()

func (*BatchJobStateChangedEvent) SetJobName 

func (x *BatchJobStateChangedEvent) SetJobName(name string)

SetJobName implements BatchJobEvent.

func (*BatchJobStateChangedEvent) SetJobUid 

func (x *BatchJobStateChangedEvent) SetJobUid(uid string)

SetJobUid implements BatchJobEvent.

func (*BatchJobStateChangedEvent) String 

func (x *BatchJobStateChangedEvent) String() string

func (*BatchJobStateChangedEvent) UnmarshalJSON 

func (msg *BatchJobStateChangedEvent) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*BatchJobStateChangedEvent) Validate 

func (m *BatchJobStateChangedEvent) Validate() error

Validate checks the field values on BatchJobStateChangedEvent with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*BatchJobStateChangedEvent) ValidateAll 

func (m *BatchJobStateChangedEvent) ValidateAll() error

ValidateAll checks the field values on BatchJobStateChangedEvent with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in BatchJobStateChangedEventMultiError, or nil if none found.

type BatchJobStateChangedEventMultiError 

type BatchJobStateChangedEventMultiError []error

BatchJobStateChangedEventMultiError is an error wrapping multiple validation errors returned by BatchJobStateChangedEvent.ValidateAll() if the designated constraints aren't met.

func (BatchJobStateChangedEventMultiError) AllErrors 

func (m BatchJobStateChangedEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BatchJobStateChangedEventMultiError) Error 

func (m BatchJobStateChangedEventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type BatchJobStateChangedEventValidationError 

type BatchJobStateChangedEventValidationError struct {
	// contains filtered or unexported fields
}

BatchJobStateChangedEventValidationError is the validation error returned by BatchJobStateChangedEvent.Validate if the designated constraints aren't met.

func (BatchJobStateChangedEventValidationError) Cause 

func (e BatchJobStateChangedEventValidationError) Cause() error

Cause function returns cause value.

func (BatchJobStateChangedEventValidationError) Error 

func (e BatchJobStateChangedEventValidationError) Error() string

Error satisfies the builtin error interface

func (BatchJobStateChangedEventValidationError) ErrorName 

func (e BatchJobStateChangedEventValidationError) ErrorName() string

ErrorName returns error name.

func (BatchJobStateChangedEventValidationError) Field 

func (e BatchJobStateChangedEventValidationError) Field() string

Field function returns field value.

func (BatchJobStateChangedEventValidationError) Key 

func (e BatchJobStateChangedEventValidationError) Key() bool

Key function returns key value.

func (BatchJobStateChangedEventValidationError) Reason 

func (e BatchJobStateChangedEventValidationError) Reason() string

Reason function returns reason value.

type BatchJobStateChangedEvent_State 

type BatchJobStateChangedEvent_State int32

Valid Job states. 

const (
	// Job state unspecified.
	BatchJobStateChangedEvent_STATE_UNSPECIFIED BatchJobStateChangedEvent_State = 0
	// Job is admitted (validated and persisted) and waiting for resources.
	BatchJobStateChangedEvent_QUEUED BatchJobStateChangedEvent_State = 1
	// Job is scheduled to run as soon as resource allocation is ready.
	// The resource allocation may happen at a later time but with a high
	// chance to succeed.
	BatchJobStateChangedEvent_SCHEDULED BatchJobStateChangedEvent_State = 2
	// Resource allocation has been successful. At least one Task in the Job is
	// RUNNING.
	BatchJobStateChangedEvent_RUNNING BatchJobStateChangedEvent_State = 3
	// All Tasks in the Job have finished successfully.
	BatchJobStateChangedEvent_SUCCEEDED BatchJobStateChangedEvent_State = 4
	// At least one Task in the Job has failed.
	BatchJobStateChangedEvent_FAILED BatchJobStateChangedEvent_State = 5
	// The Job will be deleted, but has not been deleted yet. Typically this is
	// because resources used by the Job are still being cleaned up.
	BatchJobStateChangedEvent_DELETION_IN_PROGRESS BatchJobStateChangedEvent_State = 6
)

func NewBatchJobStateChangedEvent_State 

func NewBatchJobStateChangedEvent_State(text string) BatchJobStateChangedEvent_State

BatchJobStateChangedEvent_State is the enum type of BatchJobStateChangedEvent.State.

func (BatchJobStateChangedEvent_State) Descriptor 

func (BatchJobStateChangedEvent_State) Descriptor() protoreflect.EnumDescriptor

func (BatchJobStateChangedEvent_State) Enum 

func (x BatchJobStateChangedEvent_State) Enum() *BatchJobStateChangedEvent_State

func (BatchJobStateChangedEvent_State) EnumDescriptor deprecated 

func (BatchJobStateChangedEvent_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use BatchJobStateChangedEvent_State.Descriptor instead.

func (BatchJobStateChangedEvent_State) Number 

func (x BatchJobStateChangedEvent_State) Number() protoreflect.EnumNumber

func (BatchJobStateChangedEvent_State) String 

func (x BatchJobStateChangedEvent_State) String() string

func (BatchJobStateChangedEvent_State) Type 

func (BatchJobStateChangedEvent_State) Type() protoreflect.EnumType

type BatchJobStatus 

type BatchJobStatus = batchpb.JobStatus

type BatchJobStatus_State 

type BatchJobStatus_State = batchpb.JobStatus_State

type BatchOperation 

type BatchOperation = longrunningpb.Operation

type BatchOperationIterator 

type BatchOperationIterator interface {
	Next() (*BatchOperation, error)
	PageInfo() BatchPageInfo
}

type BatchPageInfo 

type BatchPageInfo interface {
	Token() string
	MaxSize() int
	Remaining() int
}

PageInfo contains information about an iterator's paging state.

type BatchServiceClient 

type BatchServiceClient interface {
	CreateJob(context.Context, *CreateBatchJobRequest, ...gax.CallOption) (*BatchJob, error)
	GetJob(context.Context, *GetBatchJobRequest, ...gax.CallOption) (*BatchJob, error)
	DeleteJob(context.Context, *DeleteBatchJobRequest, ...gax.CallOption) (DeleteBatchJobOperation, error)
	DeleteJobOperation(string) DeleteBatchJobOperation
	ListJobs(context.Context, *ListBatchJobsRequest, ...gax.CallOption) BatchJobIterator
	GetTask(context.Context, *GetBatchTaskRequest, ...gax.CallOption) (*BatchTask, error)
	ListTasks(context.Context, *ListBatchTasksRequest, ...gax.CallOption) BatchTaskIterator
	CancelOperation(context.Context, *CancelBatchOperationRequest, ...gax.CallOption) error
	DeleteOperation(context.Context, *DeleteBatchOperationRequest, ...gax.CallOption) error
}

BatchServiceClient is the client API for BatchService service.

type BatchTask 

type BatchTask = batchpb.Task

type BatchTaskEvent 

type BatchTaskEvent interface {
	ParseTaskName() (ParsedTaskName, error)
	GetTaskName() string
	SetTaskName(string)
	GetTaskUid() string
	SetTaskUid(string)
}

BatchTaskEvent is the interface for batch job event type BatchTaskEvent interface {

type BatchTaskEventHandler 

type BatchTaskEventHandler interface {
	// HandleBatchTaskEvent handles connect.batch.v1.BatchTaskEvent event.
	HandleBatchTaskEvent(context.Context, BatchTaskEvent) error
}

BatchTaskEventHandler handles connect.batch.v1.BatchTaskEvent event.

type BatchTaskIterator 

type BatchTaskIterator interface {
	Next() (*batchpb.Task, error)
	PageInfo() BatchPageInfo
}

type BatchTaskStateChangedEvent 

type BatchTaskStateChangedEvent struct {

	// Task name.
	// The name is generated from the parent TaskGroup name and 'id' field.
	// For example:
	// "projects/123456/locations/us-west1/jobs/job01/taskGroups/group01/tasks/task01".
	TaskName string `protobuf:"bytes,1,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	// Output only. Task UID.
	TaskUid string `protobuf:"bytes,2,opt,name=task_uid,json=taskUid,proto3" json:"task_uid,omitempty"`
	// Output only. Task's old state.
	OldTaskState BatchTaskStateChangedEvent_State `` /* 155-byte string literal not displayed */
	// Output only. Task's new state.
	NewTaskState BatchTaskStateChangedEvent_State `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

BatchTaskStateChangedEvent is emitted when a task's state changes.

func (*BatchTaskStateChangedEvent) Default 

func (x *BatchTaskStateChangedEvent) Default()

func (*BatchTaskStateChangedEvent) Descriptor deprecated 

func (*BatchTaskStateChangedEvent) Descriptor() ([]byte, []int)

Deprecated: Use BatchTaskStateChangedEvent.ProtoReflect.Descriptor instead.

func (*BatchTaskStateChangedEvent) GetNewTaskState 

func (x *BatchTaskStateChangedEvent) GetNewTaskState() BatchTaskStateChangedEvent_State

func (*BatchTaskStateChangedEvent) GetOldTaskState 

func (x *BatchTaskStateChangedEvent) GetOldTaskState() BatchTaskStateChangedEvent_State

func (*BatchTaskStateChangedEvent) GetTaskName 

func (x *BatchTaskStateChangedEvent) GetTaskName() string

func (*BatchTaskStateChangedEvent) GetTaskUid 

func (x *BatchTaskStateChangedEvent) GetTaskUid() string

func (*BatchTaskStateChangedEvent) MarshalJSON 

func (msg *BatchTaskStateChangedEvent) MarshalJSON() ([]byte, error)

MarshalJSON implements json.Marshaler

func (*BatchTaskStateChangedEvent) ParseTaskName 

func (x *BatchTaskStateChangedEvent) ParseTaskName() (ParsedTaskName, error)

func (*BatchTaskStateChangedEvent) ProtoMessage 

func (*BatchTaskStateChangedEvent) ProtoMessage()

func (*BatchTaskStateChangedEvent) ProtoReflect 

func (x *BatchTaskStateChangedEvent) ProtoReflect() protoreflect.Message

func (*BatchTaskStateChangedEvent) Reset 

func (x *BatchTaskStateChangedEvent) Reset()

func (*BatchTaskStateChangedEvent) SetTaskName 

func (x *BatchTaskStateChangedEvent) SetTaskName(name string)

SetTaskName implements BatchTaskEvent.

func (*BatchTaskStateChangedEvent) SetTaskUid 

func (x *BatchTaskStateChangedEvent) SetTaskUid(uid string)

SetTaskUid implements BatchTaskEvent.

func (*BatchTaskStateChangedEvent) String 

func (x *BatchTaskStateChangedEvent) String() string

func (*BatchTaskStateChangedEvent) UnmarshalJSON 

func (msg *BatchTaskStateChangedEvent) UnmarshalJSON(b []byte) error

UnmarshalJSON implements json.Unmarshaler

func (*BatchTaskStateChangedEvent) Validate 

func (m *BatchTaskStateChangedEvent) Validate() error

Validate checks the field values on BatchTaskStateChangedEvent with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*BatchTaskStateChangedEvent) ValidateAll 

func (m *BatchTaskStateChangedEvent) ValidateAll() error

ValidateAll checks the field values on BatchTaskStateChangedEvent with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in BatchTaskStateChangedEventMultiError, or nil if none found.

type BatchTaskStateChangedEventMultiError 

type BatchTaskStateChangedEventMultiError []error

BatchTaskStateChangedEventMultiError is an error wrapping multiple validation errors returned by BatchTaskStateChangedEvent.ValidateAll() if the designated constraints aren't met.

func (BatchTaskStateChangedEventMultiError) AllErrors 

func (m BatchTaskStateChangedEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BatchTaskStateChangedEventMultiError) Error 

func (m BatchTaskStateChangedEventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type BatchTaskStateChangedEventValidationError 

type BatchTaskStateChangedEventValidationError struct {
	// contains filtered or unexported fields
}

BatchTaskStateChangedEventValidationError is the validation error returned by BatchTaskStateChangedEvent.Validate if the designated constraints aren't met.

func (BatchTaskStateChangedEventValidationError) Cause 

func (e BatchTaskStateChangedEventValidationError) Cause() error

Cause function returns cause value.

func (BatchTaskStateChangedEventValidationError) Error 

func (e BatchTaskStateChangedEventValidationError) Error() string

Error satisfies the builtin error interface

func (BatchTaskStateChangedEventValidationError) ErrorName 

func (e BatchTaskStateChangedEventValidationError) ErrorName() string

ErrorName returns error name.

func (BatchTaskStateChangedEventValidationError) Field 

func (e BatchTaskStateChangedEventValidationError) Field() string

Field function returns field value.

func (BatchTaskStateChangedEventValidationError) Key 

func (e BatchTaskStateChangedEventValidationError) Key() bool

Key function returns key value.

func (BatchTaskStateChangedEventValidationError) Reason 

func (e BatchTaskStateChangedEventValidationError) Reason() string

Reason function returns reason value.

type BatchTaskStateChangedEvent_State 

type BatchTaskStateChangedEvent_State int32

Task states. 

const (
	// Unknown state.
	BatchTaskStateChangedEvent_STATE_UNSPECIFIED BatchTaskStateChangedEvent_State = 0
	// The Task is created and waiting for resources.
	BatchTaskStateChangedEvent_PENDING BatchTaskStateChangedEvent_State = 1
	// The Task is assigned to at least one VM.
	BatchTaskStateChangedEvent_ASSIGNED BatchTaskStateChangedEvent_State = 2
	// The Task is running.
	BatchTaskStateChangedEvent_RUNNING BatchTaskStateChangedEvent_State = 3
	// The Task has failed.
	BatchTaskStateChangedEvent_FAILED BatchTaskStateChangedEvent_State = 4
	// The Task has succeeded.
	BatchTaskStateChangedEvent_SUCCEEDED BatchTaskStateChangedEvent_State = 5
	// The Task has not been executed when the Job finishes.
	BatchTaskStateChangedEvent_UNEXECUTED BatchTaskStateChangedEvent_State = 6
)

func NewBatchTaskStateChangedEvent_State 

func NewBatchTaskStateChangedEvent_State(text string) BatchTaskStateChangedEvent_State

BatchTaskStateChangedEvent_State is the enum type of BatchTaskStateChangedEvent.State.

func (BatchTaskStateChangedEvent_State) Descriptor 

func (BatchTaskStateChangedEvent_State) Descriptor() protoreflect.EnumDescriptor

func (BatchTaskStateChangedEvent_State) Enum 

func (x BatchTaskStateChangedEvent_State) Enum() *BatchTaskStateChangedEvent_State

func (BatchTaskStateChangedEvent_State) EnumDescriptor deprecated 

func (BatchTaskStateChangedEvent_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use BatchTaskStateChangedEvent_State.Descriptor instead.

func (BatchTaskStateChangedEvent_State) Number 

func (x BatchTaskStateChangedEvent_State) Number() protoreflect.EnumNumber

func (BatchTaskStateChangedEvent_State) String 

func (x BatchTaskStateChangedEvent_State) String() string

func (BatchTaskStateChangedEvent_State) Type 

func (BatchTaskStateChangedEvent_State) Type() protoreflect.EnumType

type BatchTaskStatus 

type BatchTaskStatus = batchpb.TaskStatus

type BatchTaskStatus_State 

type BatchTaskStatus_State = batchpb.TaskStatus_State

type CancelBatchOperationRequest 

type CancelBatchOperationRequest = longrunningpb.CancelOperationRequest

type CreateBatchJobRequest 

type CreateBatchJobRequest = batchpb.CreateJobRequest

type DeleteBatchJobOperation 

type DeleteBatchJobOperation interface {
	Name() string
	Wait(ctx context.Context, opts ...gax.CallOption) error
	Poll(ctx context.Context, opts ...gax.CallOption) error
	Metadata() (*batchpb.OperationMetadata, error)
	Done() bool
}

DeleteJobOperation manages a long-running operation from DeleteJob.

type DeleteBatchJobRequest 

type DeleteBatchJobRequest = batchpb.DeleteJobRequest

type DeleteBatchOperationRequest 

type DeleteBatchOperationRequest = longrunningpb.DeleteOperationRequest

type GetBatchJobRequest 

type GetBatchJobRequest = batchpb.GetJobRequest

type GetBatchTaskRequest 

type GetBatchTaskRequest = batchpb.GetTaskRequest

type ListBatchJobsRequest 

type ListBatchJobsRequest = batchpb.ListJobsRequest

type ListBatchTasksRequest 

type ListBatchTasksRequest = batchpb.ListTasksRequest

type NoBatchPageInfo 

type NoBatchPageInfo struct{}

NoBatchPageInfo is a no-op implementation of BatchPageInfo.

func (*NoBatchPageInfo) MaxSize 

func (*NoBatchPageInfo) MaxSize() int

MaxSize implements BatchPageInfo.

func (*NoBatchPageInfo) Remaining 

func (*NoBatchPageInfo) Remaining() int

Remaining implements BatchPageInfo.

func (*NoBatchPageInfo) Token 

func (*NoBatchPageInfo) Token() string

Token implements BatchPageInfo.

type NopBatchJobIterator 

type NopBatchJobIterator struct{}

NopBatchJobIterator is a no-op implementation of BatchJobIterator.

func (*NopBatchJobIterator) Next 

func (*NopBatchJobIterator) Next() (*batchpb.Job, error)

Next implements BatchJobIterator.

func (*NopBatchJobIterator) PageInfo 

func (*NopBatchJobIterator) PageInfo() BatchPageInfo

PageInfo implements BatchJobIterator.

type NopBatchServiceClient 

type NopBatchServiceClient struct{}

NopBatchServiceClient is a no-op implementation of BatchServiceClient.

func (*NopBatchServiceClient) CancelOperation 

func (*NopBatchServiceClient) CancelOperation(context.Context, *longrunningpb.CancelOperationRequest, ...gax.CallOption) error

CancelOperation implements BatchServiceClient.

func (*NopBatchServiceClient) CreateJob 

func (*NopBatchServiceClient) CreateJob(context.Context, *batchpb.CreateJobRequest, ...gax.CallOption) (*batchpb.Job, error)

CreateJob implements BatchServiceClient.

func (*NopBatchServiceClient) DeleteJob 

func (*NopBatchServiceClient) DeleteJob(context.Context, *batchpb.DeleteJobRequest, ...gax.CallOption) (DeleteBatchJobOperation, error)

DeleteJob implements BatchServiceClient.

func (*NopBatchServiceClient) DeleteJobOperation 

func (*NopBatchServiceClient) DeleteJobOperation(string) DeleteBatchJobOperation

DeleteJobOperation implements BatchServiceClient.

func (*NopBatchServiceClient) DeleteOperation 

func (*NopBatchServiceClient) DeleteOperation(context.Context, *longrunningpb.DeleteOperationRequest, ...gax.CallOption) error

DeleteOperation implements BatchServiceClient.

func (*NopBatchServiceClient) GetJob 

func (*NopBatchServiceClient) GetJob(context.Context, *batchpb.GetJobRequest, ...gax.CallOption) (*batchpb.Job, error)

GetJob implements BatchServiceClient.

func (*NopBatchServiceClient) GetTask 

func (*NopBatchServiceClient) GetTask(context.Context, *batchpb.GetTaskRequest, ...gax.CallOption) (*batchpb.Task, error)

GetTask implements BatchServiceClient.

func (*NopBatchServiceClient) ListJobs 

func (*NopBatchServiceClient) ListJobs(context.Context, *batchpb.ListJobsRequest, ...gax.CallOption) BatchJobIterator

ListJobs implements BatchServiceClient.

func (*NopBatchServiceClient) ListTasks 

func (*NopBatchServiceClient) ListTasks(context.Context, *batchpb.ListTasksRequest, ...gax.CallOption) BatchTaskIterator

ListTasks implements BatchServiceClient.

type NopBatchTaskIterator 

type NopBatchTaskIterator struct{}

NopBatchTaskIterator is a no-op implementation of BatchTaskIterator.

func (*NopBatchTaskIterator) Next 

func (*NopBatchTaskIterator) Next() (*batchpb.Task, error)

Next implements BatchTaskIterator.

func (*NopBatchTaskIterator) PageInfo 

func (*NopBatchTaskIterator) PageInfo() BatchPageInfo

PageInfo implements BatchTaskIterator.

type NopDeleteBatchJobOperation 

type NopDeleteBatchJobOperation struct{}

NopDeleteBatchJobOperation is a no-op implementation of DeleteBatchJobOperation.

func (*NopDeleteBatchJobOperation) Done 

func (*NopDeleteBatchJobOperation) Done() bool

Done implements DeleteBatchJobOperation.

func (*NopDeleteBatchJobOperation) Metadata 

func (*NopDeleteBatchJobOperation) Metadata() (*batchpb.OperationMetadata, error)

Metadata implements DeleteBatchJobOperation.

func (*NopDeleteBatchJobOperation) Name 

func (*NopDeleteBatchJobOperation) Name() string

Name implements DeleteBatchJobOperation.

func (*NopDeleteBatchJobOperation) Poll 

func (*NopDeleteBatchJobOperation) Poll(ctx context.Context, opts ...gax.CallOption) error

Poll implements DeleteBatchJobOperation.

func (*NopDeleteBatchJobOperation) Wait 

func (*NopDeleteBatchJobOperation) Wait(ctx context.Context, opts ...gax.CallOption) error

Wait implements DeleteBatchJobOperation.

type ParsedJobName 

type ParsedJobName struct {
	ProjectID string

	LocationID string

	JobID string
}

func ParseFullJobName 

func ParseFullJobName(s string) (ParsedJobName, error)

func ParseJobName 

func ParseJobName(s string) (ParsedJobName, error)

func (ParsedJobName) FullName 

func (n ParsedJobName) FullName() string

func (ParsedJobName) Key 

func (x ParsedJobName) Key() string

Key returns the key of the resource.

func (ParsedJobName) Name 

func (n ParsedJobName) Name() string

func (ParsedJobName) Parent 

func (x ParsedJobName) Parent() ParsedLocationName

Parent returns the parent resource.

func (ParsedJobName) String 

func (x ParsedJobName) String() string

String returns the string representation.

type ParsedLocationName 

type ParsedLocationName struct {
	ProjectID string

	LocationID string
}

func ParseFullLocationName 

func ParseFullLocationName(s string) (ParsedLocationName, error)

func ParseLocationName 

func ParseLocationName(s string) (ParsedLocationName, error)

func (ParsedLocationName) FullName 

func (n ParsedLocationName) FullName() string

func (ParsedLocationName) Key 

func (x ParsedLocationName) Key() string

Key returns the key of the resource.

func (ParsedLocationName) Name 

func (n ParsedLocationName) Name() string

func (ParsedLocationName) Parent 

func (x ParsedLocationName) Parent() ParsedProjectName

Parent returns the parent resource.

func (ParsedLocationName) String 

func (x ParsedLocationName) String() string

String returns the string representation.

type ParsedNetworkName 

type ParsedNetworkName struct {
	ProjectID string

	NetworkID string
}

func ParseFullNetworkName 

func ParseFullNetworkName(s string) (ParsedNetworkName, error)

func ParseNetworkName 

func ParseNetworkName(s string) (ParsedNetworkName, error)

func (ParsedNetworkName) FullName 

func (n ParsedNetworkName) FullName() string

func (ParsedNetworkName) Key 

func (x ParsedNetworkName) Key() string

Key returns the key of the resource.

func (ParsedNetworkName) Name 

func (n ParsedNetworkName) Name() string

func (ParsedNetworkName) Parent 

func (x ParsedNetworkName) Parent() ParsedProjectName

Parent returns the parent resource.

func (ParsedNetworkName) String 

func (x ParsedNetworkName) String() string

String returns the string representation.

type ParsedProjectName 

type ParsedProjectName struct {
	ProjectID string
}

func ParseFullProjectName 

func ParseFullProjectName(s string) (ParsedProjectName, error)

func ParseProjectName 

func ParseProjectName(s string) (ParsedProjectName, error)

func (ParsedProjectName) FullName 

func (n ParsedProjectName) FullName() string

func (ParsedProjectName) Key 

func (x ParsedProjectName) Key() string

Key returns the key of the resource.

func (ParsedProjectName) Name 

func (n ParsedProjectName) Name() string

func (ParsedProjectName) String 

func (x ParsedProjectName) String() string

String returns the string representation.

type ParsedRegionName 

type ParsedRegionName struct {
	ProjectID string

	RegionID string
}

func ParseFullRegionName 

func ParseFullRegionName(s string) (ParsedRegionName, error)

func ParseRegionName 

func ParseRegionName(s string) (ParsedRegionName, error)

func (ParsedRegionName) FullName 

func (n ParsedRegionName) FullName() string

func (ParsedRegionName) Key 

func (x ParsedRegionName) Key() string

Key returns the key of the resource.

func (ParsedRegionName) Name 

func (n ParsedRegionName) Name() string

func (ParsedRegionName) Parent 

func (x ParsedRegionName) Parent() ParsedProjectName

Parent returns the parent resource.

func (ParsedRegionName) String 

func (x ParsedRegionName) String() string

String returns the string representation.

type ParsedSubnetworkName 

type ParsedSubnetworkName struct {
	ProjectID string

	RegionID string

	SubnetworkID string
}

func ParseFullSubnetworkName 

func ParseFullSubnetworkName(s string) (ParsedSubnetworkName, error)

func ParseSubnetworkName 

func ParseSubnetworkName(s string) (ParsedSubnetworkName, error)

func (ParsedSubnetworkName) FullName 

func (n ParsedSubnetworkName) FullName() string

func (ParsedSubnetworkName) Key 

func (x ParsedSubnetworkName) Key() string

Key returns the key of the resource.

func (ParsedSubnetworkName) Name 

func (n ParsedSubnetworkName) Name() string

func (ParsedSubnetworkName) String 

func (x ParsedSubnetworkName) String() string

String returns the string representation.

type ParsedTaskGroupName 

type ParsedTaskGroupName struct {
	ProjectID string

	LocationID string

	JobID string

	TaskGroupID string
}

func ParseFullTaskGroupName 

func ParseFullTaskGroupName(s string) (ParsedTaskGroupName, error)

func ParseTaskGroupName 

func ParseTaskGroupName(s string) (ParsedTaskGroupName, error)

func (ParsedTaskGroupName) FullName 

func (n ParsedTaskGroupName) FullName() string

func (ParsedTaskGroupName) Key 

func (x ParsedTaskGroupName) Key() string

Key returns the key of the resource.

func (ParsedTaskGroupName) Name 

func (n ParsedTaskGroupName) Name() string

func (ParsedTaskGroupName) Parent 

func (x ParsedTaskGroupName) Parent() ParsedJobName

Parent returns the parent resource.

func (ParsedTaskGroupName) String 

func (x ParsedTaskGroupName) String() string

String returns the string representation.

type ParsedTaskName 

type ParsedTaskName struct {
	ProjectID string

	LocationID string

	JobID string

	TaskGroupID string

	TaskID string
}

func ParseFullTaskName 

func ParseFullTaskName(s string) (ParsedTaskName, error)

func ParseTaskName 

func ParseTaskName(s string) (ParsedTaskName, error)

func (ParsedTaskName) FullName 

func (n ParsedTaskName) FullName() string

func (ParsedTaskName) Key 

func (x ParsedTaskName) Key() string

Key returns the key of the resource.

func (ParsedTaskName) Name 

func (n ParsedTaskName) Name() string

func (ParsedTaskName) Parent 

func (x ParsedTaskName) Parent() ParsedTaskGroupName

Parent returns the parent resource.

func (ParsedTaskName) String 

func (x ParsedTaskName) String() string

String returns the string representation.

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.