batch_jobs

package
v2.13.0 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	BatchJobStateType_name = map[int32]string{
		0: "BATCH_JOB_STATE_TYPE_UNSPECIFIED",
		1: "PENDING",
		2: "STARTED",
		3: "ERROR_STARTING",
		4: "RUNNING",
		5: "FINISHED",
		6: "ERROR",
	}
	BatchJobStateType_value = map[string]int32{
		"BATCH_JOB_STATE_TYPE_UNSPECIFIED": 0,
		"PENDING":                          1,
		"STARTED":                          2,
		"ERROR_STARTING":                   3,
		"RUNNING":                          4,
		"FINISHED":                         5,
		"ERROR":                            6,
	}
)

Enum value maps for BatchJobStateType.

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 AwsS3BucketLocation added in v2.12.0 

type AwsS3BucketLocation struct {

	// (-- api-linter: core::0122::name-suffix=disabled
	//     aip.dev/not-precedent: We refer to a bucket name. --)
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// The credentials that are to be used to access the bucket.
	Credentials string `protobuf:"bytes,2,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// The ARN of the role to assume.
	//If present, start an AssumeRole flow to get temporary credentials in another AWS account.
	//This is used when the customer has a separate users account.
	//Default there is no assumed role.
	AssumeRoleArn string `protobuf:"bytes,3,opt,name=assume_role_arn,json=assumeRoleArn,proto3" json:"assume_role_arn,omitempty"`
	// If omitted, files are read from the root of the bucket.
	PathPrefix string `protobuf:"bytes,4,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
	// (-- api-linter: core::0122::name-suffix=disabled
	//     aip.dev/not-precedent: This is the object name without the path prefix. --)
	// If omitted, all files in the specified path_prefix are read. In the case of writing, the output file names match
	// the input file names, with a suffix indicating the type of data (encrypted, keys, decrypted-1-2-3).
	// If present, this is the only file that is read. In the case of writing, this name is the explicit file name.
	FileName string `protobuf:"bytes,5,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use AwsS3BucketLocation.ProtoReflect.Descriptor instead.

func (*AwsS3BucketLocation) GetAssumeRoleArn added in v2.12.0 

func (x *AwsS3BucketLocation) GetAssumeRoleArn() string

func (*AwsS3BucketLocation) GetBucketName added in v2.12.0 

func (x *AwsS3BucketLocation) GetBucketName() string

func (*AwsS3BucketLocation) GetCredentials added in v2.12.0 

func (x *AwsS3BucketLocation) GetCredentials() string

func (*AwsS3BucketLocation) GetFileName added in v2.12.0 

func (x *AwsS3BucketLocation) GetFileName() string

func (*AwsS3BucketLocation) GetPathPrefix added in v2.12.0 

func (x *AwsS3BucketLocation) GetPathPrefix() string

func (*AwsS3BucketLocation) ProtoMessage added in v2.12.0 

func (*AwsS3BucketLocation) ProtoMessage()

func (*AwsS3BucketLocation) ProtoReflect added in v2.12.0 

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

func (*AwsS3BucketLocation) Reset added in v2.12.0 

func (x *AwsS3BucketLocation) Reset()

func (*AwsS3BucketLocation) String added in v2.12.0 

func (x *AwsS3BucketLocation) String() string

type BatchJob added in v2.12.0 

type BatchJob struct {
	Ref                *BatchJobRef         `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	States             []*BatchJobState     `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
	SourceData         *DataConnector       `protobuf:"bytes,3,opt,name=source_data,json=sourceData,proto3" json:"source_data,omitempty"`
	Consent            *ConsentConfig       `protobuf:"bytes,4,opt,name=consent,proto3" json:"consent,omitempty"`
	Encryption         *EncryptionConfig    `protobuf:"bytes,5,opt,name=encryption,proto3" json:"encryption,omitempty"`
	EventContractRef   *v1.EventContractRef `protobuf:"bytes,6,opt,name=event_contract_ref,json=eventContractRef,proto3" json:"event_contract_ref,omitempty"`
	EncryptedData      *EncryptedData       `protobuf:"bytes,7,opt,name=encrypted_data,json=encryptedData,proto3" json:"encrypted_data,omitempty"`
	EncryptionKeysData *EncryptionKeysData  `protobuf:"bytes,8,opt,name=encryption_keys_data,json=encryptionKeysData,proto3" json:"encryption_keys_data,omitempty"`
	DerivedData        []*DerivedData       `protobuf:"bytes,9,rep,name=derived_data,json=derivedData,proto3" json:"derived_data,omitempty"`
	// contains filtered or unexported fields
}

Batch Jobs Currently we only support: - CSV as DataFormat type - a clean database for every batch job - CSV files with a header row, because the header is needed to get the field names

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

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

Deprecated: Use BatchJob.ProtoReflect.Descriptor instead.

func (*BatchJob) GetConsent added in v2.12.0 

func (x *BatchJob) GetConsent() *ConsentConfig

func (*BatchJob) GetDerivedData added in v2.12.0 

func (x *BatchJob) GetDerivedData() []*DerivedData

func (*BatchJob) GetEncryptedData added in v2.12.0 

func (x *BatchJob) GetEncryptedData() *EncryptedData

func (*BatchJob) GetEncryption added in v2.12.0 

func (x *BatchJob) GetEncryption() *EncryptionConfig

func (*BatchJob) GetEncryptionKeysData added in v2.12.0 

func (x *BatchJob) GetEncryptionKeysData() *EncryptionKeysData

func (*BatchJob) GetEventContractRef added in v2.12.0 

func (x *BatchJob) GetEventContractRef() *v1.EventContractRef

func (*BatchJob) GetRef added in v2.12.0 

func (x *BatchJob) GetRef() *BatchJobRef

func (*BatchJob) GetSourceData added in v2.12.0 

func (x *BatchJob) GetSourceData() *DataConnector

func (*BatchJob) GetStates added in v2.12.0 

func (x *BatchJob) GetStates() []*BatchJobState

func (*BatchJob) ProtoMessage added in v2.12.0 

func (*BatchJob) ProtoMessage()

func (*BatchJob) ProtoReflect added in v2.12.0 

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

func (*BatchJob) Reset added in v2.12.0 

func (x *BatchJob) Reset()

func (*BatchJob) String added in v2.12.0 

func (x *BatchJob) String() string

type BatchJobRef added in v2.12.0 

type BatchJobRef struct {
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	// the UUIDv4 of the job
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use BatchJobRef.ProtoReflect.Descriptor instead.

func (*BatchJobRef) GetBillingId added in v2.12.0 

func (x *BatchJobRef) GetBillingId() string

func (*BatchJobRef) GetId added in v2.12.0 

func (x *BatchJobRef) GetId() string

func (*BatchJobRef) ProtoMessage added in v2.12.0 

func (*BatchJobRef) ProtoMessage()

func (*BatchJobRef) ProtoReflect added in v2.12.0 

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

func (*BatchJobRef) Reset added in v2.12.0 

func (x *BatchJobRef) Reset()

func (*BatchJobRef) String added in v2.12.0 

func (x *BatchJobRef) String() string

type BatchJobState added in v2.12.0 

type BatchJobState struct {
	StateTime    *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=state_time,json=stateTime,proto3" json:"state_time,omitempty"`
	State        BatchJobStateType      `protobuf:"varint,2,opt,name=state,proto3,enum=strmprivacy.api.batch_jobs.v1.BatchJobStateType" json:"state,omitempty"`
	ErrorMessage string                 `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use BatchJobState.ProtoReflect.Descriptor instead.

func (*BatchJobState) GetErrorMessage added in v2.12.0 

func (x *BatchJobState) GetErrorMessage() string

func (*BatchJobState) GetState added in v2.12.0 

func (x *BatchJobState) GetState() BatchJobStateType

func (*BatchJobState) GetStateTime added in v2.12.0 

func (x *BatchJobState) GetStateTime() *timestamppb.Timestamp

func (*BatchJobState) ProtoMessage added in v2.12.0 

func (*BatchJobState) ProtoMessage()

func (*BatchJobState) ProtoReflect added in v2.12.0 

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

func (*BatchJobState) Reset added in v2.12.0 

func (x *BatchJobState) Reset()

func (*BatchJobState) String added in v2.12.0 

func (x *BatchJobState) String() string

type BatchJobStateType added in v2.12.0 

type BatchJobStateType int32
const (
	BatchJobStateType_BATCH_JOB_STATE_TYPE_UNSPECIFIED BatchJobStateType = 0
	BatchJobStateType_PENDING                          BatchJobStateType = 1
	BatchJobStateType_STARTED                          BatchJobStateType = 2
	BatchJobStateType_ERROR_STARTING                   BatchJobStateType = 3
	BatchJobStateType_RUNNING                          BatchJobStateType = 4
	BatchJobStateType_FINISHED                         BatchJobStateType = 5
	BatchJobStateType_ERROR                            BatchJobStateType = 6
)

func (BatchJobStateType) Descriptor added in v2.12.0 

func (BatchJobStateType) Descriptor() protoreflect.EnumDescriptor

func (BatchJobStateType) Enum added in v2.12.0 

func (x BatchJobStateType) Enum() *BatchJobStateType

func (BatchJobStateType) EnumDescriptor deprecated added in v2.12.0 

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

Deprecated: Use BatchJobStateType.Descriptor instead.

func (BatchJobStateType) Number added in v2.12.0 

func (x BatchJobStateType) Number() protoreflect.EnumNumber

func (BatchJobStateType) String added in v2.12.0 

func (x BatchJobStateType) String() string

func (BatchJobStateType) Type added in v2.12.0 

func (BatchJobStateType) Type() protoreflect.EnumType

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 ConsentConfig added in v2.12.0 

type ConsentConfig struct {
	DefaultConsentLevels  []int32                `` /* 131-byte string literal not displayed */
	ConsentLevelExtractor *ConsentLevelExtractor `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ConsentConfig.ProtoReflect.Descriptor instead.

func (*ConsentConfig) GetConsentLevelExtractor added in v2.12.0 

func (x *ConsentConfig) GetConsentLevelExtractor() *ConsentLevelExtractor

func (*ConsentConfig) GetDefaultConsentLevels added in v2.12.0 

func (x *ConsentConfig) GetDefaultConsentLevels() []int32

func (*ConsentConfig) ProtoMessage added in v2.12.0 

func (*ConsentConfig) ProtoMessage()

func (*ConsentConfig) ProtoReflect added in v2.12.0 

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

func (*ConsentConfig) Reset added in v2.12.0 

func (x *ConsentConfig) Reset()

func (*ConsentConfig) String added in v2.12.0 

func (x *ConsentConfig) String() string

type ConsentLevelExtractor added in v2.12.0 

type ConsentLevelExtractor struct {
	Field         string                       `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	FieldPatterns map[string]*v1.ConsentLevels `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ConsentLevelExtractor.ProtoReflect.Descriptor instead.

func (*ConsentLevelExtractor) GetField added in v2.12.0 

func (x *ConsentLevelExtractor) GetField() string

func (*ConsentLevelExtractor) GetFieldPatterns added in v2.12.0 

func (x *ConsentLevelExtractor) GetFieldPatterns() map[string]*v1.ConsentLevels

func (*ConsentLevelExtractor) ProtoMessage added in v2.12.0 

func (*ConsentLevelExtractor) ProtoMessage()

func (*ConsentLevelExtractor) ProtoReflect added in v2.12.0 

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

func (*ConsentLevelExtractor) Reset added in v2.12.0 

func (x *ConsentLevelExtractor) Reset()

func (*ConsentLevelExtractor) String added in v2.12.0 

func (x *ConsentLevelExtractor) String() string

type CreateBatchJobRequest 

type CreateBatchJobRequest struct {
	BatchJob *BatchJob `protobuf:"bytes,1,opt,name=batch_job,json=batchJob,proto3" json:"batch_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 

func (x *CreateBatchJobRequest) GetBatchJob() *BatchJob

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 {
	BatchJob *BatchJob `protobuf:"bytes,1,opt,name=batch_job,json=batchJob,proto3" json:"batch_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 

func (x *CreateBatchJobResponse) GetBatchJob() *BatchJob

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 CsvConfig added in v2.12.0 

type CsvConfig struct {
	Charset string `protobuf:"bytes,1,opt,name=charset,proto3" json:"charset,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use CsvConfig.ProtoReflect.Descriptor instead.

func (*CsvConfig) GetCharset added in v2.12.0 

func (x *CsvConfig) GetCharset() string

func (*CsvConfig) ProtoMessage added in v2.12.0 

func (*CsvConfig) ProtoMessage()

func (*CsvConfig) ProtoReflect added in v2.12.0 

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

func (*CsvConfig) Reset added in v2.12.0 

func (x *CsvConfig) Reset()

func (*CsvConfig) String added in v2.12.0 

func (x *CsvConfig) String() string

type DataConnector added in v2.12.0 

type DataConnector struct {

	// Types that are assignable to Location:
	//	*DataConnector_S3Bucket
	Location isDataConnector_Location `protobuf_oneof:"location"`
	// Types that are assignable to DataType:
	//	*DataConnector_Csv
	DataType isDataConnector_DataType `protobuf_oneof:"data_type"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use DataConnector.ProtoReflect.Descriptor instead.

func (*DataConnector) GetCsv added in v2.12.0 

func (x *DataConnector) GetCsv() *CsvConfig

func (*DataConnector) GetDataType added in v2.12.0 

func (m *DataConnector) GetDataType() isDataConnector_DataType

func (*DataConnector) GetLocation added in v2.12.0 

func (m *DataConnector) GetLocation() isDataConnector_Location

func (*DataConnector) GetS3Bucket added in v2.12.0 

func (x *DataConnector) GetS3Bucket() *AwsS3BucketLocation

func (*DataConnector) ProtoMessage added in v2.12.0 

func (*DataConnector) ProtoMessage()

func (*DataConnector) ProtoReflect added in v2.12.0 

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

func (*DataConnector) Reset added in v2.12.0 

func (x *DataConnector) Reset()

func (*DataConnector) String added in v2.12.0 

func (x *DataConnector) String() string

type DataConnector_Csv added in v2.12.0 

type DataConnector_Csv struct {
	Csv *CsvConfig `protobuf:"bytes,5,opt,name=csv,proto3,oneof"`
}

type DataConnector_S3Bucket added in v2.12.0 

type DataConnector_S3Bucket struct {
	S3Bucket *AwsS3BucketLocation `protobuf:"bytes,1,opt,name=s3_bucket,json=s3Bucket,proto3,oneof"`
}

type DeleteBatchJobRequest 

type DeleteBatchJobRequest struct {
	Ref *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() *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 DerivedData added in v2.12.0 

type DerivedData struct {
	Target           *DataConnector      `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	ConsentLevels    []int32             `protobuf:"varint,2,rep,packed,name=consent_levels,json=consentLevels,proto3" json:"consent_levels,omitempty"`
	ConsentLevelType v1.ConsentLevelType `` /* 162-byte string literal not displayed */
	MaskedFields     *v1.MaskedFields    `protobuf:"bytes,4,opt,name=masked_fields,json=maskedFields,proto3" json:"masked_fields,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use DerivedData.ProtoReflect.Descriptor instead.

func (*DerivedData) GetConsentLevelType added in v2.12.0 

func (x *DerivedData) GetConsentLevelType() v1.ConsentLevelType

func (*DerivedData) GetConsentLevels added in v2.12.0 

func (x *DerivedData) GetConsentLevels() []int32

func (*DerivedData) GetMaskedFields added in v2.12.0 

func (x *DerivedData) GetMaskedFields() *v1.MaskedFields

func (*DerivedData) GetTarget added in v2.12.0 

func (x *DerivedData) GetTarget() *DataConnector

func (*DerivedData) ProtoMessage added in v2.12.0 

func (*DerivedData) ProtoMessage()

func (*DerivedData) ProtoReflect added in v2.12.0 

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

func (*DerivedData) Reset added in v2.12.0 

func (x *DerivedData) Reset()

func (*DerivedData) String added in v2.12.0 

func (x *DerivedData) String() string

type EncryptedData added in v2.12.0 

type EncryptedData struct {
	Target *DataConnector `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use EncryptedData.ProtoReflect.Descriptor instead.

func (*EncryptedData) GetTarget added in v2.12.0 

func (x *EncryptedData) GetTarget() *DataConnector

func (*EncryptedData) ProtoMessage added in v2.12.0 

func (*EncryptedData) ProtoMessage()

func (*EncryptedData) ProtoReflect added in v2.12.0 

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

func (*EncryptedData) Reset added in v2.12.0 

func (x *EncryptedData) Reset()

func (*EncryptedData) String added in v2.12.0 

func (x *EncryptedData) String() string

type EncryptionConfig added in v2.12.0 

type EncryptionConfig struct {
	TimestampConfig *TimestampConfig `protobuf:"bytes,1,opt,name=timestamp_config,json=timestampConfig,proto3" json:"timestamp_config,omitempty"`
	BatchJobGroupId string           `protobuf:"bytes,2,opt,name=batch_job_group_id,json=batchJobGroupId,proto3" json:"batch_job_group_id,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use EncryptionConfig.ProtoReflect.Descriptor instead.

func (*EncryptionConfig) GetBatchJobGroupId added in v2.12.0 

func (x *EncryptionConfig) GetBatchJobGroupId() string

func (*EncryptionConfig) GetTimestampConfig added in v2.12.0 

func (x *EncryptionConfig) GetTimestampConfig() *TimestampConfig

func (*EncryptionConfig) ProtoMessage added in v2.12.0 

func (*EncryptionConfig) ProtoMessage()

func (*EncryptionConfig) ProtoReflect added in v2.12.0 

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

func (*EncryptionConfig) Reset added in v2.12.0 

func (x *EncryptionConfig) Reset()

func (*EncryptionConfig) String added in v2.12.0 

func (x *EncryptionConfig) String() string

type EncryptionKeysData added in v2.12.0 

type EncryptionKeysData struct {
	Target *DataConnector `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use EncryptionKeysData.ProtoReflect.Descriptor instead.

func (*EncryptionKeysData) GetTarget added in v2.12.0 

func (x *EncryptionKeysData) GetTarget() *DataConnector

func (*EncryptionKeysData) ProtoMessage added in v2.12.0 

func (*EncryptionKeysData) ProtoMessage()

func (*EncryptionKeysData) ProtoReflect added in v2.12.0 

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

func (*EncryptionKeysData) Reset added in v2.12.0 

func (x *EncryptionKeysData) Reset()

func (*EncryptionKeysData) String added in v2.12.0 

func (x *EncryptionKeysData) String() string

type GetBatchJobRequest 

type GetBatchJobRequest struct {
	Ref *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() *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 {
	BatchJob *BatchJob `protobuf:"bytes,1,opt,name=batch_job,json=batchJob,proto3" json:"batch_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 

func (x *GetBatchJobResponse) GetBatchJob() *BatchJob

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 {
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_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 

func (x *ListBatchJobsRequest) GetBillingId() 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 {
	BatchJobs []*BatchJob `protobuf:"bytes,1,rep,name=batch_jobs,json=batchJobs,proto3" json:"batch_jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBatchJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListBatchJobsResponse.ProtoReflect.Descriptor instead.

func (*ListBatchJobsResponse) GetBatchJobs 

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

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 TimestampConfig added in v2.12.0 

type TimestampConfig struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// Java Time Format template, see https://docs.oracle.com/javase/8/docs/api/java/time/format/DateTimeFormatter.html
	Format          string             `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	DefaultTimeZone *datetime.TimeZone `protobuf:"bytes,3,opt,name=default_time_zone,json=defaultTimeZone,proto3" json:"default_time_zone,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use TimestampConfig.ProtoReflect.Descriptor instead.

func (*TimestampConfig) GetDefaultTimeZone added in v2.12.0 

func (x *TimestampConfig) GetDefaultTimeZone() *datetime.TimeZone

func (*TimestampConfig) GetField added in v2.12.0 

func (x *TimestampConfig) GetField() string

func (*TimestampConfig) GetFormat added in v2.12.0 

func (x *TimestampConfig) GetFormat() string

func (*TimestampConfig) ProtoMessage added in v2.12.0 

func (*TimestampConfig) ProtoMessage()

func (*TimestampConfig) ProtoReflect added in v2.12.0 

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

func (*TimestampConfig) Reset added in v2.12.0 

func (x *TimestampConfig) Reset()

func (*TimestampConfig) String added in v2.12.0 

func (x *TimestampConfig) 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           *BatchJobRef   `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	BatchJobState *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() *BatchJobState

func (*UpdateBatchJobStateRequest) GetRef added in v2.12.0 

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