entities

type AuthMechanism int32

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

type BatchExporterRef 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
}

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

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

type BucketConfig struct {

	// (-- api-linter: core::0122::name-suffix=disabled
	//     aip.dev/not-precedent: We refer to a bucket name. --)
	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
}

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

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
}

type ConsentLevelType int32

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
}

type EventContract struct {
	Ref       *EventContractRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	State     State             `protobuf:"varint,2,opt,name=state,proto3,enum=streammachine.api.entities.v1.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
}

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
}

type EventContractRef struct {
	Handle  string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type FilterPublicPrivate int32

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    `` /* 150-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
}

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"`
	// (-- shared export --)
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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
}

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

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

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
}

type KafkaUserRef 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
}

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
}

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
}

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
}

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
}

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
	Seed string `protobuf:"bytes,2,opt,name=seed,proto3" json:"seed,omitempty"`
	// map of event-contract-ref vs field patterns
	FieldPatterns map[string]*MaskedFields_PatternList `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

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
}

type Schema struct {
	Ref   *SchemaRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	State State      `protobuf:"varint,2,opt,name=state,proto3,enum=streammachine.api.entities.v1.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"`
	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
}

type SchemaMetadata struct {

	// The human readable title of this Schema. Used in the Portal. Defaults to the Schema name. This field can be modified.
	Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	// The (optional) description of this Schema. Used in the Portal. Markdown syntax is supported. This field can be modified.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// The timestamp when this Schema was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The (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
}

type SchemaRef struct {
	Handle     string     `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"`
	Name       string     `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version    string     `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	SchemaType SchemaType `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SchemaType int32

type Schema_SimpleSchemaDefinition struct {
	Name      string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string              `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Doc       string              `protobuf:"bytes,3,opt,name=doc,proto3" json:"doc,omitempty"`
	Nodes     []*SimpleSchemaNode `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

type SimpleSchemaNode struct {
	Type     SimpleSchemaNodeType `protobuf:"varint,1,opt,name=type,proto3,enum=streammachine.api.entities.v1.SimpleSchemaNodeType" json:"type,omitempty"`
	Name     string               `protobuf:"bytes,2,opt,name=name,proto3" json:"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"`
	Doc      string               `protobuf:"bytes,6,opt,name=doc,proto3" json:"doc,omitempty"`
	// contains filtered or unexported fields
}

type SimpleSchemaNodeType int32

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

type SinkRef 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
}

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
}

type SinkType int32

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

type State int32

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
	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 `` /* 164-byte string literal not displayed */
	// whether or not this stream is enabled.
	Enabled bool `protobuf:"varint,5,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// stream limits
	Limits *Limits `protobuf:"bytes,6,opt,name=limits,proto3" json:"limits,omitempty"`
	// null for source streams
	LinkedStream string `protobuf:"bytes,7,opt,name=linked_stream,json=linkedStream,proto3" json:"linked_stream,omitempty"`
	// customer purposes.
	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
}

type StreamRef 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
}

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
}

type Validation struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Type  string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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
}