batch_jobs

package
v3.0.1 Latest Latest
Warning

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

 Go to latest Published: Jun 22, 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.

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)
}

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 

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 

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 

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 

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 

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) 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 

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 

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 

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

Deprecated: Use UpdateBatchJobStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateBatchJobStateRequest) GetBatchJobState 

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

func (*UpdateBatchJobStateRequest) GetRef 

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

func (*UpdateBatchJobStateRequest) ProtoMessage 

func (*UpdateBatchJobStateRequest) ProtoMessage()

func (*UpdateBatchJobStateRequest) ProtoReflect 

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

func (*UpdateBatchJobStateRequest) Reset 

func (x *UpdateBatchJobStateRequest) Reset()

func (*UpdateBatchJobStateRequest) String 

func (x *UpdateBatchJobStateRequest) String() string

type UpdateBatchJobStateResponse 

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

func (*UpdateBatchJobStateResponse) Descriptor deprecated 

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

Deprecated: Use UpdateBatchJobStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateBatchJobStateResponse) ProtoMessage 

func (*UpdateBatchJobStateResponse) ProtoMessage()

func (*UpdateBatchJobStateResponse) ProtoReflect 

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

func (*UpdateBatchJobStateResponse) Reset 

func (x *UpdateBatchJobStateResponse) Reset()

func (*UpdateBatchJobStateResponse) String 

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.