batch_jobs

package
v2.87.1 Latest Latest
Warning

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

Go to latest
Published: Jun 5, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var BatchJobsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.batch_jobs.v1.BatchJobsService",
	HandlerType: (*BatchJobsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetBatchJob",
			Handler:    _BatchJobsService_GetBatchJob_Handler,
		},
		{
			MethodName: "ListBatchJobs",
			Handler:    _BatchJobsService_ListBatchJobs_Handler,
		},
		{
			MethodName: "CreateBatchJob",
			Handler:    _BatchJobsService_CreateBatchJob_Handler,
		},
		{
			MethodName: "DeleteBatchJob",
			Handler:    _BatchJobsService_DeleteBatchJob_Handler,
		},
		{
			MethodName: "UpdateBatchJobState",
			Handler:    _BatchJobsService_UpdateBatchJobState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/batch_jobs/v1/batch_jobs_v1.proto",
}

BatchJobsService_ServiceDesc is the grpc.ServiceDesc for BatchJobsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_strmprivacy_api_batch_jobs_v1_batch_jobs_v1_proto protoreflect.FileDescriptor

Functions

func RegisterBatchJobsServiceServer

func RegisterBatchJobsServiceServer(s grpc.ServiceRegistrar, srv BatchJobsServiceServer)

Types

type BatchJobsServiceClient

type BatchJobsServiceClient interface {
	GetBatchJob(ctx context.Context, in *GetBatchJobRequest, opts ...grpc.CallOption) (*GetBatchJobResponse, error)
	ListBatchJobs(ctx context.Context, in *ListBatchJobsRequest, opts ...grpc.CallOption) (*ListBatchJobsResponse, error)
	CreateBatchJob(ctx context.Context, in *CreateBatchJobRequest, opts ...grpc.CallOption) (*CreateBatchJobResponse, error)
	DeleteBatchJob(ctx context.Context, in *DeleteBatchJobRequest, opts ...grpc.CallOption) (*DeleteBatchJobResponse, error)
	UpdateBatchJobState(ctx context.Context, in *UpdateBatchJobStateRequest, opts ...grpc.CallOption) (*UpdateBatchJobStateResponse, error)
}

BatchJobsServiceClient is the client API for BatchJobsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type BatchJobsServiceServer

BatchJobsServiceServer is the server API for BatchJobsService service. All implementations should embed UnimplementedBatchJobsServiceServer for forward compatibility

type CreateBatchJobRequest

type CreateBatchJobRequest struct {

	// Deprecated: Do not use.
	BatchJob *v1.BatchJob `protobuf:"bytes,1,opt,name=batch_job,json=batchJob,proto3" json:"batch_job,omitempty"`
	// Todo: use [(validate.rules).message.required = true] instead once all apps use the wrapper
	// (-- api-linter: core::0133::request-required-fields=disabled
	//
	//	aip.dev/not-precedent: We really need this field to be required because
	//
	// it used to work up til now, and api-linter is complaining just for the fun of it. --)
	Job *v1.BatchJobWrapper `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBatchJobRequest) Descriptor deprecated

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

Deprecated: Use CreateBatchJobRequest.ProtoReflect.Descriptor instead.

func (*CreateBatchJobRequest) GetBatchJob deprecated

func (x *CreateBatchJobRequest) GetBatchJob() *v1.BatchJob

Deprecated: Do not use.

func (*CreateBatchJobRequest) GetJob added in v2.59.0

func (*CreateBatchJobRequest) ProtoMessage

func (*CreateBatchJobRequest) ProtoMessage()

func (*CreateBatchJobRequest) ProtoReflect

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

func (*CreateBatchJobRequest) Reset

func (x *CreateBatchJobRequest) Reset()

func (*CreateBatchJobRequest) String

func (x *CreateBatchJobRequest) String() string

type CreateBatchJobResponse

type CreateBatchJobResponse struct {

	// Deprecated: Do not use.
	BatchJob *v1.BatchJob        `protobuf:"bytes,1,opt,name=batch_job,json=batchJob,proto3" json:"batch_job,omitempty"`
	Job      *v1.BatchJobWrapper `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBatchJobResponse) Descriptor deprecated

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

Deprecated: Use CreateBatchJobResponse.ProtoReflect.Descriptor instead.

func (*CreateBatchJobResponse) GetBatchJob deprecated

func (x *CreateBatchJobResponse) GetBatchJob() *v1.BatchJob

Deprecated: Do not use.

func (*CreateBatchJobResponse) GetJob added in v2.59.0

func (*CreateBatchJobResponse) ProtoMessage

func (*CreateBatchJobResponse) ProtoMessage()

func (*CreateBatchJobResponse) ProtoReflect

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

func (*CreateBatchJobResponse) Reset

func (x *CreateBatchJobResponse) Reset()

func (*CreateBatchJobResponse) String

func (x *CreateBatchJobResponse) String() string

type DeleteBatchJobRequest

type DeleteBatchJobRequest struct {
	Ref *v1.BatchJobRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBatchJobRequest) Descriptor deprecated

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

Deprecated: Use DeleteBatchJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteBatchJobRequest) GetRef

func (x *DeleteBatchJobRequest) GetRef() *v1.BatchJobRef

func (*DeleteBatchJobRequest) ProtoMessage

func (*DeleteBatchJobRequest) ProtoMessage()

func (*DeleteBatchJobRequest) ProtoReflect

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

func (*DeleteBatchJobRequest) Reset

func (x *DeleteBatchJobRequest) Reset()

func (*DeleteBatchJobRequest) String

func (x *DeleteBatchJobRequest) String() string

type DeleteBatchJobResponse

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

func (*DeleteBatchJobResponse) Descriptor deprecated

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

Deprecated: Use DeleteBatchJobResponse.ProtoReflect.Descriptor instead.

func (*DeleteBatchJobResponse) ProtoMessage

func (*DeleteBatchJobResponse) ProtoMessage()

func (*DeleteBatchJobResponse) ProtoReflect

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

func (*DeleteBatchJobResponse) Reset

func (x *DeleteBatchJobResponse) Reset()

func (*DeleteBatchJobResponse) String

func (x *DeleteBatchJobResponse) String() string

type GetBatchJobRequest

type GetBatchJobRequest struct {
	Ref *v1.BatchJobRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBatchJobRequest) Descriptor deprecated

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

Deprecated: Use GetBatchJobRequest.ProtoReflect.Descriptor instead.

func (*GetBatchJobRequest) GetRef

func (x *GetBatchJobRequest) GetRef() *v1.BatchJobRef

func (*GetBatchJobRequest) ProtoMessage

func (*GetBatchJobRequest) ProtoMessage()

func (*GetBatchJobRequest) ProtoReflect

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

func (*GetBatchJobRequest) Reset

func (x *GetBatchJobRequest) Reset()

func (*GetBatchJobRequest) String

func (x *GetBatchJobRequest) String() string

type GetBatchJobResponse

type GetBatchJobResponse struct {

	// Deprecated: Do not use.
	BatchJob *v1.BatchJob        `protobuf:"bytes,1,opt,name=batch_job,json=batchJob,proto3" json:"batch_job,omitempty"`
	Job      *v1.BatchJobWrapper `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBatchJobResponse) Descriptor deprecated

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

Deprecated: Use GetBatchJobResponse.ProtoReflect.Descriptor instead.

func (*GetBatchJobResponse) GetBatchJob deprecated

func (x *GetBatchJobResponse) GetBatchJob() *v1.BatchJob

Deprecated: Do not use.

func (*GetBatchJobResponse) GetJob added in v2.59.0

func (x *GetBatchJobResponse) GetJob() *v1.BatchJobWrapper

func (*GetBatchJobResponse) ProtoMessage

func (*GetBatchJobResponse) ProtoMessage()

func (*GetBatchJobResponse) ProtoReflect

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

func (*GetBatchJobResponse) Reset

func (x *GetBatchJobResponse) Reset()

func (*GetBatchJobResponse) String

func (x *GetBatchJobResponse) String() string

type ListBatchJobsRequest

type ListBatchJobsRequest struct {

	// Deprecated: Do not use.
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBatchJobsRequest) Descriptor deprecated

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

Deprecated: Use ListBatchJobsRequest.ProtoReflect.Descriptor instead.

func (*ListBatchJobsRequest) GetBillingId deprecated

func (x *ListBatchJobsRequest) GetBillingId() string

Deprecated: Do not use.

func (*ListBatchJobsRequest) GetProjectId added in v2.38.0

func (x *ListBatchJobsRequest) GetProjectId() string

func (*ListBatchJobsRequest) ProtoMessage

func (*ListBatchJobsRequest) ProtoMessage()

func (*ListBatchJobsRequest) ProtoReflect

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

func (*ListBatchJobsRequest) Reset

func (x *ListBatchJobsRequest) Reset()

func (*ListBatchJobsRequest) String

func (x *ListBatchJobsRequest) String() string

type ListBatchJobsResponse

type ListBatchJobsResponse struct {

	// Deprecated: Do not use.
	BatchJobs []*v1.BatchJob        `protobuf:"bytes,1,rep,name=batch_jobs,json=batchJobs,proto3" json:"batch_jobs,omitempty"`
	Jobs      []*v1.BatchJobWrapper `protobuf:"bytes,2,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

(-- api-linter: core::0132::response-unknown-fields=disabled

aip.dev/not-precedent: we prefer this approach over creating a new service --)

func (*ListBatchJobsResponse) Descriptor deprecated

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

Deprecated: Use ListBatchJobsResponse.ProtoReflect.Descriptor instead.

func (*ListBatchJobsResponse) GetBatchJobs deprecated

func (x *ListBatchJobsResponse) GetBatchJobs() []*v1.BatchJob

Deprecated: Do not use.

func (*ListBatchJobsResponse) GetJobs added in v2.59.0

func (x *ListBatchJobsResponse) GetJobs() []*v1.BatchJobWrapper

func (*ListBatchJobsResponse) ProtoMessage

func (*ListBatchJobsResponse) ProtoMessage()

func (*ListBatchJobsResponse) ProtoReflect

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

func (*ListBatchJobsResponse) Reset

func (x *ListBatchJobsResponse) Reset()

func (*ListBatchJobsResponse) String

func (x *ListBatchJobsResponse) String() string

type UnimplementedBatchJobsServiceServer

type UnimplementedBatchJobsServiceServer struct {
}

UnimplementedBatchJobsServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedBatchJobsServiceServer) CreateBatchJob

func (UnimplementedBatchJobsServiceServer) DeleteBatchJob

func (UnimplementedBatchJobsServiceServer) GetBatchJob

func (UnimplementedBatchJobsServiceServer) ListBatchJobs

func (UnimplementedBatchJobsServiceServer) UpdateBatchJobState added in v2.12.0

type UnsafeBatchJobsServiceServer

type UnsafeBatchJobsServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeBatchJobsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BatchJobsServiceServer will result in compilation errors.

type UpdateBatchJobStateRequest added in v2.12.0

type UpdateBatchJobStateRequest struct {
	Ref           *v1.BatchJobRef   `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	BatchJobState *v1.BatchJobState `protobuf:"bytes,2,opt,name=batch_job_state,json=batchJobState,proto3" json:"batch_job_state,omitempty"`
	// contains filtered or unexported fields
}

(-- api-linter: core::0134::request-mask-required=disabled

aip.dev/not-precedent: This RPC only updates one field. --)

func (*UpdateBatchJobStateRequest) Descriptor deprecated added in v2.12.0

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

Deprecated: Use UpdateBatchJobStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateBatchJobStateRequest) GetBatchJobState added in v2.12.0

func (x *UpdateBatchJobStateRequest) GetBatchJobState() *v1.BatchJobState

func (*UpdateBatchJobStateRequest) GetRef added in v2.12.0

func (*UpdateBatchJobStateRequest) ProtoMessage added in v2.12.0

func (*UpdateBatchJobStateRequest) ProtoMessage()

func (*UpdateBatchJobStateRequest) ProtoReflect added in v2.12.0

func (*UpdateBatchJobStateRequest) Reset added in v2.12.0

func (x *UpdateBatchJobStateRequest) Reset()

func (*UpdateBatchJobStateRequest) String added in v2.12.0

func (x *UpdateBatchJobStateRequest) String() string

type UpdateBatchJobStateResponse added in v2.12.0

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

func (*UpdateBatchJobStateResponse) Descriptor deprecated added in v2.12.0

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

Deprecated: Use UpdateBatchJobStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateBatchJobStateResponse) ProtoMessage added in v2.12.0

func (*UpdateBatchJobStateResponse) ProtoMessage()

func (*UpdateBatchJobStateResponse) ProtoReflect added in v2.12.0

func (*UpdateBatchJobStateResponse) Reset added in v2.12.0

func (x *UpdateBatchJobStateResponse) Reset()

func (*UpdateBatchJobStateResponse) String added in v2.12.0

func (x *UpdateBatchJobStateResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL