entities

package
v2.51.0 Latest Latest
Warning

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

 Go to latest Published: Aug 12, 2022 License: Apache-2.0 Imports: 8 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 (
	Schema_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "DRAFT",
		2: "ACTIVE",
		3: "ARCHIVED",
		4: "IN_REVIEW",
	}
	Schema_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"DRAFT":             1,
		"ACTIVE":            2,
		"ARCHIVED":          3,
		"IN_REVIEW":         4,
	}
)

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",
	}
	EventContract_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"DRAFT":             1,
		"ACTIVE":            2,
		"ARCHIVED":          3,
		"IN_REVIEW":         4,
	}
)

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",
	}
	DataContract_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"DRAFT":             1,
		"IN_REVIEW":         2,
		"ACTIVE":            3,
		"ARCHIVED":          4,
	}
)

Enum value maps for DataContract_State.

View Source 
var File_strmprivacy_api_entities_v1_entities_v1_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

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) Descriptor() protoreflect.EnumDescriptor

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 (x AuthMechanism) Number() protoreflect.EnumNumber

func (AuthMechanism) String 

func (x AuthMechanism) String() string

func (AuthMechanism) Type 

func (AuthMechanism) Type() protoreflect.EnumType

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

func (*AzureBlobStorageContainerLocation) Reset added in v2.21.0 

func (x *AzureBlobStorageContainerLocation) Reset()

func (*AzureBlobStorageContainerLocation) String added in v2.21.0 

func (x *AzureBlobStorageContainerLocation) String() string

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

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"`
	//
	//constraints:
	//interval > 30s
	//interval < TBD
	Interval *durationpb.Duration `protobuf:"bytes,4,opt,name=interval,proto3" json:"interval,omitempty"`
	// constraints: generic name constraints
	SinkName string `protobuf:"bytes,5,opt,name=sink_name,json=sinkName,proto3" json:"sink_name,omitempty"`
	// constraints:
	//Total key size on S3 is 1024 unicode characters max. The export filenames are
	//created from the stream name suffixed with partition numbers and a timestamp.
	//Suggestion: generic name constraint
	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 

func (x *BatchExporter) GetSinkName() string

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"`
	// 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
}

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"`
	// 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) 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
	Id        string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	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) Descriptor() protoreflect.EnumDescriptor

func (BatchJobStateType) Enum added in v2.22.0 

func (x BatchJobStateType) Enum() *BatchJobStateType

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 (x BatchJobStateType) Number() protoreflect.EnumNumber

func (BatchJobStateType) String added in v2.22.0 

func (x BatchJobStateType) String() string

func (BatchJobStateType) Type added in v2.22.0 

func (BatchJobStateType) Type() protoreflect.EnumType

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 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 (x *ConsentLevelMapping) GetRef() *ConsentLevelMappingRef

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) Descriptor() protoreflect.EnumDescriptor

func (ConsentLevelType) Enum 

func (x ConsentLevelType) Enum() *ConsentLevelType

func (ConsentLevelType) EnumDescriptor deprecated 

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

Deprecated: Use ConsentLevelType.Descriptor instead.

func (ConsentLevelType) Number 

func (x ConsentLevelType) Number() protoreflect.EnumNumber

func (ConsentLevelType) String 

func (x ConsentLevelType) String() string

func (ConsentLevelType) Type 

func (ConsentLevelType) Type() protoreflect.EnumType

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 {

	// Deprecated: Do not use.
	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 deprecated 

func (x *Credentials) GetBillingId() string

Deprecated: Do not use.

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
	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) 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"`
	// 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) ProtoMessage added in v2.22.0 

func (*DataConnectorDependentEntities) ProtoMessage()

func (*DataConnectorDependentEntities) ProtoReflect added in v2.22.0 

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

func (*DataConnectorDependentEntities) Reset added in v2.22.0 

func (x *DataConnectorDependentEntities) Reset()

func (*DataConnectorDependentEntities) String added in v2.22.0 

func (x *DataConnectorDependentEntities) String() string

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_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"`
	EventSequenceField string                               `protobuf:"bytes,5,opt,name=event_sequence_field,json=eventSequenceField,proto3" json:"event_sequence_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           *DataContractMetadata                `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Definition         string                               `protobuf:"bytes,9,opt,name=definition,proto3" json:"definition,omitempty"`
	Fingerprint        string                               `protobuf:"bytes,10,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	SimpleSchema       *DataContract_SimpleSchemaDefinition `protobuf:"bytes,11,opt,name=simple_schema,json=simpleSchema,proto3" json:"simple_schema,omitempty"`
	DataSubjectField   string                               `protobuf:"bytes,12,opt,name=data_subject_field,json=dataSubjectField,proto3" json:"data_subject_field,omitempty"`
	ProjectId          string                               `protobuf:"bytes,13,opt,name=project_id,json=projectId,proto3" json:"project_id,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) GetDefinition added in v2.36.0 

func (x *DataContract) GetDefinition() string

func (*DataContract) GetEventSequenceField added in v2.36.0 

func (x *DataContract) GetEventSequenceField() string

func (*DataContract) GetFingerprint added in v2.36.0 

func (x *DataContract) GetFingerprint() string

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) GetMetadata added in v2.36.0 

func (x *DataContract) GetMetadata() *DataContractMetadata

func (*DataContract) GetPiiFields added in v2.36.0 

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

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) GetSimpleSchema added in v2.36.0 

func (x *DataContract) GetSimpleSchema() *DataContract_SimpleSchemaDefinition

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 (optional) 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 {

	// constraints: generic name constraint, globally unique
	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: semantic version
	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_SimpleSchemaDefinition added in v2.36.0 

type DataContract_SimpleSchemaDefinition struct {

	// constraints:
	//https://avro.apache.org/docs/current/spec.html#names
	//start with [A-Za-z_]
	//subsequently contain only [A-Za-z0-9_]
	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"`
	// constraints:
	//size < 5000
	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
	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 (*DataContract_SimpleSchemaDefinition) Descriptor deprecated added in v2.36.0 

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

Deprecated: Use DataContract_SimpleSchemaDefinition.ProtoReflect.Descriptor instead.

func (*DataContract_SimpleSchemaDefinition) GetAvroName added in v2.36.0 

func (x *DataContract_SimpleSchemaDefinition) GetAvroName() string

func (*DataContract_SimpleSchemaDefinition) GetDoc added in v2.36.0 

func (x *DataContract_SimpleSchemaDefinition) GetDoc() string

func (*DataContract_SimpleSchemaDefinition) GetName added in v2.36.0 

func (x *DataContract_SimpleSchemaDefinition) GetName() string

func (*DataContract_SimpleSchemaDefinition) GetNamespace added in v2.36.0 

func (x *DataContract_SimpleSchemaDefinition) GetNamespace() string

func (*DataContract_SimpleSchemaDefinition) GetNodes added in v2.36.0 

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

func (*DataContract_SimpleSchemaDefinition) ProtoMessage added in v2.36.0 

func (*DataContract_SimpleSchemaDefinition) ProtoMessage()

func (*DataContract_SimpleSchemaDefinition) ProtoReflect added in v2.36.0 

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

func (*DataContract_SimpleSchemaDefinition) Reset added in v2.36.0 

func (x *DataContract_SimpleSchemaDefinition) Reset()

func (*DataContract_SimpleSchemaDefinition) String added in v2.36.0 

func (x *DataContract_SimpleSchemaDefinition) String() string

type DataContract_State added in v2.36.0 

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

func (DataContract_State) Descriptor added in v2.36.0 

func (DataContract_State) Descriptor() protoreflect.EnumDescriptor

func (DataContract_State) Enum added in v2.36.0 

func (x DataContract_State) Enum() *DataContract_State

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 (x DataContract_State) Number() protoreflect.EnumNumber

func (DataContract_State) String added in v2.36.0 

func (x DataContract_State) String() string

func (DataContract_State) Type added in v2.36.0 

func (DataContract_State) Type() protoreflect.EnumType

type DataType added in v2.14.0 

type DataType struct {

	// Types that are assignable to DataType:
	//	*DataType_Csv
	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) 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 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 {

	// constraints: generic name constraint, globally unique
	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: semantic version
	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
	//
	//The initial state, this event contract has not been accepted yet, can still be modified and also deleted.
	EventContract_DRAFT EventContract_State = 1
	//
	//This event contract can be used for events and batch jobs. It cannot be modified or deleted.
	EventContract_ACTIVE EventContract_State = 2
	//
	//This event contract has been active, but no more events can be sent using this event contract. In-flight events are still processed.
	EventContract_ARCHIVED EventContract_State = 3
	//
	//This event contract is being reviewed. It can be approved or rejected from here.
	EventContract_IN_REVIEW EventContract_State = 4
)

func (EventContract_State) Descriptor added in v2.19.0 

func (EventContract_State) Descriptor() protoreflect.EnumDescriptor

func (EventContract_State) Enum added in v2.19.0 

func (x EventContract_State) Enum() *EventContract_State

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 (x EventContract_State) Number() protoreflect.EnumNumber

func (EventContract_State) String added in v2.19.0 

func (x EventContract_State) String() string

func (EventContract_State) Type added in v2.19.0 

func (EventContract_State) Type() protoreflect.EnumType

type ExtendedBatchExporter added in v2.28.0 

type ExtendedBatchExporter struct {
	Uuid     string         `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	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 {
	BatchJob *BatchJob `protobuf:"bytes,1,opt,name=batch_job,json=batchJob,proto3" json:"batch_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 added in v2.28.0 

func (x *ExtendedBatchJob) GetBatchJob() *BatchJob

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"`
	Topic  string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	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 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) Descriptor() protoreflect.EnumDescriptor

func (FilterPublicPrivate) Enum 

func (x FilterPublicPrivate) Enum() *FilterPublicPrivate

func (FilterPublicPrivate) EnumDescriptor deprecated 

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

Deprecated: Use FilterPublicPrivate.Descriptor instead.

func (FilterPublicPrivate) Number 

func (x FilterPublicPrivate) Number() protoreflect.EnumNumber

func (FilterPublicPrivate) String 

func (x FilterPublicPrivate) String() string

func (FilterPublicPrivate) Type 

func (FilterPublicPrivate) Type() protoreflect.EnumType

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

func (*GoogleCloudStorageBucketLocation) Reset added in v2.16.0 

func (x *GoogleCloudStorageBucketLocation) Reset()

func (*GoogleCloudStorageBucketLocation) String added in v2.16.0 

func (x *GoogleCloudStorageBucketLocation) 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 --)
	//
	// Deprecated: Do not use.
	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 deprecated 

func (x *KafkaClusterRef) GetBillingId() string

Deprecated: Do not use.

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 {

	// Deprecated: Do not use.
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	//
	//default value  <cluster-name>-<stream-name>
	//
	//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
}

func (*KafkaExporterRef) Descriptor deprecated 

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

Deprecated: Use KafkaExporterRef.ProtoReflect.Descriptor instead.

func (*KafkaExporterRef) GetBillingId deprecated 

func (x *KafkaExporterRef) GetBillingId() string

Deprecated: Do not use.

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"`
	// 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
}

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

func (x *KeyStream) GetStatus() string

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 (optional) 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 for empty string
	HashType string `protobuf:"bytes,1,opt,name=hash_type,json=hashType,proto3" json:"hash_type,omitempty"`
	//
	//hashing seed
	//constraints: size < 1000, unicode
	Seed string `protobuf:"bytes,2,opt,name=seed,proto3" json:"seed,omitempty"`
	//
	//map of event-contract-ref vs field patterns
	//
	//constraints:
	// event-contract-refs should be existing event contracts
	// field_patterns should be valid values (checked by event-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 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"`
	// 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) 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 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.
	//
	//constraints: size < 500
	Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	//
	//The (optional) description of this Schema. Used in the Portal. Markdown syntax is supported. This field can be modified.
	//constraints: size < 5000
	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 (optional) 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 

func (SchemaType) Type() protoreflect.EnumType

type Schema_SimpleSchemaDefinition 

type Schema_SimpleSchemaDefinition struct {

	// constraints:
	//https://avro.apache.org/docs/current/spec.html#names
	//start with [A-Za-z_]
	//subsequently contain only [A-Za-z0-9_]
	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"`
	// constraints:
	//size < 5000
	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
	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 (x *Schema_SimpleSchemaDefinition) GetDoc() string

func (*Schema_SimpleSchemaDefinition) GetName 

func (x *Schema_SimpleSchemaDefinition) GetName() string

func (*Schema_SimpleSchemaDefinition) GetNamespace 

func (x *Schema_SimpleSchemaDefinition) GetNamespace() string

func (*Schema_SimpleSchemaDefinition) GetNodes 

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

func (*Schema_SimpleSchemaDefinition) ProtoMessage 

func (*Schema_SimpleSchemaDefinition) ProtoMessage()

func (*Schema_SimpleSchemaDefinition) ProtoReflect 

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

func (*Schema_SimpleSchemaDefinition) Reset 

func (x *Schema_SimpleSchemaDefinition) Reset()

func (*Schema_SimpleSchemaDefinition) String 

func (x *Schema_SimpleSchemaDefinition) String() string

type Schema_State added in v2.19.0 

type Schema_State int32
const (
	Schema_STATE_UNSPECIFIED Schema_State = 0
	//
	//The initial state, this schema has not been accepted yet, can still be modified and also deleted.
	Schema_DRAFT Schema_State = 1
	//
	//This schema can be used for events and batch jobs. It cannot be modified or deleted.
	Schema_ACTIVE Schema_State = 2
	//
	//This schema 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 being reviewed. It can be approved or rejected from here.
	Schema_IN_REVIEW Schema_State = 4
)

func (Schema_State) Descriptor added in v2.19.0 

func (Schema_State) Descriptor() protoreflect.EnumDescriptor

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 (x Schema_State) Number() protoreflect.EnumNumber

func (Schema_State) String added in v2.19.0 

func (x Schema_State) String() string

func (Schema_State) Type added in v2.19.0 

func (Schema_State) Type() protoreflect.EnumType

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 (x *SimpleSchemaNode) GetType() SimpleSchemaNodeType

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) Descriptor() protoreflect.EnumDescriptor

func (SimpleSchemaNodeType) Enum 

func (x SimpleSchemaNodeType) Enum() *SimpleSchemaNodeType

func (SimpleSchemaNodeType) EnumDescriptor deprecated 

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

Deprecated: Use SimpleSchemaNodeType.Descriptor instead.

func (SimpleSchemaNodeType) Number 

func (x SimpleSchemaNodeType) Number() protoreflect.EnumNumber

func (SimpleSchemaNodeType) String 

func (x SimpleSchemaNodeType) String() string

func (SimpleSchemaNodeType) Type 

func (SimpleSchemaNodeType) Type() protoreflect.EnumType

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 

func (SinkType) Type() protoreflect.EnumType

type Sink_Bucket 

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

type Stream 

type Stream struct {
	Ref *StreamRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// customer's description for this Stream.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	//
	//consent levels for derived streams
	//
	//constraints:
	//size < 50
	//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
	//constraints: general name constraint
	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"`
	KafkaTopic   string        `protobuf:"bytes,11,opt,name=kafka_topic,json=kafkaTopic,proto3" json:"kafka_topic,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 added in v2.35.0 

func (x *Stream) GetKafkaTopic() string

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

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

func (*TimestampConfig) Descriptor deprecated added in v2.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 */
	// 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) GetFirstName added in v2.49.0 

func (x *User) GetFirstName() string

func (*User) GetLastName added in v2.49.0 

func (x *User) GetLastName() 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 

func (UserRole) Type() protoreflect.EnumType

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.