entities

package
v2.19.0 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 2022 License: Apache-2.0 Imports: 7 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for Schema_State.

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

Enum value maps for EventContract_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 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 */
	// 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) 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 {
	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"`
	// contains filtered or unexported fields
}

func (*BatchExporterRef) Descriptor deprecated 

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

Deprecated: Use BatchExporterRef.ProtoReflect.Descriptor instead.

func (*BatchExporterRef) GetBillingId 

func (x *BatchExporterRef) GetBillingId() string

func (*BatchExporterRef) GetName 

func (x *BatchExporterRef) GetName() 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 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 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 {
	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"`
	// contains filtered or unexported fields
}

func (*ConsentLevelMappingRef) Descriptor deprecated 

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

Deprecated: Use ConsentLevelMappingRef.ProtoReflect.Descriptor instead.

func (*ConsentLevelMappingRef) GetBillingId 

func (x *ConsentLevelMappingRef) GetBillingId() string

func (*ConsentLevelMappingRef) GetLevel 

func (x *ConsentLevelMappingRef) GetLevel() int32

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 {
	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"`
	// contains filtered or unexported fields
}

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

func (*Credentials) Descriptor deprecated 

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

Deprecated: Use Credentials.ProtoReflect.Descriptor instead.

func (*Credentials) GetBillingId 

func (x *Credentials) GetBillingId() string

func (*Credentials) GetClientId 

func (x *Credentials) GetClientId() string

func (*Credentials) GetClientSecret 

func (x *Credentials) GetClientSecret() string

func (*Credentials) 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
	Location isDataConnector_Location `protobuf_oneof:"location"`
	// 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) 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) 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 DataConnectorRef added in v2.14.0 

type DataConnectorRef struct {
	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"`
	// 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 added in v2.14.0 

func (x *DataConnectorRef) GetBillingId() string

func (*DataConnectorRef) GetName added in v2.14.0 

func (x *DataConnectorRef) GetName() 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_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 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 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"`
	// contains filtered or unexported fields
}

func (*EventContract) Descriptor deprecated 

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

Deprecated: Use EventContract.ProtoReflect.Descriptor instead.

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 schema has not been accepted yet, can still be modified and also deleted.
	EventContract_DRAFT EventContract_State = 1
	//
	//This schema can be used for events and batch jobs. It cannot be modified or deleted.
	EventContract_ACTIVE EventContract_State = 2
	//
	//This schema has been active, but no more events can be sent using this schema. In-flight events are still processed.
	EventContract_ARCHIVED EventContract_State = 3
)

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 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 --)
	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"`
	// contains filtered or unexported fields
}

How to refer to a certain Kafka cluster.

func (*KafkaClusterRef) Descriptor deprecated 

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

Deprecated: Use KafkaClusterRef.ProtoReflect.Descriptor instead.

func (*KafkaClusterRef) GetBillingId 

func (x *KafkaClusterRef) GetBillingId() string

func (*KafkaClusterRef) GetName 

func (x *KafkaClusterRef) GetName() string

func (*KafkaClusterRef) ProtoMessage 

func (*KafkaClusterRef) ProtoMessage()

func (*KafkaClusterRef) ProtoReflect 

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

func (*KafkaClusterRef) Reset 

func (x *KafkaClusterRef) Reset()

func (*KafkaClusterRef) String 

func (x *KafkaClusterRef) String() string

type KafkaExporter 

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

func (*KafkaExporter) Descriptor deprecated 

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

Deprecated: Use KafkaExporter.ProtoReflect.Descriptor instead.

func (*KafkaExporter) GetRef 

func (x *KafkaExporter) GetRef() *KafkaExporterRef

func (*KafkaExporter) GetStreamRef 

func (x *KafkaExporter) GetStreamRef() *StreamRef

func (*KafkaExporter) GetTarget 

func (x *KafkaExporter) GetTarget() *KafkaExporterTarget

func (*KafkaExporter) GetUsers 

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

func (*KafkaExporter) ProtoMessage 

func (*KafkaExporter) ProtoMessage()

func (*KafkaExporter) ProtoReflect 

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

func (*KafkaExporter) Reset 

func (x *KafkaExporter) Reset()

func (*KafkaExporter) String 

func (x *KafkaExporter) String() string

type KafkaExporterRef 

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

func (*KafkaExporterRef) Descriptor deprecated 

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

Deprecated: Use KafkaExporterRef.ProtoReflect.Descriptor instead.

func (*KafkaExporterRef) GetBillingId 

func (x *KafkaExporterRef) GetBillingId() string

func (*KafkaExporterRef) GetName 

func (x *KafkaExporterRef) GetName() string

func (*KafkaExporterRef) 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 {
	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"`
	// contains filtered or unexported fields
}

func (*KafkaUserRef) Descriptor deprecated 

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

Deprecated: Use KafkaUserRef.ProtoReflect.Descriptor instead.

func (*KafkaUserRef) GetBillingId 

func (x *KafkaUserRef) GetBillingId() string

func (*KafkaUserRef) GetName 

func (x *KafkaUserRef) GetName() 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"`
	// 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) 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 {
	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"`
	// 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 

func (x *KeyStreamRef) GetBillingId() string

func (*KeyStreamRef) GetName 

func (x *KeyStreamRef) GetName() 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 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"`
	// 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) 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
)

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.

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 

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
}

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 

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
}

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 

type SinkType int32
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"`
	// 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) 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 {
	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"`
	// 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 

func (x *StreamRef) GetBillingId() string

func (*StreamRef) GetName 

func (x *StreamRef) GetName() 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 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.