entities

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: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	UserRole_name = map[int32]string{
		0: "USER_ROLE_UNSPECIFIED",
		1: "ADMIN",
		2: "PROJECT_ADMIN",
		3: "APPROVER",
		4: "MEMBER",
	}
	UserRole_value = map[string]int32{
		"USER_ROLE_UNSPECIFIED": 0,
		"ADMIN":                 1,
		"PROJECT_ADMIN":         2,
		"APPROVER":              3,
		"MEMBER":                4,
	}
)

Enum value maps for UserRole.

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 (
	ConsentLevelType_name = map[int32]string{
		0: "CONSENT_LEVEL_TYPE_UNSPECIFIED",
		1: "CUMULATIVE",
		2: "GRANULAR",
	}
	ConsentLevelType_value = map[string]int32{
		"CONSENT_LEVEL_TYPE_UNSPECIFIED": 0,
		"CUMULATIVE":                     1,
		"GRANULAR":                       2,
	}
)

Enum value maps for ConsentLevelType.

View Source
var (
	SinkType_name = map[int32]string{
		0: "SINK_TYPE_UNSPECIFIED",
		1: "S3",
		2: "GCLOUD",
	}
	SinkType_value = map[string]int32{
		"SINK_TYPE_UNSPECIFIED": 0,
		"S3":                    1,
		"GCLOUD":                2,
	}
)

Enum value maps for SinkType.

View Source
var (
	AuthMechanism_name = map[int32]string{
		0: "AUTH_MECHANISM_UNSPECIFIED",
		1: "SASL_PLAIN",
		2: "SASL_SSL",
	}
	AuthMechanism_value = map[string]int32{
		"AUTH_MECHANISM_UNSPECIFIED": 0,
		"SASL_PLAIN":                 1,
		"SASL_SSL":                   2,
	}
)

Enum value maps for AuthMechanism.

View Source
var (
	SchemaType_name = map[int32]string{
		0: "SCHEMA_TYPE_UNSPECIFIED",
		1: "AVRO",
		2: "JSONSCHEMA",
	}
	SchemaType_value = map[string]int32{
		"SCHEMA_TYPE_UNSPECIFIED": 0,
		"AVRO":                    1,
		"JSONSCHEMA":              2,
	}
)

Enum value maps for SchemaType.

View Source
var (
	SimpleSchemaNodeType_name = map[int32]string{
		0:  "SIMPLE_SCHEMA_NODE_TYPE_UNSPECIFIED",
		1:  "STRING",
		2:  "BOOLEAN",
		3:  "FLOAT",
		4:  "INTEGER",
		5:  "LONG",
		10: "NODE",
	}
	SimpleSchemaNodeType_value = map[string]int32{
		"SIMPLE_SCHEMA_NODE_TYPE_UNSPECIFIED": 0,
		"STRING":                              1,
		"BOOLEAN":                             2,
		"FLOAT":                               3,
		"INTEGER":                             4,
		"LONG":                                5,
		"NODE":                                10,
	}
)

Enum value maps for SimpleSchemaNodeType.

View Source
var (
	FilterPublicPrivate_name = map[int32]string{
		0: "FILTER_PUBLIC_PRIVATE_UNSPECIFIED",
		1: "ONLY_PUBLIC",
		2: "ONLY_PRIVATE",
	}
	FilterPublicPrivate_value = map[string]int32{
		"FILTER_PUBLIC_PRIVATE_UNSPECIFIED": 0,
		"ONLY_PUBLIC":                       1,
		"ONLY_PRIVATE":                      2,
	}
)

Enum value maps for FilterPublicPrivate.

View Source
var (
	StatisticalDataType_name = map[int32]string{
		0: "STATISTICAL_DATA_TYPE_UNSPECIFIED",
		1: "NOMINAL",
		2: "ORDINAL",
		3: "NUMERICAL",
	}
	StatisticalDataType_value = map[string]int32{
		"STATISTICAL_DATA_TYPE_UNSPECIFIED": 0,
		"NOMINAL":                           1,
		"ORDINAL":                           2,
		"NUMERICAL":                         3,
	}
)

Enum value maps for StatisticalDataType.

View Source
var (
	SubscriptionPlan_name = map[int32]string{
		0: "SUBSCRIPTION_PLAN_UNSPECIFIED",
		1: "FREE",
		2: "BUSINESS",
		3: "SELF_HOSTED",
		4: "AWS_MARKETPLACE_PAYG",
		5: "AWS_MARKETPLACE_BYOL",
	}
	SubscriptionPlan_value = map[string]int32{
		"SUBSCRIPTION_PLAN_UNSPECIFIED": 0,
		"FREE":                          1,
		"BUSINESS":                      2,
		"SELF_HOSTED":                   3,
		"AWS_MARKETPLACE_PAYG":          4,
		"AWS_MARKETPLACE_BYOL":          5,
	}
)

Enum value maps for SubscriptionPlan.

View Source
var (
	DatabaseType_name = map[int32]string{
		0: "DATABASE_TYPE_UNSPECIFIED",
		1: "POSTGRES",
		2: "MYSQL",
		3: "BIGQUERY",
		4: "SNOWFLAKE",
	}
	DatabaseType_value = map[string]int32{
		"DATABASE_TYPE_UNSPECIFIED": 0,
		"POSTGRES":                  1,
		"MYSQL":                     2,
		"BIGQUERY":                  3,
		"SNOWFLAKE":                 4,
	}
)

Enum value maps for DatabaseType.

View Source
var (
	Policy_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "STATE_DRAFT",
		2: "STATE_ACTIVE",
		3: "STATE_ARCHIVED",
	}
	Policy_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"STATE_DRAFT":       1,
		"STATE_ACTIVE":      2,
		"STATE_ARCHIVED":    3,
	}
)

Enum value maps for Policy_State.

View Source
var (
	Schema_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "DRAFT",
		2: "ACTIVE",
		3: "ARCHIVED",
		4: "IN_REVIEW",
		5: "INCOMPLETE",
		6: "APPROVED",
	}
	Schema_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"DRAFT":             1,
		"ACTIVE":            2,
		"ARCHIVED":          3,
		"IN_REVIEW":         4,
		"INCOMPLETE":        5,
		"APPROVED":          6,
	}
)

Enum value maps for Schema_State.

View Source
var (
	EventContract_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "DRAFT",
		2: "ACTIVE",
		3: "ARCHIVED",
		4: "IN_REVIEW",
		5: "INCOMPLETE",
	}
	EventContract_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"DRAFT":             1,
		"ACTIVE":            2,
		"ARCHIVED":          3,
		"IN_REVIEW":         4,
		"INCOMPLETE":        5,
	}
)

Enum value maps for EventContract_State.

View Source
var (
	DataContract_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "DRAFT",
		2: "IN_REVIEW",
		3: "ACTIVE",
		4: "ARCHIVED",
		5: "INCOMPLETE",
		6: "APPROVED",
	}
	DataContract_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"DRAFT":             1,
		"IN_REVIEW":         2,
		"ACTIVE":            3,
		"ARCHIVED":          4,
		"INCOMPLETE":        5,
		"APPROVED":          6,
	}
)

Enum value maps for DataContract_State.

View Source
var (
	FieldMetadata_NullHandlingConfig_NullHandlingType_name = map[int32]string{
		0: "NULL_HANDLING_TYPE_UNSPECIFIED",
		1: "DROP_RECORD",
		2: "DEFAULT_VALUE",
	}
	FieldMetadata_NullHandlingConfig_NullHandlingType_value = map[string]int32{
		"NULL_HANDLING_TYPE_UNSPECIFIED": 0,
		"DROP_RECORD":                    1,
		"DEFAULT_VALUE":                  2,
	}
)

Enum value maps for FieldMetadata_NullHandlingConfig_NullHandlingType.

View Source
var (
	Project_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "OPERATIONAL",
		2: "PENDING_DELETION",
	}
	Project_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"OPERATIONAL":       1,
		"PENDING_DELETION":  2,
	}
)

Enum value maps for Project_State.

View Source
var File_strmprivacy_api_entities_v1_entities_v1_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AuditTrailEntry added in v2.82.0

type AuditTrailEntry struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The entity this audit trail entry is attached to.
	EntityRef *GenericRef `protobuf:"bytes,3,opt,name=entity_ref,json=entityRef,proto3" json:"entity_ref,omitempty"`
	// The content of the audit trail entry.
	Content string `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	// The user whose action triggered the audit trail entry. Upon creation, only the user's external_user_id needs to be set.
	Actor *User `protobuf:"bytes,5,opt,name=actor,proto3" json:"actor,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditTrailEntry) Descriptor deprecated added in v2.82.0

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

Deprecated: Use AuditTrailEntry.ProtoReflect.Descriptor instead.

func (*AuditTrailEntry) GetActor added in v2.82.0

func (x *AuditTrailEntry) GetActor() *User

func (*AuditTrailEntry) GetContent added in v2.82.0

func (x *AuditTrailEntry) GetContent() string

func (*AuditTrailEntry) GetCreateTime added in v2.82.0

func (x *AuditTrailEntry) GetCreateTime() *timestamppb.Timestamp

func (*AuditTrailEntry) GetEntityRef added in v2.82.0

func (x *AuditTrailEntry) GetEntityRef() *GenericRef

func (*AuditTrailEntry) GetId added in v2.82.0

func (x *AuditTrailEntry) GetId() string

func (*AuditTrailEntry) ProtoMessage added in v2.82.0

func (*AuditTrailEntry) ProtoMessage()

func (*AuditTrailEntry) ProtoReflect added in v2.82.0

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

func (*AuditTrailEntry) Reset added in v2.82.0

func (x *AuditTrailEntry) Reset()

func (*AuditTrailEntry) String added in v2.82.0

func (x *AuditTrailEntry) String() string

type AuthMechanism

type AuthMechanism int32

(-- TODO align values with JAAS. see https://docs.confluent.io/platform/current/kafka/overview-authentication-methods.html --)

also see the Kafka exporter to determine the correct terminology here
SASL_SSL should probably be SASL_OAUTHBEARER --)
const (
	AuthMechanism_AUTH_MECHANISM_UNSPECIFIED AuthMechanism = 0
	AuthMechanism_SASL_PLAIN                 AuthMechanism = 1
	AuthMechanism_SASL_SSL                   AuthMechanism = 2
)

func (AuthMechanism) Descriptor

func (AuthMechanism) Enum

func (x AuthMechanism) Enum() *AuthMechanism

func (AuthMechanism) EnumDescriptor deprecated

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

Deprecated: Use AuthMechanism.Descriptor instead.

func (AuthMechanism) Number

func (AuthMechanism) String

func (x AuthMechanism) String() string

func (AuthMechanism) Type

type AwsS3BucketLocation added in v2.14.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 AWS IAM credentials that give access to this bucket, in JSON format as returned by the AWS CLI. This means a
	// JSON with at least one property: "AccessKey", which contains at least the two properties: "AccessKeyId" and
	// "SecretAccessKey".
	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"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use AwsS3BucketLocation.ProtoReflect.Descriptor instead.

func (*AwsS3BucketLocation) GetAssumeRoleArn added in v2.14.0

func (x *AwsS3BucketLocation) GetAssumeRoleArn() string

func (*AwsS3BucketLocation) GetBucketName added in v2.14.0

func (x *AwsS3BucketLocation) GetBucketName() string

func (*AwsS3BucketLocation) GetCredentials added in v2.14.0

func (x *AwsS3BucketLocation) GetCredentials() string

func (*AwsS3BucketLocation) ProtoMessage added in v2.14.0

func (*AwsS3BucketLocation) ProtoMessage()

func (*AwsS3BucketLocation) ProtoReflect added in v2.14.0

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

func (*AwsS3BucketLocation) Reset added in v2.14.0

func (x *AwsS3BucketLocation) Reset()

func (*AwsS3BucketLocation) String added in v2.14.0

func (x *AwsS3BucketLocation) String() string

type AzureBlobStorageContainerLocation added in v2.21.0

type AzureBlobStorageContainerLocation struct {

	// The base URI of the Azure Storage Account. Typically this is 'https://<your-account-name>.blob.core.windows.net',
	// but Azure users can map this to their own domain or subdomain.
	StorageAccountUri string `protobuf:"bytes,1,opt,name=storage_account_uri,json=storageAccountUri,proto3" json:"storage_account_uri,omitempty"`
	// (-- api-linter: core::0122::name-suffix=disabled
	//
	//	aip.dev/not-precedent: We refer to a container name. --)
	//
	// Name of the Storage Container
	ContainerName string `protobuf:"bytes,2,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	// The AAD client secret credential used to acquire a token for the AAD application that has the required
	// permissions on this Blob Storage Container.
	ClientSecretCredential *AzureClientSecretCredential `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AzureBlobStorageContainerLocation) Descriptor deprecated added in v2.21.0

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

Deprecated: Use AzureBlobStorageContainerLocation.ProtoReflect.Descriptor instead.

func (*AzureBlobStorageContainerLocation) GetClientSecretCredential added in v2.21.0

func (x *AzureBlobStorageContainerLocation) GetClientSecretCredential() *AzureClientSecretCredential

func (*AzureBlobStorageContainerLocation) GetContainerName added in v2.21.0

func (x *AzureBlobStorageContainerLocation) GetContainerName() string

func (*AzureBlobStorageContainerLocation) GetStorageAccountUri added in v2.21.0

func (x *AzureBlobStorageContainerLocation) GetStorageAccountUri() string

func (*AzureBlobStorageContainerLocation) ProtoMessage added in v2.21.0

func (*AzureBlobStorageContainerLocation) ProtoMessage()

func (*AzureBlobStorageContainerLocation) ProtoReflect added in v2.21.0

func (*AzureBlobStorageContainerLocation) Reset added in v2.21.0

func (*AzureBlobStorageContainerLocation) String added in v2.21.0

type AzureClientSecretCredential added in v2.21.0

type AzureClientSecretCredential struct {

	// Tenant ID of the Azure AD Application.
	TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// Client ID of the Azure AD Application.
	ClientId string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// Client secret to use for authentication.
	ClientSecret string `protobuf:"bytes,3,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`
	// contains filtered or unexported fields
}

func (*AzureClientSecretCredential) Descriptor deprecated added in v2.21.0

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

Deprecated: Use AzureClientSecretCredential.ProtoReflect.Descriptor instead.

func (*AzureClientSecretCredential) GetClientId added in v2.21.0

func (x *AzureClientSecretCredential) GetClientId() string

func (*AzureClientSecretCredential) GetClientSecret added in v2.21.0

func (x *AzureClientSecretCredential) GetClientSecret() string

func (*AzureClientSecretCredential) GetTenantId added in v2.21.0

func (x *AzureClientSecretCredential) GetTenantId() string

func (*AzureClientSecretCredential) ProtoMessage added in v2.21.0

func (*AzureClientSecretCredential) ProtoMessage()

func (*AzureClientSecretCredential) ProtoReflect added in v2.21.0

func (*AzureClientSecretCredential) Reset added in v2.21.0

func (x *AzureClientSecretCredential) Reset()

func (*AzureClientSecretCredential) String added in v2.21.0

func (x *AzureClientSecretCredential) String() string

type BatchExporter

type BatchExporter struct {
	Ref *BatchExporterRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Types that are assignable to StreamOrKeyStreamRef:
	//
	//	*BatchExporter_StreamRef
	//	*BatchExporter_KeyStreamRef
	StreamOrKeyStreamRef isBatchExporter_StreamOrKeyStreamRef `protobuf_oneof:"stream_or_key_stream_ref"`
	// granularity of seconds, nanos is unused
	Interval *durationpb.Duration `protobuf:"bytes,4,opt,name=interval,proto3" json:"interval,omitempty"`
	// (-- api-linter: core::0122::name-suffix=disabled
	//
	//	aip.dev/not-precedent: We refer to the sink by name. --)
	//
	// Deprecated in favor of data_connector_ref
	//
	// Deprecated: Do not use.
	SinkName              string            `protobuf:"bytes,5,opt,name=sink_name,json=sinkName,proto3" json:"sink_name,omitempty"`
	PathPrefix            string            `protobuf:"bytes,6,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
	IncludeExistingEvents bool              `` /* 127-byte string literal not displayed */
	DataConnectorRef      *DataConnectorRef `protobuf:"bytes,8,opt,name=data_connector_ref,json=dataConnectorRef,proto3" json:"data_connector_ref,omitempty"`
	// contains filtered or unexported fields
}

A batch exporter.

func (*BatchExporter) Descriptor deprecated

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

Deprecated: Use BatchExporter.ProtoReflect.Descriptor instead.

func (*BatchExporter) GetDataConnectorRef added in v2.22.0

func (x *BatchExporter) GetDataConnectorRef() *DataConnectorRef

func (*BatchExporter) GetIncludeExistingEvents added in v2.6.0

func (x *BatchExporter) GetIncludeExistingEvents() bool

func (*BatchExporter) GetInterval

func (x *BatchExporter) GetInterval() *durationpb.Duration

func (*BatchExporter) GetKeyStreamRef

func (x *BatchExporter) GetKeyStreamRef() *KeyStreamRef

func (*BatchExporter) GetPathPrefix

func (x *BatchExporter) GetPathPrefix() string

func (*BatchExporter) GetRef

func (x *BatchExporter) GetRef() *BatchExporterRef

func (*BatchExporter) GetSinkName deprecated

func (x *BatchExporter) GetSinkName() string

Deprecated: Do not use.

func (*BatchExporter) GetStreamOrKeyStreamRef

func (m *BatchExporter) GetStreamOrKeyStreamRef() isBatchExporter_StreamOrKeyStreamRef

func (*BatchExporter) GetStreamRef

func (x *BatchExporter) GetStreamRef() *StreamRef

func (*BatchExporter) ProtoMessage

func (*BatchExporter) ProtoMessage()

func (*BatchExporter) ProtoReflect

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

func (*BatchExporter) Reset

func (x *BatchExporter) Reset()

func (*BatchExporter) String

func (x *BatchExporter) String() string

type BatchExporterRef

type BatchExporterRef struct {

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

func (*BatchExporterRef) Descriptor deprecated

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

Deprecated: Use BatchExporterRef.ProtoReflect.Descriptor instead.

func (*BatchExporterRef) GetBillingId deprecated

func (x *BatchExporterRef) GetBillingId() string

Deprecated: Do not use.

func (*BatchExporterRef) GetName

func (x *BatchExporterRef) GetName() string

func (*BatchExporterRef) GetProjectId added in v2.38.0

func (x *BatchExporterRef) GetProjectId() string

func (*BatchExporterRef) ProtoMessage

func (*BatchExporterRef) ProtoMessage()

func (*BatchExporterRef) ProtoReflect

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

func (*BatchExporterRef) Reset

func (x *BatchExporterRef) Reset()

func (*BatchExporterRef) String

func (x *BatchExporterRef) String() string

type BatchExporter_KeyStreamRef

type BatchExporter_KeyStreamRef struct {
	KeyStreamRef *KeyStreamRef `protobuf:"bytes,3,opt,name=key_stream_ref,json=keyStreamRef,proto3,oneof"`
}

type BatchExporter_StreamRef

type BatchExporter_StreamRef struct {
	StreamRef *StreamRef `protobuf:"bytes,2,opt,name=stream_ref,json=streamRef,proto3,oneof"`
}

type BatchJob added in v2.22.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         *DataConnectorAndType `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   *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"`
	PolicyId           string                `protobuf:"bytes,10,opt,name=policy_id,json=policyId,proto3" json:"policy_id,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.22.0

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

Deprecated: Use BatchJob.ProtoReflect.Descriptor instead.

func (*BatchJob) GetConsent added in v2.22.0

func (x *BatchJob) GetConsent() *ConsentConfig

func (*BatchJob) GetDerivedData added in v2.22.0

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

func (*BatchJob) GetEncryptedData added in v2.22.0

func (x *BatchJob) GetEncryptedData() *EncryptedData

func (*BatchJob) GetEncryption added in v2.22.0

func (x *BatchJob) GetEncryption() *EncryptionConfig

func (*BatchJob) GetEncryptionKeysData added in v2.22.0

func (x *BatchJob) GetEncryptionKeysData() *EncryptionKeysData

func (*BatchJob) GetEventContractRef added in v2.22.0

func (x *BatchJob) GetEventContractRef() *EventContractRef

func (*BatchJob) GetPolicyId added in v2.58.0

func (x *BatchJob) GetPolicyId() string

func (*BatchJob) GetRef added in v2.22.0

func (x *BatchJob) GetRef() *BatchJobRef

func (*BatchJob) GetSourceData added in v2.22.0

func (x *BatchJob) GetSourceData() *DataConnectorAndType

func (*BatchJob) GetStates added in v2.22.0

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

func (*BatchJob) ProtoMessage added in v2.22.0

func (*BatchJob) ProtoMessage()

func (*BatchJob) ProtoReflect added in v2.22.0

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

func (*BatchJob) Reset added in v2.22.0

func (x *BatchJob) Reset()

func (*BatchJob) String added in v2.22.0

func (x *BatchJob) String() string

type BatchJobRef added in v2.22.0

type BatchJobRef struct {

	// Deprecated: Do not use.
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	// the UUIDv4 of the job, generated upon creation
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// the UUIDv4 of the STRM Privacy project
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use BatchJobRef.ProtoReflect.Descriptor instead.

func (*BatchJobRef) GetBillingId deprecated added in v2.22.0

func (x *BatchJobRef) GetBillingId() string

Deprecated: Do not use.

func (*BatchJobRef) GetId added in v2.22.0

func (x *BatchJobRef) GetId() string

func (*BatchJobRef) GetProjectId added in v2.38.0

func (x *BatchJobRef) GetProjectId() string

func (*BatchJobRef) ProtoMessage added in v2.22.0

func (*BatchJobRef) ProtoMessage()

func (*BatchJobRef) ProtoReflect added in v2.22.0

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

func (*BatchJobRef) Reset added in v2.22.0

func (x *BatchJobRef) Reset()

func (*BatchJobRef) String added in v2.22.0

func (x *BatchJobRef) String() string

type BatchJobState added in v2.22.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.entities.v1.BatchJobStateType" json:"state,omitempty"`
	Message   string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use BatchJobState.ProtoReflect.Descriptor instead.

func (*BatchJobState) GetMessage added in v2.22.0

func (x *BatchJobState) GetMessage() string

func (*BatchJobState) GetState added in v2.22.0

func (x *BatchJobState) GetState() BatchJobStateType

func (*BatchJobState) GetStateTime added in v2.22.0

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

func (*BatchJobState) ProtoMessage added in v2.22.0

func (*BatchJobState) ProtoMessage()

func (*BatchJobState) ProtoReflect added in v2.22.0

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

func (*BatchJobState) Reset added in v2.22.0

func (x *BatchJobState) Reset()

func (*BatchJobState) String added in v2.22.0

func (x *BatchJobState) String() string

type BatchJobStateType added in v2.22.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.22.0

func (BatchJobStateType) Enum added in v2.22.0

func (BatchJobStateType) EnumDescriptor deprecated added in v2.22.0

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

Deprecated: Use BatchJobStateType.Descriptor instead.

func (BatchJobStateType) Number added in v2.22.0

func (BatchJobStateType) String added in v2.22.0

func (x BatchJobStateType) String() string

func (BatchJobStateType) Type added in v2.22.0

type BatchJobWrapper added in v2.61.0

type BatchJobWrapper struct {

	// Types that are assignable to Job:
	//
	//	*BatchJobWrapper_EncryptionBatchJob
	//	*BatchJobWrapper_MicroAggregationBatchJob
	Job isBatchJobWrapper_Job `protobuf_oneof:"job"`
	// contains filtered or unexported fields
}

func (*BatchJobWrapper) Descriptor deprecated added in v2.61.0

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

Deprecated: Use BatchJobWrapper.ProtoReflect.Descriptor instead.

func (*BatchJobWrapper) GetEncryptionBatchJob added in v2.61.0

func (x *BatchJobWrapper) GetEncryptionBatchJob() *BatchJob

func (*BatchJobWrapper) GetJob added in v2.61.0

func (m *BatchJobWrapper) GetJob() isBatchJobWrapper_Job

func (*BatchJobWrapper) GetMicroAggregationBatchJob added in v2.61.0

func (x *BatchJobWrapper) GetMicroAggregationBatchJob() *MicroAggregationBatchJob

func (*BatchJobWrapper) ProtoMessage added in v2.61.0

func (*BatchJobWrapper) ProtoMessage()

func (*BatchJobWrapper) ProtoReflect added in v2.61.0

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

func (*BatchJobWrapper) Reset added in v2.61.0

func (x *BatchJobWrapper) Reset()

func (*BatchJobWrapper) String added in v2.61.0

func (x *BatchJobWrapper) String() string

type BatchJobWrapper_EncryptionBatchJob added in v2.61.0

type BatchJobWrapper_EncryptionBatchJob struct {
	EncryptionBatchJob *BatchJob `protobuf:"bytes,1,opt,name=encryption_batch_job,json=encryptionBatchJob,proto3,oneof"`
}

type BatchJobWrapper_MicroAggregationBatchJob added in v2.61.0

type BatchJobWrapper_MicroAggregationBatchJob struct {
	MicroAggregationBatchJob *MicroAggregationBatchJob `protobuf:"bytes,2,opt,name=micro_aggregation_batch_job,json=microAggregationBatchJob,proto3,oneof"`
}

type BucketConfig

type BucketConfig struct {

	// constraints: validated via access check
	BucketName string `protobuf:"bytes,4,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// The credentials that are to be used to access the sink target (e.g. S3 or Google Cloud Storage)
	Credentials string `protobuf:"bytes,5,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,6,opt,name=assume_role_arn,json=assumeRoleArn,proto3" json:"assume_role_arn,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketConfig) Descriptor deprecated

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

Deprecated: Use BucketConfig.ProtoReflect.Descriptor instead.

func (*BucketConfig) GetAssumeRoleArn

func (x *BucketConfig) GetAssumeRoleArn() string

func (*BucketConfig) GetBucketName

func (x *BucketConfig) GetBucketName() string

func (*BucketConfig) GetCredentials

func (x *BucketConfig) GetCredentials() string

func (*BucketConfig) ProtoMessage

func (*BucketConfig) ProtoMessage()

func (*BucketConfig) ProtoReflect

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

func (*BucketConfig) Reset

func (x *BucketConfig) Reset()

func (*BucketConfig) String

func (x *BucketConfig) String() string

type Comment added in v2.82.0

type Comment struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The entity this comment is attached to.
	EntityRef *GenericRef `protobuf:"bytes,3,opt,name=entity_ref,json=entityRef,proto3" json:"entity_ref,omitempty"`
	// The content of the comment.
	Content string `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	// The user who created the comment.
	Creator *User `protobuf:"bytes,5,opt,name=creator,proto3" json:"creator,omitempty"`
	// contains filtered or unexported fields
}

func (*Comment) Descriptor deprecated added in v2.82.0

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

Deprecated: Use Comment.ProtoReflect.Descriptor instead.

func (*Comment) GetContent added in v2.82.0

func (x *Comment) GetContent() string

func (*Comment) GetCreateTime added in v2.82.0

func (x *Comment) GetCreateTime() *timestamppb.Timestamp

func (*Comment) GetCreator added in v2.82.0

func (x *Comment) GetCreator() *User

func (*Comment) GetEntityRef added in v2.82.0

func (x *Comment) GetEntityRef() *GenericRef

func (*Comment) GetId added in v2.82.0

func (x *Comment) GetId() string

func (*Comment) ProtoMessage added in v2.82.0

func (*Comment) ProtoMessage()

func (*Comment) ProtoReflect added in v2.82.0

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

func (*Comment) Reset added in v2.82.0

func (x *Comment) Reset()

func (*Comment) String added in v2.82.0

func (x *Comment) String() string

type ConsentConfig added in v2.22.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.22.0

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

Deprecated: Use ConsentConfig.ProtoReflect.Descriptor instead.

func (*ConsentConfig) GetConsentLevelExtractor added in v2.22.0

func (x *ConsentConfig) GetConsentLevelExtractor() *ConsentLevelExtractor

func (*ConsentConfig) GetDefaultConsentLevels added in v2.22.0

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

func (*ConsentConfig) ProtoMessage added in v2.22.0

func (*ConsentConfig) ProtoMessage()

func (*ConsentConfig) ProtoReflect added in v2.22.0

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

func (*ConsentConfig) Reset added in v2.22.0

func (x *ConsentConfig) Reset()

func (*ConsentConfig) String added in v2.22.0

func (x *ConsentConfig) String() string

type ConsentLevelExtractor added in v2.22.0

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

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

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

Deprecated: Use ConsentLevelExtractor.ProtoReflect.Descriptor instead.

func (*ConsentLevelExtractor) GetField added in v2.22.0

func (x *ConsentLevelExtractor) GetField() string

func (*ConsentLevelExtractor) GetFieldPatterns added in v2.22.0

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

func (*ConsentLevelExtractor) ProtoMessage added in v2.22.0

func (*ConsentLevelExtractor) ProtoMessage()

func (*ConsentLevelExtractor) ProtoReflect added in v2.22.0

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

func (*ConsentLevelExtractor) Reset added in v2.22.0

func (x *ConsentLevelExtractor) Reset()

func (*ConsentLevelExtractor) String added in v2.22.0

func (x *ConsentLevelExtractor) String() string

type ConsentLevelMapping

type ConsentLevelMapping struct {
	Ref *ConsentLevelMappingRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// some text like 'analytics'
	// constraints: generic name constraint
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

for descriptive purposes only.

func (*ConsentLevelMapping) Descriptor deprecated

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

Deprecated: Use ConsentLevelMapping.ProtoReflect.Descriptor instead.

func (*ConsentLevelMapping) GetName

func (x *ConsentLevelMapping) GetName() string

func (*ConsentLevelMapping) GetRef

func (*ConsentLevelMapping) ProtoMessage

func (*ConsentLevelMapping) ProtoMessage()

func (*ConsentLevelMapping) ProtoReflect

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

func (*ConsentLevelMapping) Reset

func (x *ConsentLevelMapping) Reset()

func (*ConsentLevelMapping) String

func (x *ConsentLevelMapping) String() string

type ConsentLevelMappingRef

type ConsentLevelMappingRef struct {

	// Deprecated: Do not use.
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	// the typically small integer value that we use in the events.
	Level     int32  `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"`
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsentLevelMappingRef) Descriptor deprecated

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

Deprecated: Use ConsentLevelMappingRef.ProtoReflect.Descriptor instead.

func (*ConsentLevelMappingRef) GetBillingId deprecated

func (x *ConsentLevelMappingRef) GetBillingId() string

Deprecated: Do not use.

func (*ConsentLevelMappingRef) GetLevel

func (x *ConsentLevelMappingRef) GetLevel() int32

func (*ConsentLevelMappingRef) GetProjectId added in v2.38.0

func (x *ConsentLevelMappingRef) GetProjectId() string

func (*ConsentLevelMappingRef) ProtoMessage

func (*ConsentLevelMappingRef) ProtoMessage()

func (*ConsentLevelMappingRef) ProtoReflect

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

func (*ConsentLevelMappingRef) Reset

func (x *ConsentLevelMappingRef) Reset()

func (*ConsentLevelMappingRef) String

func (x *ConsentLevelMappingRef) String() string

type ConsentLevelType

type ConsentLevelType int32

Consent level is meant to interpret the consent-levels of an event for decryption purposes only.

Cumulative means that the highest consent-level in an event must be greater than or equal to the single requested level for the decrypted stream.

Granular means that the set of consent-levels in an event must enclose the set of requested event levels for the decrypted stream.

const (
	ConsentLevelType_CONSENT_LEVEL_TYPE_UNSPECIFIED ConsentLevelType = 0
	ConsentLevelType_CUMULATIVE                     ConsentLevelType = 1
	ConsentLevelType_GRANULAR                       ConsentLevelType = 2
)

func (ConsentLevelType) Descriptor

func (ConsentLevelType) Enum

func (ConsentLevelType) EnumDescriptor deprecated

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

Deprecated: Use ConsentLevelType.Descriptor instead.

func (ConsentLevelType) Number

func (ConsentLevelType) String

func (x ConsentLevelType) String() string

func (ConsentLevelType) Type

type ConsentLevels added in v2.12.0

type ConsentLevels struct {
	ConsentLevels []int32 `protobuf:"varint,1,rep,packed,name=consent_levels,json=consentLevels,proto3" json:"consent_levels,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ConsentLevels.ProtoReflect.Descriptor instead.

func (*ConsentLevels) GetConsentLevels added in v2.12.0

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

func (*ConsentLevels) ProtoMessage added in v2.12.0

func (*ConsentLevels) ProtoMessage()

func (*ConsentLevels) ProtoReflect added in v2.12.0

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

func (*ConsentLevels) Reset added in v2.12.0

func (x *ConsentLevels) Reset()

func (*ConsentLevels) String added in v2.12.0

func (x *ConsentLevels) String() string

type Credentials

type Credentials struct {
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	ClientId  string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// as this property is secret, it is not always returned
	ClientSecret string `protobuf:"bytes,3,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`
	ProjectId    string `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

Credentials to produce to the event-gateway, or to consume from egress.

func (*Credentials) Descriptor deprecated

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

Deprecated: Use Credentials.ProtoReflect.Descriptor instead.

func (*Credentials) GetBillingId

func (x *Credentials) GetBillingId() string

func (*Credentials) GetClientId

func (x *Credentials) GetClientId() string

func (*Credentials) GetClientSecret

func (x *Credentials) GetClientSecret() string

func (*Credentials) GetProjectId added in v2.38.0

func (x *Credentials) GetProjectId() string

func (*Credentials) ProtoMessage

func (*Credentials) ProtoMessage()

func (*Credentials) ProtoReflect

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

func (*Credentials) Reset

func (x *Credentials) Reset()

func (*Credentials) String

func (x *Credentials) String() string

type CsvConfig added in v2.14.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.14.0

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

Deprecated: Use CsvConfig.ProtoReflect.Descriptor instead.

func (*CsvConfig) GetCharset added in v2.14.0

func (x *CsvConfig) GetCharset() string

func (*CsvConfig) ProtoMessage added in v2.14.0

func (*CsvConfig) ProtoMessage()

func (*CsvConfig) ProtoReflect added in v2.14.0

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

func (*CsvConfig) Reset added in v2.14.0

func (x *CsvConfig) Reset()

func (*CsvConfig) String added in v2.14.0

func (x *CsvConfig) String() string

type DataConnector added in v2.14.0

type DataConnector struct {
	Ref *DataConnectorRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Types that are assignable to Location:
	//
	//	*DataConnector_S3Bucket
	//	*DataConnector_GoogleCloudStorageBucket
	//	*DataConnector_AzureBlobStorageContainer
	//	*DataConnector_JdbcLocation
	Location          isDataConnector_Location        `protobuf_oneof:"location"`
	Uuid              string                          `protobuf:"bytes,5,opt,name=uuid,proto3" json:"uuid,omitempty"`
	DependentEntities *DataConnectorDependentEntities `protobuf:"bytes,6,opt,name=dependent_entities,json=dependentEntities,proto3" json:"dependent_entities,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use DataConnector.ProtoReflect.Descriptor instead.

func (*DataConnector) GetAzureBlobStorageContainer added in v2.21.0

func (x *DataConnector) GetAzureBlobStorageContainer() *AzureBlobStorageContainerLocation

func (*DataConnector) GetDependentEntities added in v2.22.0

func (x *DataConnector) GetDependentEntities() *DataConnectorDependentEntities

func (*DataConnector) GetGoogleCloudStorageBucket added in v2.16.0

func (x *DataConnector) GetGoogleCloudStorageBucket() *GoogleCloudStorageBucketLocation

func (*DataConnector) GetJdbcLocation added in v2.77.0

func (x *DataConnector) GetJdbcLocation() *JdbcLocation

func (*DataConnector) GetLocation added in v2.14.0

func (m *DataConnector) GetLocation() isDataConnector_Location

func (*DataConnector) GetRef added in v2.14.0

func (x *DataConnector) GetRef() *DataConnectorRef

func (*DataConnector) GetS3Bucket added in v2.14.0

func (x *DataConnector) GetS3Bucket() *AwsS3BucketLocation

func (*DataConnector) GetUuid added in v2.22.0

func (x *DataConnector) GetUuid() string

func (*DataConnector) ProtoMessage added in v2.14.0

func (*DataConnector) ProtoMessage()

func (*DataConnector) ProtoReflect added in v2.14.0

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

func (*DataConnector) Reset added in v2.14.0

func (x *DataConnector) Reset()

func (*DataConnector) String added in v2.14.0

func (x *DataConnector) String() string

type DataConnectorAndType added in v2.22.0

type DataConnectorAndType struct {
	DataConnectorRef *DataConnectorRef `protobuf:"bytes,1,opt,name=data_connector_ref,json=dataConnectorRef,proto3" json:"data_connector_ref,omitempty"`
	// If omitted, files are read from the root of the bucket.
	PathPrefix string `protobuf:"bytes,2,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
	// (-- api-linter: core::0122::name-suffix=disabled
	//
	//	aip.dev/not-precedent: We think file_name is a better name. --)
	FileName string    `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	DataType *DataType `protobuf:"bytes,4,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"`
	// contains filtered or unexported fields
}

func (*DataConnectorAndType) Descriptor deprecated added in v2.22.0

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

Deprecated: Use DataConnectorAndType.ProtoReflect.Descriptor instead.

func (*DataConnectorAndType) GetDataConnectorRef added in v2.22.0

func (x *DataConnectorAndType) GetDataConnectorRef() *DataConnectorRef

func (*DataConnectorAndType) GetDataType added in v2.22.0

func (x *DataConnectorAndType) GetDataType() *DataType

func (*DataConnectorAndType) GetFileName added in v2.22.0

func (x *DataConnectorAndType) GetFileName() string

func (*DataConnectorAndType) GetPathPrefix added in v2.22.0

func (x *DataConnectorAndType) GetPathPrefix() string

func (*DataConnectorAndType) ProtoMessage added in v2.22.0

func (*DataConnectorAndType) ProtoMessage()

func (*DataConnectorAndType) ProtoReflect added in v2.22.0

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

func (*DataConnectorAndType) Reset added in v2.22.0

func (x *DataConnectorAndType) Reset()

func (*DataConnectorAndType) String added in v2.22.0

func (x *DataConnectorAndType) String() string

type DataConnectorDependentEntities added in v2.22.0

type DataConnectorDependentEntities struct {
	BatchExporters            []*BatchExporter            `protobuf:"bytes,1,rep,name=batch_exporters,json=batchExporters,proto3" json:"batch_exporters,omitempty"`
	BatchJobs                 []*BatchJob                 `protobuf:"bytes,2,rep,name=batch_jobs,json=batchJobs,proto3" json:"batch_jobs,omitempty"`
	MicroAggregationBatchJobs []*MicroAggregationBatchJob `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DataConnectorDependentEntities) Descriptor deprecated added in v2.22.0

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

Deprecated: Use DataConnectorDependentEntities.ProtoReflect.Descriptor instead.

func (*DataConnectorDependentEntities) GetBatchExporters added in v2.22.0

func (x *DataConnectorDependentEntities) GetBatchExporters() []*BatchExporter

func (*DataConnectorDependentEntities) GetBatchJobs added in v2.22.0

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

func (*DataConnectorDependentEntities) GetMicroAggregationBatchJobs added in v2.61.0

func (x *DataConnectorDependentEntities) GetMicroAggregationBatchJobs() []*MicroAggregationBatchJob

func (*DataConnectorDependentEntities) ProtoMessage added in v2.22.0

func (*DataConnectorDependentEntities) ProtoMessage()

func (*DataConnectorDependentEntities) ProtoReflect added in v2.22.0

func (*DataConnectorDependentEntities) Reset added in v2.22.0

func (x *DataConnectorDependentEntities) Reset()

func (*DataConnectorDependentEntities) String added in v2.22.0

type DataConnectorRef added in v2.14.0

type DataConnectorRef struct {

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

func (*DataConnectorRef) Descriptor deprecated added in v2.14.0

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

Deprecated: Use DataConnectorRef.ProtoReflect.Descriptor instead.

func (*DataConnectorRef) GetBillingId deprecated added in v2.14.0

func (x *DataConnectorRef) GetBillingId() string

Deprecated: Do not use.

func (*DataConnectorRef) GetName added in v2.14.0

func (x *DataConnectorRef) GetName() string

func (*DataConnectorRef) GetProjectId added in v2.38.0

func (x *DataConnectorRef) GetProjectId() string

func (*DataConnectorRef) ProtoMessage added in v2.14.0

func (*DataConnectorRef) ProtoMessage()

func (*DataConnectorRef) ProtoReflect added in v2.14.0

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

func (*DataConnectorRef) Reset added in v2.14.0

func (x *DataConnectorRef) Reset()

func (*DataConnectorRef) String added in v2.14.0

func (x *DataConnectorRef) String() string

type DataConnector_AzureBlobStorageContainer added in v2.21.0

type DataConnector_AzureBlobStorageContainer struct {
	AzureBlobStorageContainer *AzureBlobStorageContainerLocation `protobuf:"bytes,4,opt,name=azure_blob_storage_container,json=azureBlobStorageContainer,proto3,oneof"`
}

type DataConnector_GoogleCloudStorageBucket added in v2.16.0

type DataConnector_GoogleCloudStorageBucket struct {
	GoogleCloudStorageBucket *GoogleCloudStorageBucketLocation `protobuf:"bytes,3,opt,name=google_cloud_storage_bucket,json=googleCloudStorageBucket,proto3,oneof"`
}

type DataConnector_JdbcLocation added in v2.77.0

type DataConnector_JdbcLocation struct {
	JdbcLocation *JdbcLocation `protobuf:"bytes,7,opt,name=jdbc_location,json=jdbcLocation,proto3,oneof"`
}

type DataConnector_S3Bucket added in v2.14.0

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

type DataContract added in v2.36.0

type DataContract struct {
	Id    string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Ref   *DataContractRef   `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	State DataContract_State `protobuf:"varint,3,opt,name=state,proto3,enum=strmprivacy.api.entities.v1.DataContract_State" json:"state,omitempty"`
	// (-- 'is' is intentional here (see https://google.aip.dev/140#booleans) --)
	IsPublic bool   `protobuf:"varint,4,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"`
	KeyField string `protobuf:"bytes,5,opt,name=key_field,json=keyField,proto3" json:"key_field,omitempty"`
	// PII Fields as a map, where the key is the field path (i.e. producerSessionId or customer/id) and the
	// value is the purpose level, provided as an integer
	//
	// Deprecated: Do not use.
	PiiFields        map[string]int32      `` /* 177-byte string literal not displayed */
	Validations      []*Validation         `protobuf:"bytes,7,rep,name=validations,proto3" json:"validations,omitempty"`
	Metadata         *DataContractMetadata `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Schema           *Schema               `protobuf:"bytes,9,opt,name=schema,proto3" json:"schema,omitempty"`
	DataSubjectField string                `protobuf:"bytes,10,opt,name=data_subject_field,json=dataSubjectField,proto3" json:"data_subject_field,omitempty"`
	ProjectId        string                `protobuf:"bytes,11,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	FieldMetadata    []*FieldMetadata      `protobuf:"bytes,12,rep,name=field_metadata,json=fieldMetadata,proto3" json:"field_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*DataContract) Descriptor deprecated added in v2.36.0

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

Deprecated: Use DataContract.ProtoReflect.Descriptor instead.

func (*DataContract) GetDataSubjectField added in v2.44.0

func (x *DataContract) GetDataSubjectField() string

func (*DataContract) GetFieldMetadata added in v2.59.0

func (x *DataContract) GetFieldMetadata() []*FieldMetadata

func (*DataContract) GetId added in v2.36.0

func (x *DataContract) GetId() string

func (*DataContract) GetIsPublic added in v2.36.0

func (x *DataContract) GetIsPublic() bool

func (*DataContract) GetKeyField added in v2.52.1

func (x *DataContract) GetKeyField() string

func (*DataContract) GetMetadata added in v2.36.0

func (x *DataContract) GetMetadata() *DataContractMetadata

func (*DataContract) GetPiiFields deprecated added in v2.36.0

func (x *DataContract) GetPiiFields() map[string]int32

Deprecated: Do not use.

func (*DataContract) GetProjectId added in v2.47.0

func (x *DataContract) GetProjectId() string

func (*DataContract) GetRef added in v2.36.0

func (x *DataContract) GetRef() *DataContractRef

func (*DataContract) GetSchema added in v2.52.0

func (x *DataContract) GetSchema() *Schema

func (*DataContract) GetState added in v2.36.0

func (x *DataContract) GetState() DataContract_State

func (*DataContract) GetValidations added in v2.36.0

func (x *DataContract) GetValidations() []*Validation

func (*DataContract) ProtoMessage added in v2.36.0

func (*DataContract) ProtoMessage()

func (*DataContract) ProtoReflect added in v2.36.0

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

func (*DataContract) Reset added in v2.36.0

func (x *DataContract) Reset()

func (*DataContract) String added in v2.36.0

func (x *DataContract) String() string

type DataContractMetadata added in v2.36.0

type DataContractMetadata struct {

	// The human readable title of this Data Contract. Used in the Portal. Defaults to the Data Contract name if left unspecified. This field can be modified.
	Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	// The description of this Data Contract. Used in the Portal. Markdown syntax is supported. This field can be modified.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// The timestamp when this Data Contract was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Generic (key/value) labels for this Data Contract.
	Labels     []*Label `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"`
	Domains    []string `protobuf:"bytes,6,rep,name=domains,proto3" json:"domains,omitempty"`
	Industries []string `protobuf:"bytes,7,rep,name=industries,proto3" json:"industries,omitempty"`
	// contains filtered or unexported fields
}

func (*DataContractMetadata) Descriptor deprecated added in v2.36.0

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

Deprecated: Use DataContractMetadata.ProtoReflect.Descriptor instead.

func (*DataContractMetadata) GetCreateTime added in v2.36.0

func (x *DataContractMetadata) GetCreateTime() *timestamppb.Timestamp

func (*DataContractMetadata) GetDescription added in v2.36.0

func (x *DataContractMetadata) GetDescription() string

func (*DataContractMetadata) GetDomains added in v2.36.0

func (x *DataContractMetadata) GetDomains() []string

func (*DataContractMetadata) GetIndustries added in v2.36.0

func (x *DataContractMetadata) GetIndustries() []string

func (*DataContractMetadata) GetLabels added in v2.36.0

func (x *DataContractMetadata) GetLabels() []*Label

func (*DataContractMetadata) GetTitle added in v2.36.0

func (x *DataContractMetadata) GetTitle() string

func (*DataContractMetadata) ProtoMessage added in v2.36.0

func (*DataContractMetadata) ProtoMessage()

func (*DataContractMetadata) ProtoReflect added in v2.36.0

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

func (*DataContractMetadata) Reset added in v2.36.0

func (x *DataContractMetadata) Reset()

func (*DataContractMetadata) String added in v2.36.0

func (x *DataContractMetadata) String() string

type DataContractRef added in v2.36.0

type DataContractRef struct {

	// constraint: handle should already exist
	Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"`
	// constraints: generic name constraint, unique within handle
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// constraints: semantic version, e.g. 1.12.3
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*DataContractRef) Descriptor deprecated added in v2.36.0

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

Deprecated: Use DataContractRef.ProtoReflect.Descriptor instead.

func (*DataContractRef) GetHandle added in v2.36.0

func (x *DataContractRef) GetHandle() string

func (*DataContractRef) GetName added in v2.36.0

func (x *DataContractRef) GetName() string

func (*DataContractRef) GetVersion added in v2.36.0

func (x *DataContractRef) GetVersion() string

func (*DataContractRef) ProtoMessage added in v2.36.0

func (*DataContractRef) ProtoMessage()

func (*DataContractRef) ProtoReflect added in v2.36.0

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

func (*DataContractRef) Reset added in v2.36.0

func (x *DataContractRef) Reset()

func (*DataContractRef) String added in v2.36.0

func (x *DataContractRef) String() string

type DataContract_State added in v2.36.0

type DataContract_State int32
const (
	DataContract_STATE_UNSPECIFIED DataContract_State = 0
	// This data contract is valid and complete, but has not been accepted yet, can still be modified and also deleted.
	DataContract_DRAFT DataContract_State = 1
	// This data contract is in review. It can be used once it has been approved.
	DataContract_IN_REVIEW DataContract_State = 2
	// This data contract is valid and complete can be used for events and batch jobs. It cannot be modified or deleted.
	DataContract_ACTIVE DataContract_State = 3
	// This data contract is valid and complete has been active, but no more events can be sent using this data contract. In-flight events are still processed.
	DataContract_ARCHIVED DataContract_State = 4
	// This data contract is still under construction.
	DataContract_INCOMPLETE DataContract_State = 5
	// This data contract is approved and when activated can be used used for events and batch jobs. It cannot be modified or deleted.
	DataContract_APPROVED DataContract_State = 6
)

func (DataContract_State) Descriptor added in v2.36.0

func (DataContract_State) Enum added in v2.36.0

func (DataContract_State) EnumDescriptor deprecated added in v2.36.0

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

Deprecated: Use DataContract_State.Descriptor instead.

func (DataContract_State) Number added in v2.36.0

func (DataContract_State) String added in v2.36.0

func (x DataContract_State) String() string

func (DataContract_State) Type added in v2.36.0

type DataType added in v2.14.0

type DataType struct {

	// Types that are assignable to DataType:
	//
	//	*DataType_Csv
	//	*DataType_Database
	DataType isDataType_DataType `protobuf_oneof:"data_type"`
	// contains filtered or unexported fields
}

func (*DataType) Descriptor deprecated added in v2.14.0

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

Deprecated: Use DataType.ProtoReflect.Descriptor instead.

func (*DataType) GetCsv added in v2.14.0

func (x *DataType) GetCsv() *CsvConfig

func (*DataType) GetDataType added in v2.14.0

func (m *DataType) GetDataType() isDataType_DataType

func (*DataType) GetDatabase added in v2.77.0

func (x *DataType) GetDatabase() *DatabaseConfig

func (*DataType) ProtoMessage added in v2.14.0

func (*DataType) ProtoMessage()

func (*DataType) ProtoReflect added in v2.14.0

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

func (*DataType) Reset added in v2.14.0

func (x *DataType) Reset()

func (*DataType) String added in v2.14.0

func (x *DataType) String() string

type DataType_Csv added in v2.14.0

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

type DataType_Database added in v2.77.0

type DataType_Database struct {
	Database *DatabaseConfig `protobuf:"bytes,2,opt,name=database,proto3,oneof"`
}

type DatabaseConfig added in v2.77.0

type DatabaseConfig struct {
	Schema  string   `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Table   string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Columns []string `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseConfig) Descriptor deprecated added in v2.77.0

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

Deprecated: Use DatabaseConfig.ProtoReflect.Descriptor instead.

func (*DatabaseConfig) GetColumns added in v2.77.0

func (x *DatabaseConfig) GetColumns() []string

func (*DatabaseConfig) GetSchema added in v2.77.0

func (x *DatabaseConfig) GetSchema() string

func (*DatabaseConfig) GetTable added in v2.77.0

func (x *DatabaseConfig) GetTable() string

func (*DatabaseConfig) ProtoMessage added in v2.77.0

func (*DatabaseConfig) ProtoMessage()

func (*DatabaseConfig) ProtoReflect added in v2.77.0

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

func (*DatabaseConfig) Reset added in v2.77.0

func (x *DatabaseConfig) Reset()

func (*DatabaseConfig) String added in v2.77.0

func (x *DatabaseConfig) String() string

type DatabaseType added in v2.77.0

type DatabaseType int32
const (
	DatabaseType_DATABASE_TYPE_UNSPECIFIED DatabaseType = 0
	DatabaseType_POSTGRES                  DatabaseType = 1
	DatabaseType_MYSQL                     DatabaseType = 2
	DatabaseType_BIGQUERY                  DatabaseType = 3
	DatabaseType_SNOWFLAKE                 DatabaseType = 4
)

func (DatabaseType) Descriptor added in v2.77.0

func (DatabaseType) Enum added in v2.77.0

func (x DatabaseType) Enum() *DatabaseType

func (DatabaseType) EnumDescriptor deprecated added in v2.77.0

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

Deprecated: Use DatabaseType.Descriptor instead.

func (DatabaseType) Number added in v2.77.0

func (DatabaseType) String added in v2.77.0

func (x DatabaseType) String() string

func (DatabaseType) Type added in v2.77.0

type DerivedData added in v2.22.0

type DerivedData struct {
	Target           *DataConnectorAndType `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 ConsentLevelType      `` /* 162-byte string literal not displayed */
	MaskedFields     *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.22.0

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

Deprecated: Use DerivedData.ProtoReflect.Descriptor instead.

func (*DerivedData) GetConsentLevelType added in v2.22.0

func (x *DerivedData) GetConsentLevelType() ConsentLevelType

func (*DerivedData) GetConsentLevels added in v2.22.0

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

func (*DerivedData) GetMaskedFields added in v2.22.0

func (x *DerivedData) GetMaskedFields() *MaskedFields

func (*DerivedData) GetTarget added in v2.22.0

func (x *DerivedData) GetTarget() *DataConnectorAndType

func (*DerivedData) ProtoMessage added in v2.22.0

func (*DerivedData) ProtoMessage()

func (*DerivedData) ProtoReflect added in v2.22.0

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

func (*DerivedData) Reset added in v2.22.0

func (x *DerivedData) Reset()

func (*DerivedData) String added in v2.22.0

func (x *DerivedData) String() string

type EncryptedData added in v2.22.0

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

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

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

Deprecated: Use EncryptedData.ProtoReflect.Descriptor instead.

func (*EncryptedData) GetTarget added in v2.22.0

func (x *EncryptedData) GetTarget() *DataConnectorAndType

func (*EncryptedData) ProtoMessage added in v2.22.0

func (*EncryptedData) ProtoMessage()

func (*EncryptedData) ProtoReflect added in v2.22.0

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

func (*EncryptedData) Reset added in v2.22.0

func (x *EncryptedData) Reset()

func (*EncryptedData) String added in v2.22.0

func (x *EncryptedData) String() string

type EncryptionConfig added in v2.22.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.22.0

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

Deprecated: Use EncryptionConfig.ProtoReflect.Descriptor instead.

func (*EncryptionConfig) GetBatchJobGroupId added in v2.22.0

func (x *EncryptionConfig) GetBatchJobGroupId() string

func (*EncryptionConfig) GetTimestampConfig added in v2.22.0

func (x *EncryptionConfig) GetTimestampConfig() *TimestampConfig

func (*EncryptionConfig) ProtoMessage added in v2.22.0

func (*EncryptionConfig) ProtoMessage()

func (*EncryptionConfig) ProtoReflect added in v2.22.0

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

func (*EncryptionConfig) Reset added in v2.22.0

func (x *EncryptionConfig) Reset()

func (*EncryptionConfig) String added in v2.22.0

func (x *EncryptionConfig) String() string

type EncryptionKeysData added in v2.22.0

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

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

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

Deprecated: Use EncryptionKeysData.ProtoReflect.Descriptor instead.

func (*EncryptionKeysData) GetTarget added in v2.22.0

func (x *EncryptionKeysData) GetTarget() *DataConnectorAndType

func (*EncryptionKeysData) ProtoMessage added in v2.22.0

func (*EncryptionKeysData) ProtoMessage()

func (*EncryptionKeysData) ProtoReflect added in v2.22.0

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

func (*EncryptionKeysData) Reset added in v2.22.0

func (x *EncryptionKeysData) Reset()

func (*EncryptionKeysData) String added in v2.22.0

func (x *EncryptionKeysData) String() string

type EventContract

type EventContract struct {
	Ref       *EventContractRef   `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	State     EventContract_State `protobuf:"varint,2,opt,name=state,proto3,enum=strmprivacy.api.entities.v1.EventContract_State" json:"state,omitempty"`
	SchemaRef *SchemaRef          `protobuf:"bytes,3,opt,name=schema_ref,json=schemaRef,proto3" json:"schema_ref,omitempty"`
	// (-- 'is' is intentional here (see https://google.aip.dev/140#booleans) --)
	IsPublic bool `protobuf:"varint,4,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"`
	// FIXME rename key_field to event_sequence_field
	KeyField    string                 `protobuf:"bytes,5,opt,name=key_field,json=keyField,proto3" json:"key_field,omitempty"`
	PiiFields   map[string]int32       `` /* 177-byte string literal not displayed */
	Validations []*Validation          `protobuf:"bytes,7,rep,name=validations,proto3" json:"validations,omitempty"`
	Metadata    *EventContractMetadata `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The UUID of this event contract
	Id               string `protobuf:"bytes,9,opt,name=id,proto3" json:"id,omitempty"`
	DataSubjectField string `protobuf:"bytes,10,opt,name=data_subject_field,json=dataSubjectField,proto3" json:"data_subject_field,omitempty"`
	// contains filtered or unexported fields
}

func (*EventContract) Descriptor deprecated

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

Deprecated: Use EventContract.ProtoReflect.Descriptor instead.

func (*EventContract) GetDataSubjectField added in v2.45.0

func (x *EventContract) GetDataSubjectField() string

func (*EventContract) GetId added in v2.36.0

func (x *EventContract) GetId() string

func (*EventContract) GetIsPublic

func (x *EventContract) GetIsPublic() bool

func (*EventContract) GetKeyField

func (x *EventContract) GetKeyField() string

func (*EventContract) GetMetadata

func (x *EventContract) GetMetadata() *EventContractMetadata

func (*EventContract) GetPiiFields

func (x *EventContract) GetPiiFields() map[string]int32

func (*EventContract) GetRef

func (x *EventContract) GetRef() *EventContractRef

func (*EventContract) GetSchemaRef

func (x *EventContract) GetSchemaRef() *SchemaRef

func (*EventContract) GetState

func (x *EventContract) GetState() EventContract_State

func (*EventContract) GetValidations

func (x *EventContract) GetValidations() []*Validation

func (*EventContract) ProtoMessage

func (*EventContract) ProtoMessage()

func (*EventContract) ProtoReflect

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

func (*EventContract) Reset

func (x *EventContract) Reset()

func (*EventContract) String

func (x *EventContract) String() string

type EventContractMetadata

type EventContractMetadata struct {

	// The human readable title of this Event Contract. Used in the Portal. Defaults to the Event Contract name. This field can be modified.
	Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	// The (optional) description of this Event Contract. Used in the Portal. Markdown syntax is supported. This field can be modified.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// The timestamp when this Event Contract was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The (optional) URI to the icon used with this Event Contract. This always an absolute URI, with the https scheme. Used in the Portal.
	IconUri string `protobuf:"bytes,4,opt,name=icon_uri,json=iconUri,proto3" json:"icon_uri,omitempty"`
	// Generic (key/value) labels for this Event Contract.
	Labels     []*Label `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"`
	Domains    []string `protobuf:"bytes,6,rep,name=domains,proto3" json:"domains,omitempty"`
	Industries []string `protobuf:"bytes,7,rep,name=industries,proto3" json:"industries,omitempty"`
	// contains filtered or unexported fields
}

func (*EventContractMetadata) Descriptor deprecated

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

Deprecated: Use EventContractMetadata.ProtoReflect.Descriptor instead.

func (*EventContractMetadata) GetCreateTime

func (x *EventContractMetadata) GetCreateTime() *timestamppb.Timestamp

func (*EventContractMetadata) GetDescription

func (x *EventContractMetadata) GetDescription() string

func (*EventContractMetadata) GetDomains

func (x *EventContractMetadata) GetDomains() []string

func (*EventContractMetadata) GetIconUri

func (x *EventContractMetadata) GetIconUri() string

func (*EventContractMetadata) GetIndustries

func (x *EventContractMetadata) GetIndustries() []string

func (*EventContractMetadata) GetLabels

func (x *EventContractMetadata) GetLabels() []*Label

func (*EventContractMetadata) GetTitle

func (x *EventContractMetadata) GetTitle() string

func (*EventContractMetadata) ProtoMessage

func (*EventContractMetadata) ProtoMessage()

func (*EventContractMetadata) ProtoReflect

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

func (*EventContractMetadata) Reset

func (x *EventContractMetadata) Reset()

func (*EventContractMetadata) String

func (x *EventContractMetadata) String() string

type EventContractRef

type EventContractRef struct {

	// constraint: handle should already exist
	Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"`
	// constraints: generic name constraint, unique within handle
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// constraints: semantic version, e.g. 1.12.3
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*EventContractRef) Descriptor deprecated

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

Deprecated: Use EventContractRef.ProtoReflect.Descriptor instead.

func (*EventContractRef) GetHandle

func (x *EventContractRef) GetHandle() string

func (*EventContractRef) GetName

func (x *EventContractRef) GetName() string

func (*EventContractRef) GetVersion

func (x *EventContractRef) GetVersion() string

func (*EventContractRef) ProtoMessage

func (*EventContractRef) ProtoMessage()

func (*EventContractRef) ProtoReflect

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

func (*EventContractRef) Reset

func (x *EventContractRef) Reset()

func (*EventContractRef) String

func (x *EventContractRef) String() string

type EventContract_State added in v2.19.0

type EventContract_State int32
const (
	EventContract_STATE_UNSPECIFIED EventContract_State = 0
	// This event contract is valid and complete, but has not been accepted yet, can still be modified and also deleted.
	EventContract_DRAFT EventContract_State = 1
	// This event contract is valid and complete can be used for events and batch jobs. It cannot be modified or deleted.
	EventContract_ACTIVE EventContract_State = 2
	// This event contract is valid and complete has been active, but no more events can be sent using this schema. In-flight events are still processed.
	EventContract_ARCHIVED EventContract_State = 3
	// This event contract is in review. It can be used once it has been approved.
	EventContract_IN_REVIEW EventContract_State = 4
	// This event contract is still under construction.
	EventContract_INCOMPLETE EventContract_State = 5
)

func (EventContract_State) Descriptor added in v2.19.0

func (EventContract_State) Enum added in v2.19.0

func (EventContract_State) EnumDescriptor deprecated added in v2.19.0

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

Deprecated: Use EventContract_State.Descriptor instead.

func (EventContract_State) Number added in v2.19.0

func (EventContract_State) String added in v2.19.0

func (x EventContract_State) String() string

func (EventContract_State) Type added in v2.19.0

type ExtendedBatchExporter added in v2.28.0

type ExtendedBatchExporter struct {

	// The UUID identifier of the Batch Exporter, used in Kubernetes
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// The Kafka Topic name that the Batch Exporter reads from
	Topic    string         `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Exporter *BatchExporter `protobuf:"bytes,3,opt,name=exporter,proto3" json:"exporter,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendedBatchExporter) Descriptor deprecated added in v2.28.0

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

Deprecated: Use ExtendedBatchExporter.ProtoReflect.Descriptor instead.

func (*ExtendedBatchExporter) GetExporter added in v2.28.0

func (x *ExtendedBatchExporter) GetExporter() *BatchExporter

func (*ExtendedBatchExporter) GetTopic added in v2.28.0

func (x *ExtendedBatchExporter) GetTopic() string

func (*ExtendedBatchExporter) GetUuid added in v2.28.0

func (x *ExtendedBatchExporter) GetUuid() string

func (*ExtendedBatchExporter) ProtoMessage added in v2.28.0

func (*ExtendedBatchExporter) ProtoMessage()

func (*ExtendedBatchExporter) ProtoReflect added in v2.28.0

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

func (*ExtendedBatchExporter) Reset added in v2.28.0

func (x *ExtendedBatchExporter) Reset()

func (*ExtendedBatchExporter) String added in v2.28.0

func (x *ExtendedBatchExporter) String() string

type ExtendedBatchJob added in v2.28.0

type ExtendedBatchJob struct {

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

func (*ExtendedBatchJob) Descriptor deprecated added in v2.28.0

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

Deprecated: Use ExtendedBatchJob.ProtoReflect.Descriptor instead.

func (*ExtendedBatchJob) GetBatchJob deprecated added in v2.28.0

func (x *ExtendedBatchJob) GetBatchJob() *BatchJob

Deprecated: Do not use.

func (*ExtendedBatchJob) GetJob added in v2.59.0

func (x *ExtendedBatchJob) GetJob() *BatchJobWrapper

func (*ExtendedBatchJob) ProtoMessage added in v2.28.0

func (*ExtendedBatchJob) ProtoMessage()

func (*ExtendedBatchJob) ProtoReflect added in v2.28.0

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

func (*ExtendedBatchJob) Reset added in v2.28.0

func (x *ExtendedBatchJob) Reset()

func (*ExtendedBatchJob) String added in v2.28.0

func (x *ExtendedBatchJob) String() string

type ExtendedStream added in v2.28.0

type ExtendedStream struct {
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// The Kafka Topic name that the data is published to
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// The UUID identifier of the Stream, used in Kubernetes
	Uuid string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// whether or not a key stream EXISTS for this stream.
	// So when this flag is true, there are TWO topics associated with this stream.
	// TODO: Rename to has_key_stream, requires many updates in api gateway.
	KeyStream bool `protobuf:"varint,4,opt,name=key_stream,json=keyStream,proto3" json:"key_stream,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendedStream) Descriptor deprecated added in v2.28.0

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

Deprecated: Use ExtendedStream.ProtoReflect.Descriptor instead.

func (*ExtendedStream) GetKeyStream added in v2.30.0

func (x *ExtendedStream) GetKeyStream() bool

func (*ExtendedStream) GetStream added in v2.28.0

func (x *ExtendedStream) GetStream() *Stream

func (*ExtendedStream) GetTopic added in v2.28.0

func (x *ExtendedStream) GetTopic() string

func (*ExtendedStream) GetUuid added in v2.28.0

func (x *ExtendedStream) GetUuid() string

func (*ExtendedStream) ProtoMessage added in v2.28.0

func (*ExtendedStream) ProtoMessage()

func (*ExtendedStream) ProtoReflect added in v2.28.0

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

func (*ExtendedStream) Reset added in v2.28.0

func (x *ExtendedStream) Reset()

func (*ExtendedStream) String added in v2.28.0

func (x *ExtendedStream) String() string

type ExtendedStreamGroup added in v2.28.0

type ExtendedStreamGroup struct {
	SourceStream   *ExtendedStream   `protobuf:"bytes,1,opt,name=source_stream,json=sourceStream,proto3" json:"source_stream,omitempty"`
	DerivedStreams []*ExtendedStream `protobuf:"bytes,2,rep,name=derived_streams,json=derivedStreams,proto3" json:"derived_streams,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendedStreamGroup) Descriptor deprecated added in v2.28.0

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

Deprecated: Use ExtendedStreamGroup.ProtoReflect.Descriptor instead.

func (*ExtendedStreamGroup) GetDerivedStreams added in v2.28.0

func (x *ExtendedStreamGroup) GetDerivedStreams() []*ExtendedStream

func (*ExtendedStreamGroup) GetSourceStream added in v2.28.0

func (x *ExtendedStreamGroup) GetSourceStream() *ExtendedStream

func (*ExtendedStreamGroup) ProtoMessage added in v2.28.0

func (*ExtendedStreamGroup) ProtoMessage()

func (*ExtendedStreamGroup) ProtoReflect added in v2.28.0

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

func (*ExtendedStreamGroup) Reset added in v2.28.0

func (x *ExtendedStreamGroup) Reset()

func (*ExtendedStreamGroup) String added in v2.28.0

func (x *ExtendedStreamGroup) String() string

type FieldMetadata added in v2.59.0

type FieldMetadata struct {

	// Full reference to a (nested) field. For non-top-level fields (i.e. nested fields), each level should be separated by a forward slash. E.g. customer/id.
	FieldName string `protobuf:"bytes,1,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// Metadata on the type of personal data this field may contain.
	PersonalDataConfig *FieldMetadata_PersonalDataConfig `protobuf:"bytes,2,opt,name=personal_data_config,json=personalDataConfig,proto3" json:"personal_data_config,omitempty"`
	// The statistical data type of the field, e.g. nominal, ordinal, numerical.
	StatisticalDataType StatisticalDataType `` /* 174-byte string literal not displayed */
	// If a field is of ordinal values, defines the possible values and their order.
	OrdinalValues []string `protobuf:"bytes,4,rep,name=ordinal_values,json=ordinalValues,proto3" json:"ordinal_values,omitempty"`
	// How null values should generally be dealt with for a field.
	NullHandlingConfig *FieldMetadata_NullHandlingConfig `protobuf:"bytes,5,opt,name=null_handling_config,json=nullHandlingConfig,proto3" json:"null_handling_config,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldMetadata) Descriptor deprecated added in v2.59.0

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

Deprecated: Use FieldMetadata.ProtoReflect.Descriptor instead.

func (*FieldMetadata) GetFieldName added in v2.59.0

func (x *FieldMetadata) GetFieldName() string

func (*FieldMetadata) GetNullHandlingConfig added in v2.59.0

func (x *FieldMetadata) GetNullHandlingConfig() *FieldMetadata_NullHandlingConfig

func (*FieldMetadata) GetOrdinalValues added in v2.61.0

func (x *FieldMetadata) GetOrdinalValues() []string

func (*FieldMetadata) GetPersonalDataConfig added in v2.61.0

func (x *FieldMetadata) GetPersonalDataConfig() *FieldMetadata_PersonalDataConfig

func (*FieldMetadata) GetStatisticalDataType added in v2.61.0

func (x *FieldMetadata) GetStatisticalDataType() StatisticalDataType

func (*FieldMetadata) ProtoMessage added in v2.59.0

func (*FieldMetadata) ProtoMessage()

func (*FieldMetadata) ProtoReflect added in v2.59.0

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

func (*FieldMetadata) Reset added in v2.59.0

func (x *FieldMetadata) Reset()

func (*FieldMetadata) String added in v2.59.0

func (x *FieldMetadata) String() string

type FieldMetadata_NullHandlingConfig added in v2.59.0

type FieldMetadata_NullHandlingConfig struct {
	Type FieldMetadata_NullHandlingConfig_NullHandlingType `` /* 145-byte string literal not displayed */
	// If the type is DEFAULT_VALUE, the desired default value must be specified.
	DefaultValue string `protobuf:"bytes,2,opt,name=default_value,json=defaultValue,proto3" json:"default_value,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldMetadata_NullHandlingConfig) Descriptor deprecated added in v2.59.0

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

Deprecated: Use FieldMetadata_NullHandlingConfig.ProtoReflect.Descriptor instead.

func (*FieldMetadata_NullHandlingConfig) GetDefaultValue added in v2.59.0

func (x *FieldMetadata_NullHandlingConfig) GetDefaultValue() string

func (*FieldMetadata_NullHandlingConfig) GetType added in v2.59.0

func (*FieldMetadata_NullHandlingConfig) ProtoMessage added in v2.59.0

func (*FieldMetadata_NullHandlingConfig) ProtoMessage()

func (*FieldMetadata_NullHandlingConfig) ProtoReflect added in v2.59.0

func (*FieldMetadata_NullHandlingConfig) Reset added in v2.59.0

func (*FieldMetadata_NullHandlingConfig) String added in v2.59.0

type FieldMetadata_NullHandlingConfig_NullHandlingType added in v2.59.0

type FieldMetadata_NullHandlingConfig_NullHandlingType int32
const (
	FieldMetadata_NullHandlingConfig_NULL_HANDLING_TYPE_UNSPECIFIED FieldMetadata_NullHandlingConfig_NullHandlingType = 0
	FieldMetadata_NullHandlingConfig_DROP_RECORD                    FieldMetadata_NullHandlingConfig_NullHandlingType = 1
	FieldMetadata_NullHandlingConfig_DEFAULT_VALUE                  FieldMetadata_NullHandlingConfig_NullHandlingType = 2
)

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Descriptor added in v2.59.0

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Enum added in v2.59.0

func (FieldMetadata_NullHandlingConfig_NullHandlingType) EnumDescriptor deprecated added in v2.59.0

Deprecated: Use FieldMetadata_NullHandlingConfig_NullHandlingType.Descriptor instead.

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Number added in v2.59.0

func (FieldMetadata_NullHandlingConfig_NullHandlingType) String added in v2.59.0

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Type added in v2.59.0

type FieldMetadata_PersonalDataConfig added in v2.61.0

type FieldMetadata_PersonalDataConfig struct {

	// Currently, only string fields or repeated string fields can be marked as PII, since other data types cannot store an encrypted string.
	IsPii bool `protobuf:"varint,1,opt,name=is_pii,json=isPii,proto3" json:"is_pii,omitempty"`
	// A quasi identifier doesn't identify an individual directly, but combined with other QIs can result in a unique (direct) identifier.
	IsQuasiId bool `protobuf:"varint,2,opt,name=is_quasi_id,json=isQuasiId,proto3" json:"is_quasi_id,omitempty"`
	// The purpose level as defined in the purpose level mapping of an organization.
	PurposeLevel int32 `protobuf:"varint,3,opt,name=purpose_level,json=purposeLevel,proto3" json:"purpose_level,omitempty"`
	// The special sensitive data type as defined by the GDPR https://eur-lex.europa.eu/legal-content/EN/TXT/HTML/?uri=CELEX:32016R0679#d1e2051-1-1
	GdprSpecialPersonalDataType string `` /* 148-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FieldMetadata_PersonalDataConfig) Descriptor deprecated added in v2.61.0

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

Deprecated: Use FieldMetadata_PersonalDataConfig.ProtoReflect.Descriptor instead.

func (*FieldMetadata_PersonalDataConfig) GetGdprSpecialPersonalDataType added in v2.66.0

func (x *FieldMetadata_PersonalDataConfig) GetGdprSpecialPersonalDataType() string

func (*FieldMetadata_PersonalDataConfig) GetIsPii added in v2.61.0

func (x *FieldMetadata_PersonalDataConfig) GetIsPii() bool

func (*FieldMetadata_PersonalDataConfig) GetIsQuasiId added in v2.61.0

func (x *FieldMetadata_PersonalDataConfig) GetIsQuasiId() bool

func (*FieldMetadata_PersonalDataConfig) GetPurposeLevel added in v2.61.0

func (x *FieldMetadata_PersonalDataConfig) GetPurposeLevel() int32

func (*FieldMetadata_PersonalDataConfig) ProtoMessage added in v2.61.0

func (*FieldMetadata_PersonalDataConfig) ProtoMessage()

func (*FieldMetadata_PersonalDataConfig) ProtoReflect added in v2.61.0

func (*FieldMetadata_PersonalDataConfig) Reset added in v2.61.0

func (*FieldMetadata_PersonalDataConfig) String added in v2.61.0

type FilterPublicPrivate

type FilterPublicPrivate int32
const (
	FilterPublicPrivate_FILTER_PUBLIC_PRIVATE_UNSPECIFIED FilterPublicPrivate = 0
	FilterPublicPrivate_ONLY_PUBLIC                       FilterPublicPrivate = 1
	FilterPublicPrivate_ONLY_PRIVATE                      FilterPublicPrivate = 2
)

func (FilterPublicPrivate) Descriptor

func (FilterPublicPrivate) Enum

func (FilterPublicPrivate) EnumDescriptor deprecated

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

Deprecated: Use FilterPublicPrivate.Descriptor instead.

func (FilterPublicPrivate) Number

func (FilterPublicPrivate) String

func (x FilterPublicPrivate) String() string

func (FilterPublicPrivate) Type

type GenericRef added in v2.82.0

type GenericRef struct {

	// Types that are assignable to Ref:
	//
	//	*GenericRef_DataContractRef
	Ref isGenericRef_Ref `protobuf_oneof:"ref"`
	// contains filtered or unexported fields
}

A generic reference to an entity. This is used to reference entities in a generic way, e.g. in comments or audit trails.

func (*GenericRef) Descriptor deprecated added in v2.82.0

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

Deprecated: Use GenericRef.ProtoReflect.Descriptor instead.

func (*GenericRef) GetDataContractRef added in v2.82.0

func (x *GenericRef) GetDataContractRef() *DataContractRef

func (*GenericRef) GetRef added in v2.82.0

func (m *GenericRef) GetRef() isGenericRef_Ref

func (*GenericRef) ProtoMessage added in v2.82.0

func (*GenericRef) ProtoMessage()

func (*GenericRef) ProtoReflect added in v2.82.0

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

func (*GenericRef) Reset added in v2.82.0

func (x *GenericRef) Reset()

func (*GenericRef) String added in v2.82.0

func (x *GenericRef) String() string

type GenericRef_DataContractRef added in v2.82.0

type GenericRef_DataContractRef struct {
	DataContractRef *DataContractRef `protobuf:"bytes,1,opt,name=data_contract_ref,json=dataContractRef,proto3,oneof"`
}

type GoogleCloudStorageBucketLocation added in v2.16.0

type GoogleCloudStorageBucketLocation 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 Google Cloud Service Account credentials JSON that is used to access the Google Cloud Storage bucket.
	// We do not support credentials in P12 format.
	Credentials string `protobuf:"bytes,2,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// contains filtered or unexported fields
}

func (*GoogleCloudStorageBucketLocation) Descriptor deprecated added in v2.16.0

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

Deprecated: Use GoogleCloudStorageBucketLocation.ProtoReflect.Descriptor instead.

func (*GoogleCloudStorageBucketLocation) GetBucketName added in v2.16.0

func (x *GoogleCloudStorageBucketLocation) GetBucketName() string

func (*GoogleCloudStorageBucketLocation) GetCredentials added in v2.16.0

func (x *GoogleCloudStorageBucketLocation) GetCredentials() string

func (*GoogleCloudStorageBucketLocation) ProtoMessage added in v2.16.0

func (*GoogleCloudStorageBucketLocation) ProtoMessage()

func (*GoogleCloudStorageBucketLocation) ProtoReflect added in v2.16.0

func (*GoogleCloudStorageBucketLocation) Reset added in v2.16.0

func (*GoogleCloudStorageBucketLocation) String added in v2.16.0

type JdbcLocation added in v2.77.0

type JdbcLocation struct {
	JdbcUri string `protobuf:"bytes,1,opt,name=jdbc_uri,json=jdbcUri,proto3" json:"jdbc_uri,omitempty"`
	// this is a private key for a service account to authenticate with google bigquery. It is added by the cli upon
	// creating the jdbc data connector
	PrivateKey   string       `protobuf:"bytes,2,opt,name=private_key,json=privateKey,proto3" json:"private_key,omitempty"`
	DatabaseType DatabaseType `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*JdbcLocation) Descriptor deprecated added in v2.77.0

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

Deprecated: Use JdbcLocation.ProtoReflect.Descriptor instead.

func (*JdbcLocation) GetDatabaseType added in v2.77.0

func (x *JdbcLocation) GetDatabaseType() DatabaseType

func (*JdbcLocation) GetJdbcUri added in v2.77.0

func (x *JdbcLocation) GetJdbcUri() string

func (*JdbcLocation) GetPrivateKey added in v2.78.0

func (x *JdbcLocation) GetPrivateKey() string

func (*JdbcLocation) ProtoMessage added in v2.77.0

func (*JdbcLocation) ProtoMessage()

func (*JdbcLocation) ProtoReflect added in v2.77.0

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

func (*JdbcLocation) Reset added in v2.77.0

func (x *JdbcLocation) Reset()

func (*JdbcLocation) String added in v2.77.0

func (x *JdbcLocation) String() string

type KafkaCluster

type KafkaCluster struct {
	Ref              *KafkaClusterRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	BootstrapServers string           `protobuf:"bytes,2,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"`
	AuthMechanism    AuthMechanism    `` /* 148-byte string literal not displayed */
	TokenUri         string           `protobuf:"bytes,4,opt,name=token_uri,json=tokenUri,proto3" json:"token_uri,omitempty"`
	// contains filtered or unexported fields
}

Currently only our internal shared export cluster.

func (*KafkaCluster) Descriptor deprecated

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

Deprecated: Use KafkaCluster.ProtoReflect.Descriptor instead.

func (*KafkaCluster) GetAuthMechanism

func (x *KafkaCluster) GetAuthMechanism() AuthMechanism

func (*KafkaCluster) GetBootstrapServers

func (x *KafkaCluster) GetBootstrapServers() string

func (*KafkaCluster) GetRef

func (x *KafkaCluster) GetRef() *KafkaClusterRef

func (*KafkaCluster) GetTokenUri

func (x *KafkaCluster) GetTokenUri() string

func (*KafkaCluster) ProtoMessage

func (*KafkaCluster) ProtoMessage()

func (*KafkaCluster) ProtoReflect

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

func (*KafkaCluster) Reset

func (x *KafkaCluster) Reset()

func (*KafkaCluster) String

func (x *KafkaCluster) String() string

type KafkaClusterRef

type KafkaClusterRef struct {

	// (-- streammachine for the default export cluster --)
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	// constraints: generic name constraint
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

How to refer to a certain Kafka cluster.

func (*KafkaClusterRef) Descriptor deprecated

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

Deprecated: Use KafkaClusterRef.ProtoReflect.Descriptor instead.

func (*KafkaClusterRef) GetBillingId

func (x *KafkaClusterRef) GetBillingId() string

func (*KafkaClusterRef) GetName

func (x *KafkaClusterRef) GetName() string

func (*KafkaClusterRef) GetProjectId added in v2.38.0

func (x *KafkaClusterRef) GetProjectId() string

func (*KafkaClusterRef) ProtoMessage

func (*KafkaClusterRef) ProtoMessage()

func (*KafkaClusterRef) ProtoReflect

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

func (*KafkaClusterRef) Reset

func (x *KafkaClusterRef) Reset()

func (*KafkaClusterRef) String

func (x *KafkaClusterRef) String() string

type KafkaExporter

type KafkaExporter struct {
	Ref       *KafkaExporterRef    `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	StreamRef *StreamRef           `protobuf:"bytes,2,opt,name=stream_ref,json=streamRef,proto3" json:"stream_ref,omitempty"`
	Target    *KafkaExporterTarget `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Users     []*KafkaUser         `protobuf:"bytes,4,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaExporter) Descriptor deprecated

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

Deprecated: Use KafkaExporter.ProtoReflect.Descriptor instead.

func (*KafkaExporter) GetRef

func (x *KafkaExporter) GetRef() *KafkaExporterRef

func (*KafkaExporter) GetStreamRef

func (x *KafkaExporter) GetStreamRef() *StreamRef

func (*KafkaExporter) GetTarget

func (x *KafkaExporter) GetTarget() *KafkaExporterTarget

func (*KafkaExporter) GetUsers

func (x *KafkaExporter) GetUsers() []*KafkaUser

func (*KafkaExporter) ProtoMessage

func (*KafkaExporter) ProtoMessage()

func (*KafkaExporter) ProtoReflect

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

func (*KafkaExporter) Reset

func (x *KafkaExporter) Reset()

func (*KafkaExporter) String

func (x *KafkaExporter) String() string

type KafkaExporterRef

type KafkaExporterRef struct {
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	// default value  <cluster-name>-<stream-name>
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaExporterRef) Descriptor deprecated

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

Deprecated: Use KafkaExporterRef.ProtoReflect.Descriptor instead.

func (*KafkaExporterRef) GetBillingId

func (x *KafkaExporterRef) GetBillingId() string

func (*KafkaExporterRef) GetName

func (x *KafkaExporterRef) GetName() string

func (*KafkaExporterRef) GetProjectId added in v2.38.0

func (x *KafkaExporterRef) GetProjectId() string

func (*KafkaExporterRef) ProtoMessage

func (*KafkaExporterRef) ProtoMessage()

func (*KafkaExporterRef) ProtoReflect

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

func (*KafkaExporterRef) Reset

func (x *KafkaExporterRef) Reset()

func (*KafkaExporterRef) String

func (x *KafkaExporterRef) String() string

type KafkaExporterTarget

type KafkaExporterTarget struct {

	// what cluster to produce to
	ClusterRef *KafkaClusterRef `protobuf:"bytes,1,opt,name=cluster_ref,json=clusterRef,proto3" json:"cluster_ref,omitempty"`
	// the topic this exporter produces to
	// constraints: access checked on creation of kafka exporter
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// used to access the target Kafka Cluster in case of OAuth based authentication
	ClientId string `protobuf:"bytes,3,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// used to access the target Kafka Cluster in case of OAuth based authentication
	ClientSecret string `protobuf:"bytes,4,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaExporterTarget) Descriptor deprecated

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

Deprecated: Use KafkaExporterTarget.ProtoReflect.Descriptor instead.

func (*KafkaExporterTarget) GetClientId

func (x *KafkaExporterTarget) GetClientId() string

func (*KafkaExporterTarget) GetClientSecret

func (x *KafkaExporterTarget) GetClientSecret() string

func (*KafkaExporterTarget) GetClusterRef

func (x *KafkaExporterTarget) GetClusterRef() *KafkaClusterRef

func (*KafkaExporterTarget) GetTopic

func (x *KafkaExporterTarget) GetTopic() string

func (*KafkaExporterTarget) ProtoMessage

func (*KafkaExporterTarget) ProtoMessage()

func (*KafkaExporterTarget) ProtoReflect

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

func (*KafkaExporterTarget) Reset

func (x *KafkaExporterTarget) Reset()

func (*KafkaExporterTarget) String

func (x *KafkaExporterTarget) String() string

type KafkaUser

type KafkaUser struct {
	Ref *KafkaUserRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// (-- api-linter: core::0122::name-suffix=disabled
	//
	//	aip.dev/not-precedent: We refer to the kafka exporter by name. --)
	KafkaExporterName string           `protobuf:"bytes,3,opt,name=kafka_exporter_name,json=kafkaExporterName,proto3" json:"kafka_exporter_name,omitempty"`
	Topic             string           `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic,omitempty"`
	ClientId          string           `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	ClientSecret      string           `protobuf:"bytes,6,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`
	ClusterRef        *KafkaClusterRef `protobuf:"bytes,7,opt,name=cluster_ref,json=clusterRef,proto3" json:"cluster_ref,omitempty"`
	// contains filtered or unexported fields
}

User credentials to consume from topic produced by Kafka Exporter.

The kafka exporter is linked to a certain cluster, so this entity is bound to a certain kafka cluster.

func (*KafkaUser) Descriptor deprecated

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

Deprecated: Use KafkaUser.ProtoReflect.Descriptor instead.

func (*KafkaUser) GetClientId

func (x *KafkaUser) GetClientId() string

func (*KafkaUser) GetClientSecret

func (x *KafkaUser) GetClientSecret() string

func (*KafkaUser) GetClusterRef

func (x *KafkaUser) GetClusterRef() *KafkaClusterRef

func (*KafkaUser) GetKafkaExporterName

func (x *KafkaUser) GetKafkaExporterName() string

func (*KafkaUser) GetRef

func (x *KafkaUser) GetRef() *KafkaUserRef

func (*KafkaUser) GetTopic

func (x *KafkaUser) GetTopic() string

func (*KafkaUser) ProtoMessage

func (*KafkaUser) ProtoMessage()

func (*KafkaUser) ProtoReflect

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

func (*KafkaUser) Reset

func (x *KafkaUser) Reset()

func (*KafkaUser) String

func (x *KafkaUser) String() string

type KafkaUserRef

type KafkaUserRef struct {

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

func (*KafkaUserRef) Descriptor deprecated

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

Deprecated: Use KafkaUserRef.ProtoReflect.Descriptor instead.

func (*KafkaUserRef) GetBillingId deprecated

func (x *KafkaUserRef) GetBillingId() string

Deprecated: Do not use.

func (*KafkaUserRef) GetName

func (x *KafkaUserRef) GetName() string

func (*KafkaUserRef) GetProjectId added in v2.38.0

func (x *KafkaUserRef) GetProjectId() string

func (*KafkaUserRef) ProtoMessage

func (*KafkaUserRef) ProtoMessage()

func (*KafkaUserRef) ProtoReflect

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

func (*KafkaUserRef) Reset

func (x *KafkaUserRef) Reset()

func (*KafkaUserRef) String

func (x *KafkaUserRef) String() string

type KeyStream

type KeyStream struct {
	Ref *KeyStreamRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// -- TODO: this field is not used --
	//
	// Deprecated: Do not use.
	Status     string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	KafkaTopic string `protobuf:"bytes,3,opt,name=kafka_topic,json=kafkaTopic,proto3" json:"kafka_topic,omitempty"`
	// contains filtered or unexported fields
}

A Stream of key-link, encryption-key, policy-id messages created from a source stream with the same `name`.

func (*KeyStream) Descriptor deprecated

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

Deprecated: Use KeyStream.ProtoReflect.Descriptor instead.

func (*KeyStream) GetKafkaTopic added in v2.35.0

func (x *KeyStream) GetKafkaTopic() string

func (*KeyStream) GetRef

func (x *KeyStream) GetRef() *KeyStreamRef

func (*KeyStream) GetStatus deprecated

func (x *KeyStream) GetStatus() string

Deprecated: Do not use.

func (*KeyStream) ProtoMessage

func (*KeyStream) ProtoMessage()

func (*KeyStream) ProtoReflect

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

func (*KeyStream) Reset

func (x *KeyStream) Reset()

func (*KeyStream) String

func (x *KeyStream) String() string

type KeyStreamRef

type KeyStreamRef struct {

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

refers to a key stream.

func (*KeyStreamRef) Descriptor deprecated

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

Deprecated: Use KeyStreamRef.ProtoReflect.Descriptor instead.

func (*KeyStreamRef) GetBillingId deprecated

func (x *KeyStreamRef) GetBillingId() string

Deprecated: Do not use.

func (*KeyStreamRef) GetName

func (x *KeyStreamRef) GetName() string

func (*KeyStreamRef) GetProjectId added in v2.38.0

func (x *KeyStreamRef) GetProjectId() string

func (*KeyStreamRef) ProtoMessage

func (*KeyStreamRef) ProtoMessage()

func (*KeyStreamRef) ProtoReflect

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

func (*KeyStreamRef) Reset

func (x *KeyStreamRef) Reset()

func (*KeyStreamRef) String

func (x *KeyStreamRef) String() string

type Label

type Label struct {

	// The key of the label.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value of the label. An empty string means there is no value.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Label) Descriptor deprecated

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

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) GetKey

func (x *Label) GetKey() string

func (*Label) GetValue

func (x *Label) GetValue() string

func (*Label) ProtoMessage

func (*Label) ProtoMessage()

func (*Label) ProtoReflect

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

func (*Label) Reset

func (x *Label) Reset()

func (*Label) String

func (x *Label) String() string

type Limits

type Limits struct {

	// filled in from customer profile
	EventRate int64 `protobuf:"varint,1,opt,name=event_rate,json=eventRate,proto3" json:"event_rate,omitempty"`
	// filled in from customer profile
	EventCount int64 `protobuf:"varint,2,opt,name=event_count,json=eventCount,proto3" json:"event_count,omitempty"`
	// contains filtered or unexported fields
}

func (*Limits) Descriptor deprecated

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

Deprecated: Use Limits.ProtoReflect.Descriptor instead.

func (*Limits) GetEventCount

func (x *Limits) GetEventCount() int64

func (*Limits) GetEventRate

func (x *Limits) GetEventRate() int64

func (*Limits) ProtoMessage

func (*Limits) ProtoMessage()

func (*Limits) ProtoReflect

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

func (*Limits) Reset

func (x *Limits) Reset()

func (*Limits) String

func (x *Limits) String() string

type MaskedFields

type MaskedFields struct {

	// Default Murmurhash3 if empty
	HashType string `protobuf:"bytes,1,opt,name=hash_type,json=hashType,proto3" json:"hash_type,omitempty"`
	// hashing seed
	Seed string `protobuf:"bytes,2,opt,name=seed,proto3" json:"seed,omitempty"`
	// map of event-contract-ref vs field patterns
	//
	// constraints:
	// data-contract-refs should be existing data contracts
	// field_patterns should be valid values (checked by events-core)
	// the field_patterns list should have no duplicates.
	FieldPatterns map[string]*MaskedFields_PatternList `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MaskedFields) Descriptor deprecated

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

Deprecated: Use MaskedFields.ProtoReflect.Descriptor instead.

func (*MaskedFields) GetFieldPatterns

func (x *MaskedFields) GetFieldPatterns() map[string]*MaskedFields_PatternList

func (*MaskedFields) GetHashType

func (x *MaskedFields) GetHashType() string

func (*MaskedFields) GetSeed

func (x *MaskedFields) GetSeed() string

func (*MaskedFields) ProtoMessage

func (*MaskedFields) ProtoMessage()

func (*MaskedFields) ProtoReflect

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

func (*MaskedFields) Reset

func (x *MaskedFields) Reset()

func (*MaskedFields) String

func (x *MaskedFields) String() string

type MaskedFields_PatternList

type MaskedFields_PatternList struct {
	FieldPatterns []string `protobuf:"bytes,1,rep,name=field_patterns,json=fieldPatterns,proto3" json:"field_patterns,omitempty"`
	// contains filtered or unexported fields
}

func (*MaskedFields_PatternList) Descriptor deprecated

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

Deprecated: Use MaskedFields_PatternList.ProtoReflect.Descriptor instead.

func (*MaskedFields_PatternList) GetFieldPatterns

func (x *MaskedFields_PatternList) GetFieldPatterns() []string

func (*MaskedFields_PatternList) ProtoMessage

func (*MaskedFields_PatternList) ProtoMessage()

func (*MaskedFields_PatternList) ProtoReflect

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

func (*MaskedFields_PatternList) Reset

func (x *MaskedFields_PatternList) Reset()

func (*MaskedFields_PatternList) String

func (x *MaskedFields_PatternList) String() string

type MicroAggregationBatchJob added in v2.59.0

type MicroAggregationBatchJob 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      *DataConnectorAndType `protobuf:"bytes,3,opt,name=source_data,json=sourceData,proto3" json:"source_data,omitempty"`
	TargetData      *DataConnectorAndType `protobuf:"bytes,4,opt,name=target_data,json=targetData,proto3" json:"target_data,omitempty"`
	DataContractRef *DataContractRef      `protobuf:"bytes,5,opt,name=data_contract_ref,json=dataContractRef,proto3" json:"data_contract_ref,omitempty"`
	// Configuration specifically for the aggregation algorithm.
	AggregationConfig *MicroAggregationConfig `protobuf:"bytes,6,opt,name=aggregation_config,json=aggregationConfig,proto3" json:"aggregation_config,omitempty"`
	// contains filtered or unexported fields
}

******************************** K-Member Micro-aggregation Batch Job Currently we only support: - CSV as DataFormat type - CSV files with a header row, because the header is needed to get the field names - Numerical, Categorical & Ordinal data *******************************

func (*MicroAggregationBatchJob) Descriptor deprecated added in v2.59.0

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

Deprecated: Use MicroAggregationBatchJob.ProtoReflect.Descriptor instead.

func (*MicroAggregationBatchJob) GetAggregationConfig added in v2.59.0

func (x *MicroAggregationBatchJob) GetAggregationConfig() *MicroAggregationConfig

func (*MicroAggregationBatchJob) GetDataContractRef added in v2.59.0

func (x *MicroAggregationBatchJob) GetDataContractRef() *DataContractRef

func (*MicroAggregationBatchJob) GetRef added in v2.59.0

func (*MicroAggregationBatchJob) GetSourceData added in v2.59.0

func (x *MicroAggregationBatchJob) GetSourceData() *DataConnectorAndType

func (*MicroAggregationBatchJob) GetStates added in v2.59.0

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

func (*MicroAggregationBatchJob) GetTargetData added in v2.59.0

func (x *MicroAggregationBatchJob) GetTargetData() *DataConnectorAndType

func (*MicroAggregationBatchJob) ProtoMessage added in v2.59.0

func (*MicroAggregationBatchJob) ProtoMessage()

func (*MicroAggregationBatchJob) ProtoReflect added in v2.59.0

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

func (*MicroAggregationBatchJob) Reset added in v2.59.0

func (x *MicroAggregationBatchJob) Reset()

func (*MicroAggregationBatchJob) String added in v2.59.0

func (x *MicroAggregationBatchJob) String() string

type MicroAggregationConfig added in v2.59.0

type MicroAggregationConfig struct {

	// The desired k-anonymity level.
	MinimumKAnonymity int32 `protobuf:"varint,1,opt,name=minimum_k_anonymity,json=minimumKAnonymity,proto3" json:"minimum_k_anonymity,omitempty"`
	// If specified, these fields will be used to aggregate on. Otherwise, fields specified as Quasi Identifiers in the data contract are used instead.
	AggregationFields []string `protobuf:"bytes,2,rep,name=aggregation_fields,json=aggregationFields,proto3" json:"aggregation_fields,omitempty"`
	// contains filtered or unexported fields
}

func (*MicroAggregationConfig) Descriptor deprecated added in v2.59.0

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

Deprecated: Use MicroAggregationConfig.ProtoReflect.Descriptor instead.

func (*MicroAggregationConfig) GetAggregationFields added in v2.59.0

func (x *MicroAggregationConfig) GetAggregationFields() []string

func (*MicroAggregationConfig) GetMinimumKAnonymity added in v2.59.0

func (x *MicroAggregationConfig) GetMinimumKAnonymity() int32

func (*MicroAggregationConfig) ProtoMessage added in v2.59.0

func (*MicroAggregationConfig) ProtoMessage()

func (*MicroAggregationConfig) ProtoReflect added in v2.59.0

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

func (*MicroAggregationConfig) Reset added in v2.59.0

func (x *MicroAggregationConfig) Reset()

func (*MicroAggregationConfig) String added in v2.59.0

func (x *MicroAggregationConfig) String() string

type Policy added in v2.58.0

type Policy struct {
	Id           string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name         string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description  string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	LegalGrounds string `protobuf:"bytes,4,opt,name=legal_grounds,json=legalGrounds,proto3" json:"legal_grounds,omitempty"`
	// Can be empty during an update, field mask specifies which fields actually get modified.
	RetentionDays int32        `protobuf:"varint,5,opt,name=retention_days,json=retentionDays,proto3" json:"retention_days,omitempty"`
	State         Policy_State `protobuf:"varint,6,opt,name=state,proto3,enum=strmprivacy.api.entities.v1.Policy_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*Policy) Descriptor deprecated added in v2.58.0

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

Deprecated: Use Policy.ProtoReflect.Descriptor instead.

func (*Policy) GetDescription added in v2.58.0

func (x *Policy) GetDescription() string

func (*Policy) GetId added in v2.58.0

func (x *Policy) GetId() string

func (*Policy) GetLegalGrounds added in v2.58.0

func (x *Policy) GetLegalGrounds() string

func (*Policy) GetName added in v2.58.0

func (x *Policy) GetName() string

func (*Policy) GetRetentionDays added in v2.58.0

func (x *Policy) GetRetentionDays() int32

func (*Policy) GetState added in v2.58.0

func (x *Policy) GetState() Policy_State

func (*Policy) ProtoMessage added in v2.58.0

func (*Policy) ProtoMessage()

func (*Policy) ProtoReflect added in v2.58.0

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

func (*Policy) Reset added in v2.58.0

func (x *Policy) Reset()

func (*Policy) String added in v2.58.0

func (x *Policy) String() string

type Policy_State added in v2.58.0

type Policy_State int32
const (
	Policy_STATE_UNSPECIFIED Policy_State = 0
	Policy_STATE_DRAFT       Policy_State = 1
	Policy_STATE_ACTIVE      Policy_State = 2
	Policy_STATE_ARCHIVED    Policy_State = 3
)

func (Policy_State) Descriptor added in v2.58.0

func (Policy_State) Enum added in v2.58.0

func (x Policy_State) Enum() *Policy_State

func (Policy_State) EnumDescriptor deprecated added in v2.58.0

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

Deprecated: Use Policy_State.Descriptor instead.

func (Policy_State) Number added in v2.58.0

func (Policy_State) String added in v2.58.0

func (x Policy_State) String() string

func (Policy_State) Type added in v2.58.0

type Project added in v2.37.0

type Project struct {
	Id             string        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name           string        `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description    string        `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	OrganizationId string        `protobuf:"bytes,4,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	State          Project_State `protobuf:"varint,5,opt,name=state,proto3,enum=strmprivacy.api.entities.v1.Project_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*Project) Descriptor deprecated added in v2.37.0

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

Deprecated: Use Project.ProtoReflect.Descriptor instead.

func (*Project) GetDescription added in v2.38.0

func (x *Project) GetDescription() string

func (*Project) GetId added in v2.37.0

func (x *Project) GetId() string

func (*Project) GetName added in v2.38.0

func (x *Project) GetName() string

func (*Project) GetOrganizationId added in v2.44.0

func (x *Project) GetOrganizationId() string

func (*Project) GetState added in v2.54.0

func (x *Project) GetState() Project_State

func (*Project) ProtoMessage added in v2.37.0

func (*Project) ProtoMessage()

func (*Project) ProtoReflect added in v2.37.0

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

func (*Project) Reset added in v2.37.0

func (x *Project) Reset()

func (*Project) String added in v2.37.0

func (x *Project) String() string

type Project_State added in v2.54.0

type Project_State int32
const (
	Project_STATE_UNSPECIFIED Project_State = 0
	Project_OPERATIONAL       Project_State = 1
	Project_PENDING_DELETION  Project_State = 2
)

func (Project_State) Descriptor added in v2.54.0

func (Project_State) Enum added in v2.54.0

func (x Project_State) Enum() *Project_State

func (Project_State) EnumDescriptor deprecated added in v2.54.0

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

Deprecated: Use Project_State.Descriptor instead.

func (Project_State) Number added in v2.54.0

func (Project_State) String added in v2.54.0

func (x Project_State) String() string

func (Project_State) Type added in v2.54.0

type PurposeMapping added in v2.67.0

type PurposeMapping struct {

	// an integer, which retains the same technical function as the original "consent level"
	Level int32 `protobuf:"varint,1,opt,name=level,proto3" json:"level,omitempty"`
	// a name/short description of the purpose, e.g. "Analytics", "Functional"
	Purpose string `protobuf:"bytes,2,opt,name=purpose,proto3" json:"purpose,omitempty"`
	// a more elaborate description
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*PurposeMapping) Descriptor deprecated added in v2.67.0

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

Deprecated: Use PurposeMapping.ProtoReflect.Descriptor instead.

func (*PurposeMapping) GetDescription added in v2.67.0

func (x *PurposeMapping) GetDescription() string

func (*PurposeMapping) GetLevel added in v2.67.0

func (x *PurposeMapping) GetLevel() int32

func (*PurposeMapping) GetPurpose added in v2.67.0

func (x *PurposeMapping) GetPurpose() string

func (*PurposeMapping) ProtoMessage added in v2.67.0

func (*PurposeMapping) ProtoMessage()

func (*PurposeMapping) ProtoReflect added in v2.67.0

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

func (*PurposeMapping) Reset added in v2.67.0

func (x *PurposeMapping) Reset()

func (*PurposeMapping) String added in v2.67.0

func (x *PurposeMapping) String() string

type Schema

type Schema struct {
	Ref   *SchemaRef   `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	State Schema_State `protobuf:"varint,2,opt,name=state,proto3,enum=strmprivacy.api.entities.v1.Schema_State" json:"state,omitempty"`
	// (-- 'is' is intentional here (see https://google.aip.dev/140#booleans) --)
	IsPublic bool `protobuf:"varint,3,opt,name=is_public,json=isPublic,proto3" json:"is_public,omitempty"`
	// constraints: is no longer required provided simple_schema is not empty.
	Definition   string                         `protobuf:"bytes,4,opt,name=definition,proto3" json:"definition,omitempty"`
	Fingerprint  string                         `protobuf:"bytes,5,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	Metadata     *SchemaMetadata                `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	SimpleSchema *Schema_SimpleSchemaDefinition `protobuf:"bytes,7,opt,name=simple_schema,json=simpleSchema,proto3" json:"simple_schema,omitempty"`
	// The UUID of this schema
	Id string `protobuf:"bytes,8,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Schema) Descriptor deprecated

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetDefinition

func (x *Schema) GetDefinition() string

func (*Schema) GetFingerprint

func (x *Schema) GetFingerprint() string

func (*Schema) GetId added in v2.36.0

func (x *Schema) GetId() string

func (*Schema) GetIsPublic

func (x *Schema) GetIsPublic() bool

func (*Schema) GetMetadata

func (x *Schema) GetMetadata() *SchemaMetadata

func (*Schema) GetRef

func (x *Schema) GetRef() *SchemaRef

func (*Schema) GetSimpleSchema

func (x *Schema) GetSimpleSchema() *Schema_SimpleSchemaDefinition

func (*Schema) GetState

func (x *Schema) GetState() Schema_State

func (*Schema) ProtoMessage

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect

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

func (*Schema) Reset

func (x *Schema) Reset()

func (*Schema) String

func (x *Schema) String() string

type SchemaMetadata

type SchemaMetadata struct {

	// The human readable title of this Schema. Used in the Portal. Defaults to the Schema name. This field can be modified.
	Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	// The description of this Schema. Used in the Portal. Markdown syntax is supported. This field can be modified.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// The timestamp when this Schema was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The URI to the icon used with this Schema. This always an absolute URI, with the https scheme. Used in the Portal.
	IconUri string `protobuf:"bytes,4,opt,name=icon_uri,json=iconUri,proto3" json:"icon_uri,omitempty"`
	// Generic (key/value) labels for this Schema.
	Labels     []*Label `protobuf:"bytes,5,rep,name=labels,proto3" json:"labels,omitempty"`
	Domains    []string `protobuf:"bytes,6,rep,name=domains,proto3" json:"domains,omitempty"`
	Industries []string `protobuf:"bytes,7,rep,name=industries,proto3" json:"industries,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaMetadata) Descriptor deprecated

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

Deprecated: Use SchemaMetadata.ProtoReflect.Descriptor instead.

func (*SchemaMetadata) GetCreateTime

func (x *SchemaMetadata) GetCreateTime() *timestamppb.Timestamp

func (*SchemaMetadata) GetDescription

func (x *SchemaMetadata) GetDescription() string

func (*SchemaMetadata) GetDomains

func (x *SchemaMetadata) GetDomains() []string

func (*SchemaMetadata) GetIconUri

func (x *SchemaMetadata) GetIconUri() string

func (*SchemaMetadata) GetIndustries

func (x *SchemaMetadata) GetIndustries() []string

func (*SchemaMetadata) GetLabels

func (x *SchemaMetadata) GetLabels() []*Label

func (*SchemaMetadata) GetTitle

func (x *SchemaMetadata) GetTitle() string

func (*SchemaMetadata) ProtoMessage

func (*SchemaMetadata) ProtoMessage()

func (*SchemaMetadata) ProtoReflect

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

func (*SchemaMetadata) Reset

func (x *SchemaMetadata) Reset()

func (*SchemaMetadata) String

func (x *SchemaMetadata) String() string

type SchemaRef

type SchemaRef struct {

	// constraints: generic name constraint
	Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"`
	// constraints: generic name constraint
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// constraints: `\d+\.\d+\.\d+
	Version    string     `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	SchemaType SchemaType `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SchemaRef) Descriptor deprecated

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

Deprecated: Use SchemaRef.ProtoReflect.Descriptor instead.

func (*SchemaRef) GetHandle

func (x *SchemaRef) GetHandle() string

func (*SchemaRef) GetName

func (x *SchemaRef) GetName() string

func (*SchemaRef) GetSchemaType

func (x *SchemaRef) GetSchemaType() SchemaType

func (*SchemaRef) GetVersion

func (x *SchemaRef) GetVersion() string

func (*SchemaRef) ProtoMessage

func (*SchemaRef) ProtoMessage()

func (*SchemaRef) ProtoReflect

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

func (*SchemaRef) Reset

func (x *SchemaRef) Reset()

func (*SchemaRef) String

func (x *SchemaRef) String() string

type SchemaType

type SchemaType int32
const (
	SchemaType_SCHEMA_TYPE_UNSPECIFIED SchemaType = 0
	SchemaType_AVRO                    SchemaType = 1
	SchemaType_JSONSCHEMA              SchemaType = 2
)

func (SchemaType) Descriptor

func (SchemaType) Descriptor() protoreflect.EnumDescriptor

func (SchemaType) Enum

func (x SchemaType) Enum() *SchemaType

func (SchemaType) EnumDescriptor deprecated

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

Deprecated: Use SchemaType.Descriptor instead.

func (SchemaType) Number

func (x SchemaType) Number() protoreflect.EnumNumber

func (SchemaType) String

func (x SchemaType) String() string

func (SchemaType) Type

type Schema_SimpleSchemaDefinition

type Schema_SimpleSchemaDefinition struct {

	// constraints: printable characters
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// constraints:
	// dot separated sequence of name constraints
	// must be Avro compatible. When absent becomes <handle>.<name>.v<version>
	Namespace string              `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Doc       string              `protobuf:"bytes,3,opt,name=doc,proto3" json:"doc,omitempty"`
	Nodes     []*SimpleSchemaNode `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// avro compatible name set by creator OR derived from name (thus ignore_empty = true)
	AvroName string `protobuf:"bytes,5,opt,name=avro_name,json=avroName,proto3" json:"avro_name,omitempty"`
	// contains filtered or unexported fields
}

constraints: overall size < 100000 TBD

func (*Schema_SimpleSchemaDefinition) Descriptor deprecated

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

Deprecated: Use Schema_SimpleSchemaDefinition.ProtoReflect.Descriptor instead.

func (*Schema_SimpleSchemaDefinition) GetAvroName added in v2.10.0

func (x *Schema_SimpleSchemaDefinition) GetAvroName() string

func (*Schema_SimpleSchemaDefinition) GetDoc

func (*Schema_SimpleSchemaDefinition) GetName

func (*Schema_SimpleSchemaDefinition) GetNamespace

func (x *Schema_SimpleSchemaDefinition) GetNamespace() string

func (*Schema_SimpleSchemaDefinition) GetNodes

func (*Schema_SimpleSchemaDefinition) ProtoMessage

func (*Schema_SimpleSchemaDefinition) ProtoMessage()

func (*Schema_SimpleSchemaDefinition) ProtoReflect

func (*Schema_SimpleSchemaDefinition) Reset

func (x *Schema_SimpleSchemaDefinition) Reset()

func (*Schema_SimpleSchemaDefinition) String

type Schema_State added in v2.19.0

type Schema_State int32
const (
	Schema_STATE_UNSPECIFIED Schema_State = 0
	// This schema is valid and complete, but has not been accepted yet, can still be modified and also deleted.
	Schema_DRAFT Schema_State = 1
	// This schema is valid and complete can be used for events and batch jobs. It cannot be modified or deleted.
	Schema_ACTIVE Schema_State = 2
	// This schema is valid and complete has been active, but no more events can be sent using this schema. In-flight events are still processed.
	Schema_ARCHIVED Schema_State = 3
	// This schema is in review. It can be used once it has been approved.
	Schema_IN_REVIEW Schema_State = 4
	// This schema is still under construction.
	Schema_INCOMPLETE Schema_State = 5
	// This schema is approved and when activated can be used used for events and batch jobs. It cannot be modified or deleted.
	Schema_APPROVED Schema_State = 6
)

func (Schema_State) Descriptor added in v2.19.0

func (Schema_State) Enum added in v2.19.0

func (x Schema_State) Enum() *Schema_State

func (Schema_State) EnumDescriptor deprecated added in v2.19.0

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

Deprecated: Use Schema_State.Descriptor instead.

func (Schema_State) Number added in v2.19.0

func (Schema_State) String added in v2.19.0

func (x Schema_State) String() string

func (Schema_State) Type added in v2.19.0

type SimpleSchemaNode

type SimpleSchemaNode struct {
	Type SimpleSchemaNodeType `protobuf:"varint,1,opt,name=type,proto3,enum=strmprivacy.api.entities.v1.SimpleSchemaNodeType" json:"type,omitempty"`
	// constraints: same as SimpleSchemaDefinition
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// avro compatible name set by creator OR derived from name
	AvroName string              `protobuf:"bytes,7,opt,name=avro_name,json=avroName,proto3" json:"avro_name,omitempty"`
	Repeated bool                `protobuf:"varint,3,opt,name=repeated,proto3" json:"repeated,omitempty"`
	Required bool                `protobuf:"varint,4,opt,name=required,proto3" json:"required,omitempty"`
	Nodes    []*SimpleSchemaNode `protobuf:"bytes,5,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// constraints:
	// size < 5000
	Doc string `protobuf:"bytes,6,opt,name=doc,proto3" json:"doc,omitempty"`
	// contains filtered or unexported fields
}

func (*SimpleSchemaNode) Descriptor deprecated

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

Deprecated: Use SimpleSchemaNode.ProtoReflect.Descriptor instead.

func (*SimpleSchemaNode) GetAvroName added in v2.10.0

func (x *SimpleSchemaNode) GetAvroName() string

func (*SimpleSchemaNode) GetDoc

func (x *SimpleSchemaNode) GetDoc() string

func (*SimpleSchemaNode) GetName

func (x *SimpleSchemaNode) GetName() string

func (*SimpleSchemaNode) GetNodes

func (x *SimpleSchemaNode) GetNodes() []*SimpleSchemaNode

func (*SimpleSchemaNode) GetRepeated

func (x *SimpleSchemaNode) GetRepeated() bool

func (*SimpleSchemaNode) GetRequired

func (x *SimpleSchemaNode) GetRequired() bool

func (*SimpleSchemaNode) GetType

func (*SimpleSchemaNode) ProtoMessage

func (*SimpleSchemaNode) ProtoMessage()

func (*SimpleSchemaNode) ProtoReflect

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

func (*SimpleSchemaNode) Reset

func (x *SimpleSchemaNode) Reset()

func (*SimpleSchemaNode) String

func (x *SimpleSchemaNode) String() string

type SimpleSchemaNodeType

type SimpleSchemaNodeType int32
const (
	SimpleSchemaNodeType_SIMPLE_SCHEMA_NODE_TYPE_UNSPECIFIED SimpleSchemaNodeType = 0
	SimpleSchemaNodeType_STRING                              SimpleSchemaNodeType = 1
	SimpleSchemaNodeType_BOOLEAN                             SimpleSchemaNodeType = 2
	SimpleSchemaNodeType_FLOAT                               SimpleSchemaNodeType = 3
	SimpleSchemaNodeType_INTEGER                             SimpleSchemaNodeType = 4
	SimpleSchemaNodeType_LONG                                SimpleSchemaNodeType = 5
	SimpleSchemaNodeType_NODE                                SimpleSchemaNodeType = 10
)

func (SimpleSchemaNodeType) Descriptor

func (SimpleSchemaNodeType) Enum

func (SimpleSchemaNodeType) EnumDescriptor deprecated

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

Deprecated: Use SimpleSchemaNodeType.Descriptor instead.

func (SimpleSchemaNodeType) Number

func (SimpleSchemaNodeType) String

func (x SimpleSchemaNodeType) String() string

func (SimpleSchemaNodeType) Type

type Sink

type Sink struct {
	Ref      *SinkRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	SinkType SinkType `` /* 128-byte string literal not displayed */
	// Types that are assignable to Config:
	//
	//	*Sink_Bucket
	Config isSink_Config `protobuf_oneof:"config"`
	// contains filtered or unexported fields
}

the sink config used by the batch exporters. Deprecated: Do not use.

func (*Sink) Descriptor deprecated

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

Deprecated: Use Sink.ProtoReflect.Descriptor instead.

func (*Sink) GetBucket

func (x *Sink) GetBucket() *BucketConfig

func (*Sink) GetConfig

func (m *Sink) GetConfig() isSink_Config

func (*Sink) GetRef

func (x *Sink) GetRef() *SinkRef

func (*Sink) GetSinkType

func (x *Sink) GetSinkType() SinkType

func (*Sink) ProtoMessage

func (*Sink) ProtoMessage()

func (*Sink) ProtoReflect

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

func (*Sink) Reset

func (x *Sink) Reset()

func (*Sink) String

func (x *Sink) String() string

type SinkRef deprecated

type SinkRef struct {
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	// constraints: generic name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Do not use.

func (*SinkRef) Descriptor deprecated

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

Deprecated: Use SinkRef.ProtoReflect.Descriptor instead.

func (*SinkRef) GetBillingId

func (x *SinkRef) GetBillingId() string

func (*SinkRef) GetName

func (x *SinkRef) GetName() string

func (*SinkRef) ProtoMessage

func (*SinkRef) ProtoMessage()

func (*SinkRef) ProtoReflect

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

func (*SinkRef) Reset

func (x *SinkRef) Reset()

func (*SinkRef) String

func (x *SinkRef) String() string

type SinkTree deprecated

type SinkTree struct {
	Sink           *Sink            `protobuf:"bytes,1,opt,name=sink,proto3" json:"sink,omitempty"`
	BatchExporters []*BatchExporter `protobuf:"bytes,2,rep,name=batch_exporters,json=batchExporters,proto3" json:"batch_exporters,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Do not use.

func (*SinkTree) Descriptor deprecated

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

Deprecated: Use SinkTree.ProtoReflect.Descriptor instead.

func (*SinkTree) GetBatchExporters

func (x *SinkTree) GetBatchExporters() []*BatchExporter

func (*SinkTree) GetSink

func (x *SinkTree) GetSink() *Sink

func (*SinkTree) ProtoMessage

func (*SinkTree) ProtoMessage()

func (*SinkTree) ProtoReflect

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

func (*SinkTree) Reset

func (x *SinkTree) Reset()

func (*SinkTree) String

func (x *SinkTree) String() string

type SinkType deprecated

type SinkType int32

Deprecated: Do not use.

const (
	SinkType_SINK_TYPE_UNSPECIFIED SinkType = 0
	SinkType_S3                    SinkType = 1
	SinkType_GCLOUD                SinkType = 2
)

func (SinkType) Descriptor

func (SinkType) Descriptor() protoreflect.EnumDescriptor

func (SinkType) Enum

func (x SinkType) Enum() *SinkType

func (SinkType) EnumDescriptor deprecated

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

Deprecated: Use SinkType.Descriptor instead.

func (SinkType) Number

func (x SinkType) Number() protoreflect.EnumNumber

func (SinkType) String

func (x SinkType) String() string

func (SinkType) Type

type Sink_Bucket

type Sink_Bucket struct {
	Bucket *BucketConfig `protobuf:"bytes,4,opt,name=bucket,proto3,oneof"`
}

type StatisticalDataType added in v2.61.0

type StatisticalDataType int32
const (
	StatisticalDataType_STATISTICAL_DATA_TYPE_UNSPECIFIED StatisticalDataType = 0
	StatisticalDataType_NOMINAL                           StatisticalDataType = 1
	StatisticalDataType_ORDINAL                           StatisticalDataType = 2
	StatisticalDataType_NUMERICAL                         StatisticalDataType = 3
)

func (StatisticalDataType) Descriptor added in v2.61.0

func (StatisticalDataType) Enum added in v2.61.0

func (StatisticalDataType) EnumDescriptor deprecated added in v2.61.0

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

Deprecated: Use StatisticalDataType.Descriptor instead.

func (StatisticalDataType) Number added in v2.61.0

func (StatisticalDataType) String added in v2.61.0

func (x StatisticalDataType) String() string

func (StatisticalDataType) Type added in v2.61.0

type Stream

type Stream struct {
	Ref *StreamRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Stream description
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// consent levels for derived streams
	//
	// constraints:
	// if consent_level_type ==  CUMULATIVE then
	// size = 1
	// endif
	ConsentLevels []int32 `protobuf:"varint,3,rep,packed,name=consent_levels,json=consentLevels,proto3" json:"consent_levels,omitempty"`
	// how event consent-levels are interpreted by decrypters.
	ConsentLevelType ConsentLevelType `` /* 162-byte string literal not displayed */
	// whether or not this stream is enabled.
	Enabled bool `protobuf:"varint,5,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// stream limits
	Limits *Limits `protobuf:"bytes,6,opt,name=limits,proto3" json:"limits,omitempty"`
	// null for source streams
	LinkedStream string `protobuf:"bytes,7,opt,name=linked_stream,json=linkedStream,proto3" json:"linked_stream,omitempty"`
	// tags are meant for customers to tag their streams
	Tags        []string       `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"`
	Credentials []*Credentials `protobuf:"bytes,9,rep,name=credentials,proto3" json:"credentials,omitempty"`
	// field masking is defined per OUTPUT stream and event-contract ref. combination
	//
	// The default empty map means no masking. Otherwise, the algorithm in the decrypter is as follows.
	//
	// A source stream is (partially) decrypted, and events that don't have enough permissions are dropped.
	// the event contract ref string is used to find a MaskedFields instance.
	// if present, for all field patterns in the MaskedFields instance, the hash with the specified seed is applied.
	MaskedFields *MaskedFields `protobuf:"bytes,10,opt,name=masked_fields,json=maskedFields,proto3" json:"masked_fields,omitempty"`
	// Kafka topic of the stream. Deprecated in favor of topic in message ExtendedStream
	//
	// Deprecated: Do not use.
	KafkaTopic string `protobuf:"bytes,11,opt,name=kafka_topic,json=kafkaTopic,proto3" json:"kafka_topic,omitempty"`
	// The id of the policy that should be applied to this stream's data
	PolicyId string `protobuf:"bytes,12,opt,name=policy_id,json=policyId,proto3" json:"policy_id,omitempty"`
	// contains filtered or unexported fields
}

Streams are source or derived streams depending on whether or not linked_stream is null. Key streams are a separate entity in the api.

func (*Stream) Descriptor deprecated

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetConsentLevelType

func (x *Stream) GetConsentLevelType() ConsentLevelType

func (*Stream) GetConsentLevels

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

func (*Stream) GetCredentials

func (x *Stream) GetCredentials() []*Credentials

func (*Stream) GetDescription

func (x *Stream) GetDescription() string

func (*Stream) GetEnabled

func (x *Stream) GetEnabled() bool

func (*Stream) GetKafkaTopic deprecated added in v2.35.0

func (x *Stream) GetKafkaTopic() string

Deprecated: Do not use.

func (*Stream) GetLimits

func (x *Stream) GetLimits() *Limits

func (*Stream) GetLinkedStream

func (x *Stream) GetLinkedStream() string

func (*Stream) GetMaskedFields

func (x *Stream) GetMaskedFields() *MaskedFields

func (*Stream) GetPolicyId added in v2.58.0

func (x *Stream) GetPolicyId() string

func (*Stream) GetRef

func (x *Stream) GetRef() *StreamRef

func (*Stream) GetTags

func (x *Stream) GetTags() []string

func (*Stream) ProtoMessage

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect

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

func (*Stream) Reset

func (x *Stream) Reset()

func (*Stream) String

func (x *Stream) String() string

type StreamRef

type StreamRef struct {

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

refers to a event stream.

func (*StreamRef) Descriptor deprecated

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

Deprecated: Use StreamRef.ProtoReflect.Descriptor instead.

func (*StreamRef) GetBillingId deprecated

func (x *StreamRef) GetBillingId() string

Deprecated: Do not use.

func (*StreamRef) GetName

func (x *StreamRef) GetName() string

func (*StreamRef) GetProjectId added in v2.38.0

func (x *StreamRef) GetProjectId() string

func (*StreamRef) ProtoMessage

func (*StreamRef) ProtoMessage()

func (*StreamRef) ProtoReflect

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

func (*StreamRef) Reset

func (x *StreamRef) Reset()

func (*StreamRef) String

func (x *StreamRef) String() string

type StreamTree

type StreamTree struct {
	Stream         *Stream          `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	KeyStream      *KeyStream       `protobuf:"bytes,2,opt,name=key_stream,json=keyStream,proto3" json:"key_stream,omitempty"`
	Derived        []*Stream        `protobuf:"bytes,3,rep,name=derived,proto3" json:"derived,omitempty"`
	BatchExporters []*BatchExporter `protobuf:"bytes,4,rep,name=batch_exporters,json=batchExporters,proto3" json:"batch_exporters,omitempty"`
	KafkaExporters []*KafkaExporter `protobuf:"bytes,5,rep,name=kafka_exporters,json=kafkaExporters,proto3" json:"kafka_exporters,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamTree) Descriptor deprecated

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

Deprecated: Use StreamTree.ProtoReflect.Descriptor instead.

func (*StreamTree) GetBatchExporters

func (x *StreamTree) GetBatchExporters() []*BatchExporter

func (*StreamTree) GetDerived

func (x *StreamTree) GetDerived() []*Stream

func (*StreamTree) GetKafkaExporters

func (x *StreamTree) GetKafkaExporters() []*KafkaExporter

func (*StreamTree) GetKeyStream

func (x *StreamTree) GetKeyStream() *KeyStream

func (*StreamTree) GetStream

func (x *StreamTree) GetStream() *Stream

func (*StreamTree) ProtoMessage

func (*StreamTree) ProtoMessage()

func (*StreamTree) ProtoReflect

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

func (*StreamTree) Reset

func (x *StreamTree) Reset()

func (*StreamTree) String

func (x *StreamTree) String() string

type SubscriptionPlan added in v2.64.0

type SubscriptionPlan int32
const (
	SubscriptionPlan_SUBSCRIPTION_PLAN_UNSPECIFIED SubscriptionPlan = 0
	SubscriptionPlan_FREE                          SubscriptionPlan = 1
	SubscriptionPlan_BUSINESS                      SubscriptionPlan = 2
	SubscriptionPlan_SELF_HOSTED                   SubscriptionPlan = 3
	SubscriptionPlan_AWS_MARKETPLACE_PAYG          SubscriptionPlan = 4
	SubscriptionPlan_AWS_MARKETPLACE_BYOL          SubscriptionPlan = 5
)

func (SubscriptionPlan) Descriptor added in v2.64.0

func (SubscriptionPlan) Enum added in v2.64.0

func (SubscriptionPlan) EnumDescriptor deprecated added in v2.64.0

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

Deprecated: Use SubscriptionPlan.Descriptor instead.

func (SubscriptionPlan) Number added in v2.64.0

func (SubscriptionPlan) String added in v2.64.0

func (x SubscriptionPlan) String() string

func (SubscriptionPlan) Type added in v2.64.0

type TimestampConfig added in v2.22.0

type TimestampConfig struct {

	// generic field name
	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.22.0

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

Deprecated: Use TimestampConfig.ProtoReflect.Descriptor instead.

func (*TimestampConfig) GetDefaultTimeZone added in v2.22.0

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

func (*TimestampConfig) GetField added in v2.22.0

func (x *TimestampConfig) GetField() string

func (*TimestampConfig) GetFormat added in v2.22.0

func (x *TimestampConfig) GetFormat() string

func (*TimestampConfig) ProtoMessage added in v2.22.0

func (*TimestampConfig) ProtoMessage()

func (*TimestampConfig) ProtoReflect added in v2.22.0

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

func (*TimestampConfig) Reset added in v2.22.0

func (x *TimestampConfig) Reset()

func (*TimestampConfig) String added in v2.22.0

func (x *TimestampConfig) String() string

type User added in v2.49.0

type User struct {
	Email          string     `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	FirstName      string     `protobuf:"bytes,2,opt,name=first_name,json=firstName,proto3" json:"first_name,omitempty"`
	LastName       string     `protobuf:"bytes,3,opt,name=last_name,json=lastName,proto3" json:"last_name,omitempty"`
	UserRoles      []UserRole `` /* 138-byte string literal not displayed */
	ExternalUserId string     `protobuf:"bytes,5,opt,name=external_user_id,json=externalUserId,proto3" json:"external_user_id,omitempty"`
	// the organization of the user.
	OrganizationId string `protobuf:"bytes,6,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	FunctionTitle  string `protobuf:"bytes,7,opt,name=function_title,json=functionTitle,proto3" json:"function_title,omitempty"`
	// contains filtered or unexported fields
}

(-- api-linter: core::0148::human-names=disabled

aip.dev/not-precedent . --)

func (*User) Descriptor deprecated added in v2.49.0

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetEmail added in v2.49.0

func (x *User) GetEmail() string

func (*User) GetExternalUserId added in v2.81.1

func (x *User) GetExternalUserId() string

func (*User) GetFirstName added in v2.49.0

func (x *User) GetFirstName() string

func (*User) GetFunctionTitle added in v2.86.0

func (x *User) GetFunctionTitle() string

func (*User) GetLastName added in v2.49.0

func (x *User) GetLastName() string

func (*User) GetOrganizationId added in v2.82.0

func (x *User) GetOrganizationId() string

func (*User) GetUserRoles added in v2.51.0

func (x *User) GetUserRoles() []UserRole

func (*User) ProtoMessage added in v2.49.0

func (*User) ProtoMessage()

func (*User) ProtoReflect added in v2.49.0

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

func (*User) Reset added in v2.49.0

func (x *User) Reset()

func (*User) String added in v2.49.0

func (x *User) String() string

type UserRole added in v2.49.0

type UserRole int32
const (
	UserRole_USER_ROLE_UNSPECIFIED UserRole = 0
	UserRole_ADMIN                 UserRole = 1
	UserRole_PROJECT_ADMIN         UserRole = 2
	UserRole_APPROVER              UserRole = 3
	UserRole_MEMBER                UserRole = 4
)

func (UserRole) Descriptor added in v2.49.0

func (UserRole) Descriptor() protoreflect.EnumDescriptor

func (UserRole) Enum added in v2.49.0

func (x UserRole) Enum() *UserRole

func (UserRole) EnumDescriptor deprecated added in v2.49.0

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

Deprecated: Use UserRole.Descriptor instead.

func (UserRole) Number added in v2.49.0

func (x UserRole) Number() protoreflect.EnumNumber

func (UserRole) String added in v2.49.0

func (x UserRole) String() string

func (UserRole) Type added in v2.49.0

type Validation

type Validation struct {

	// constraint: valid field path, follows avro constraints + slashes
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// constraint: one of the validator types. handled by code
	// This should become an enum
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// constraint: a type specific definition
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Validation) Descriptor deprecated

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

Deprecated: Use Validation.ProtoReflect.Descriptor instead.

func (*Validation) GetField

func (x *Validation) GetField() string

func (*Validation) GetType

func (x *Validation) GetType() string

func (*Validation) GetValue

func (x *Validation) GetValue() string

func (*Validation) ProtoMessage

func (*Validation) ProtoMessage()

func (*Validation) ProtoReflect

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

func (*Validation) Reset

func (x *Validation) Reset()

func (*Validation) String

func (x *Validation) String() string

type WindowedEventCount

type WindowedEventCount struct {
	StartTime  *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime    *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	EventCount int64                  `protobuf:"varint,3,opt,name=event_count,json=eventCount,proto3" json:"event_count,omitempty"`
	// contains filtered or unexported fields
}

func (*WindowedEventCount) Descriptor deprecated

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

Deprecated: Use WindowedEventCount.ProtoReflect.Descriptor instead.

func (*WindowedEventCount) GetEndTime

func (x *WindowedEventCount) GetEndTime() *timestamppb.Timestamp

func (*WindowedEventCount) GetEventCount

func (x *WindowedEventCount) GetEventCount() int64

func (*WindowedEventCount) GetStartTime

func (x *WindowedEventCount) GetStartTime() *timestamppb.Timestamp

func (*WindowedEventCount) ProtoMessage

func (*WindowedEventCount) ProtoMessage()

func (*WindowedEventCount) ProtoReflect

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

func (*WindowedEventCount) Reset

func (x *WindowedEventCount) Reset()

func (*WindowedEventCount) String

func (x *WindowedEventCount) String() string

Jump to

Keyboard shortcuts

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