batch_jobs

package
v2.65.0 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2022 License: Apache-2.0 Imports: 10 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.

func NewBatchJobsServiceClient 

func NewBatchJobsServiceClient(cc grpc.ClientConnInterface) BatchJobsServiceClient

type BatchJobsServiceServer 

type BatchJobsServiceServer interface {
	GetBatchJob(context.Context, *GetBatchJobRequest) (*GetBatchJobResponse, error)
	ListBatchJobs(context.Context, *ListBatchJobsRequest) (*ListBatchJobsResponse, error)
	CreateBatchJob(context.Context, *CreateBatchJobRequest) (*CreateBatchJobResponse, error)
	DeleteBatchJob(context.Context, *DeleteBatchJobRequest) (*DeleteBatchJobResponse, error)
	UpdateBatchJobState(context.Context, *UpdateBatchJobStateRequest) (*UpdateBatchJobStateResponse, error)
	// contains filtered or unexported methods
}

BatchJobsServiceServer is the server API for BatchJobsService service. All implementations must 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"`
	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 (x *CreateBatchJobRequest) GetJob() *v1.BatchJobWrapper

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 (x *CreateBatchJobResponse) GetJob() *v1.BatchJobWrapper

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 must be embedded to have forward compatible implementations.

func (UnimplementedBatchJobsServiceServer) CreateBatchJob 

func (UnimplementedBatchJobsServiceServer) CreateBatchJob(context.Context, *CreateBatchJobRequest) (*CreateBatchJobResponse, error)

func (UnimplementedBatchJobsServiceServer) DeleteBatchJob 

func (UnimplementedBatchJobsServiceServer) DeleteBatchJob(context.Context, *DeleteBatchJobRequest) (*DeleteBatchJobResponse, error)

func (UnimplementedBatchJobsServiceServer) GetBatchJob 

func (UnimplementedBatchJobsServiceServer) GetBatchJob(context.Context, *GetBatchJobRequest) (*GetBatchJobResponse, error)

func (UnimplementedBatchJobsServiceServer) ListBatchJobs 

func (UnimplementedBatchJobsServiceServer) ListBatchJobs(context.Context, *ListBatchJobsRequest) (*ListBatchJobsResponse, error)

func (UnimplementedBatchJobsServiceServer) UpdateBatchJobState added in v2.12.0 

func (UnimplementedBatchJobsServiceServer) UpdateBatchJobState(context.Context, *UpdateBatchJobStateRequest) (*UpdateBatchJobStateResponse, error)

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 (x *UpdateBatchJobStateRequest) GetRef() *v1.BatchJobRef

func (*UpdateBatchJobStateRequest) ProtoMessage added in v2.12.0 

func (*UpdateBatchJobStateRequest) ProtoMessage()

func (*UpdateBatchJobStateRequest) ProtoReflect added in v2.12.0 

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

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 (x *UpdateBatchJobStateResponse) ProtoReflect() protoreflect.Message

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

Source Files

View all Source files

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.