entities

package
v3.18.4 Latest Latest
Warning

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

Go to latest
Published: Sep 19, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for UserRole.

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

Enum value maps for BatchJobStateType.

View Source
var (
	ConsentLevelType_name = map[int32]string{
		0: "CONSENT_LEVEL_TYPE_UNSPECIFIED",
		1: "CUMULATIVE",
		2: "GRANULAR",
	}
	ConsentLevelType_value = map[string]int32{
		"CONSENT_LEVEL_TYPE_UNSPECIFIED": 0,
		"CUMULATIVE":                     1,
		"GRANULAR":                       2,
	}
)

Enum value maps for ConsentLevelType.

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

Enum value maps for SinkType.

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

Enum value maps for AuthMechanism.

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

Enum value maps for SchemaType.

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

Enum value maps for SimpleSchemaNodeType.

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

Enum value maps for FilterPublicPrivate.

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

Enum value maps for StatisticalDataType.

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

Enum value maps for SubscriptionPlan.

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

Enum value maps for DatabaseType.

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

Enum value maps for Policy_State.

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

Enum value maps for Schema_State.

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

Enum value maps for EventContract_State.

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

Enum value maps for DataContract_State.

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

Enum value maps for FieldMetadata_NullHandlingConfig_NullHandlingType.

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

Enum value maps for Project_State.

View Source
var (
	GenericRef_GenericRefType_name = map[int32]string{
		0: "GENERIC_REF_TYPE_UNSPECIFIED",
		1: "DATA_CONTRACT",
		2: "PROJECT",
		3: "STREAM",
		4: "BATCH_EXPORTER",
		5: "DATA_CONNECTOR",
		6: "KAFKA_EXPORTER",
		7: "PROJECT_PLAN",
	}
	GenericRef_GenericRefType_value = map[string]int32{
		"GENERIC_REF_TYPE_UNSPECIFIED": 0,
		"DATA_CONTRACT":                1,
		"PROJECT":                      2,
		"STREAM":                       3,
		"BATCH_EXPORTER":               4,
		"DATA_CONNECTOR":               5,
		"KAFKA_EXPORTER":               6,
		"PROJECT_PLAN":                 7,
	}
)

Enum value maps for GenericRef_GenericRefType.

View Source
var (
	AuditTrailEntry_Action_name = map[int32]string{
		0: "ACTION_UNSPECIFIED",
		1: "CREATED",
		2: "DELETED",
		3: "CHANGED",
	}
	AuditTrailEntry_Action_value = map[string]int32{
		"ACTION_UNSPECIFIED": 0,
		"CREATED":            1,
		"DELETED":            2,
		"CHANGED":            3,
	}
)

Enum value maps for AuditTrailEntry_Action.

View Source
var (
	AuditTrailEntry_Category_name = map[int32]string{
		0: "CATEGORY_UNSPECIFIED",
		1: "TECH",
		2: "CIO",
		3: "LEGAL",
	}
	AuditTrailEntry_Category_value = map[string]int32{
		"CATEGORY_UNSPECIFIED": 0,
		"TECH":                 1,
		"CIO":                  2,
		"LEGAL":                3,
	}
)

Enum value maps for AuditTrailEntry_Category.

View Source
var (
	AuditTrailEntry_Details_ProjectMemberChange_ChangeType_name = map[int32]string{
		0: "CHANGE_TYPE_UNSPECIFIED",
		1: "PROJECT_MEMBER_ADDED",
		2: "PROJECT_MEMBER_REMOVED",
	}
	AuditTrailEntry_Details_ProjectMemberChange_ChangeType_value = map[string]int32{
		"CHANGE_TYPE_UNSPECIFIED": 0,
		"PROJECT_MEMBER_ADDED":    1,
		"PROJECT_MEMBER_REMOVED":  2,
	}
)

Enum value maps for AuditTrailEntry_Details_ProjectMemberChange_ChangeType.

View Source
var (
	Diff_DiffType_name = map[int32]string{
		0: "DIFF_TYPE_UNSPECIFIED",
		1: "MISSING",
		2: "UNEXPECTED",
		3: "DIFFERENT",
	}
	Diff_DiffType_value = map[string]int32{
		"DIFF_TYPE_UNSPECIFIED": 0,
		"MISSING":               1,
		"UNEXPECTED":            2,
		"DIFFERENT":             3,
	}
)

Enum value maps for Diff_DiffType.

View Source
var File_strmprivacy_api_entities_v1_entities_v1_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AuditTrailEntry

type AuditTrailEntry struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The entity this audit trail entry is attached to.
	EntityRef *GenericRef `protobuf:"bytes,3,opt,name=entity_ref,json=entityRef,proto3" json:"entity_ref,omitempty"`
	// The content of the audit trail entry.
	//
	// Deprecated: Do not use.
	Content string `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	// The user whose action triggered the audit trail entry. Upon creation, only the user's external_user_id needs to be set.
	Actor *User `protobuf:"bytes,5,opt,name=actor,proto3" json:"actor,omitempty"`
	// The project this audit trail entry belongs to, if applicable.
	ProjectId string `protobuf:"bytes,6,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Human readable name of the entity.
	EntityName string `protobuf:"bytes,7,opt,name=entity_name,json=entityName,proto3" json:"entity_name,omitempty"`
	// what is happening in this audit trail entry.
	Action AuditTrailEntry_Action `protobuf:"varint,8,opt,name=action,proto3,enum=strmprivacy.api.entities.v1.AuditTrailEntry_Action" json:"action,omitempty"`
	// define who (or what screen) sees what.
	// Used for filtering depending on who is using the UI,
	// or specific views in the UI.
	Category []AuditTrailEntry_Category `` /* 135-byte string literal not displayed */
	// the strictly defined details, that are going to supplant the `content` field.
	Details *AuditTrailEntry_Details `protobuf:"bytes,10,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditTrailEntry) Descriptor deprecated

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

Deprecated: Use AuditTrailEntry.ProtoReflect.Descriptor instead.

func (*AuditTrailEntry) GetAction added in v3.13.0

func (x *AuditTrailEntry) GetAction() AuditTrailEntry_Action

func (*AuditTrailEntry) GetActor

func (x *AuditTrailEntry) GetActor() *User

func (*AuditTrailEntry) GetCategory added in v3.13.0

func (x *AuditTrailEntry) GetCategory() []AuditTrailEntry_Category

func (*AuditTrailEntry) GetContent deprecated

func (x *AuditTrailEntry) GetContent() string

Deprecated: Do not use.

func (*AuditTrailEntry) GetCreateTime

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

func (*AuditTrailEntry) GetDetails added in v3.13.0

func (x *AuditTrailEntry) GetDetails() *AuditTrailEntry_Details

func (*AuditTrailEntry) GetEntityName added in v3.4.0

func (x *AuditTrailEntry) GetEntityName() string

func (*AuditTrailEntry) GetEntityRef

func (x *AuditTrailEntry) GetEntityRef() *GenericRef

func (*AuditTrailEntry) GetId

func (x *AuditTrailEntry) GetId() string

func (*AuditTrailEntry) GetProjectId added in v3.4.0

func (x *AuditTrailEntry) GetProjectId() string

func (*AuditTrailEntry) ProtoMessage

func (*AuditTrailEntry) ProtoMessage()

func (*AuditTrailEntry) ProtoReflect

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

func (*AuditTrailEntry) Reset

func (x *AuditTrailEntry) Reset()

func (*AuditTrailEntry) String

func (x *AuditTrailEntry) String() string

type AuditTrailEntry_Action added in v3.13.0

type AuditTrailEntry_Action int32
const (
	AuditTrailEntry_ACTION_UNSPECIFIED AuditTrailEntry_Action = 0
	AuditTrailEntry_CREATED            AuditTrailEntry_Action = 1
	AuditTrailEntry_DELETED            AuditTrailEntry_Action = 2
	AuditTrailEntry_CHANGED            AuditTrailEntry_Action = 3
)

func (AuditTrailEntry_Action) Descriptor added in v3.13.0

func (AuditTrailEntry_Action) Enum added in v3.13.0

func (AuditTrailEntry_Action) EnumDescriptor deprecated added in v3.13.0

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

Deprecated: Use AuditTrailEntry_Action.Descriptor instead.

func (AuditTrailEntry_Action) Number added in v3.13.0

func (AuditTrailEntry_Action) String added in v3.13.0

func (x AuditTrailEntry_Action) String() string

func (AuditTrailEntry_Action) Type added in v3.13.0

type AuditTrailEntry_Category added in v3.13.0

type AuditTrailEntry_Category int32
const (
	AuditTrailEntry_CATEGORY_UNSPECIFIED AuditTrailEntry_Category = 0
	AuditTrailEntry_TECH                 AuditTrailEntry_Category = 1
	AuditTrailEntry_CIO                  AuditTrailEntry_Category = 2
	AuditTrailEntry_LEGAL                AuditTrailEntry_Category = 3
)

func (AuditTrailEntry_Category) Descriptor added in v3.13.0

func (AuditTrailEntry_Category) Enum added in v3.13.0

func (AuditTrailEntry_Category) EnumDescriptor deprecated added in v3.13.0

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

Deprecated: Use AuditTrailEntry_Category.Descriptor instead.

func (AuditTrailEntry_Category) Number added in v3.13.0

func (AuditTrailEntry_Category) String added in v3.13.0

func (x AuditTrailEntry_Category) String() string

func (AuditTrailEntry_Category) Type added in v3.13.0

type AuditTrailEntry_Details added in v3.13.0

type AuditTrailEntry_Details struct {

	// Types that are assignable to Content:
	//
	//	*AuditTrailEntry_Details_Experimental_
	//	*AuditTrailEntry_Details_ProjectPlanDiffs_
	//	*AuditTrailEntry_Details_ProjectMemberChange_
	Content isAuditTrailEntry_Details_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*AuditTrailEntry_Details) Descriptor deprecated added in v3.13.0

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

Deprecated: Use AuditTrailEntry_Details.ProtoReflect.Descriptor instead.

func (*AuditTrailEntry_Details) GetContent added in v3.13.0

func (m *AuditTrailEntry_Details) GetContent() isAuditTrailEntry_Details_Content

func (*AuditTrailEntry_Details) GetExperimental added in v3.13.0

func (*AuditTrailEntry_Details) GetProjectMemberChange added in v3.13.0

func (*AuditTrailEntry_Details) GetProjectPlanDiffs added in v3.13.0

func (*AuditTrailEntry_Details) ProtoMessage added in v3.13.0

func (*AuditTrailEntry_Details) ProtoMessage()

func (*AuditTrailEntry_Details) ProtoReflect added in v3.13.0

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

func (*AuditTrailEntry_Details) Reset added in v3.13.0

func (x *AuditTrailEntry_Details) Reset()

func (*AuditTrailEntry_Details) String added in v3.13.0

func (x *AuditTrailEntry_Details) String() string

type AuditTrailEntry_Details_Experimental added in v3.13.0

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

for when we don't yet know what the details should entail. Note: this should only be used for a few weeks at most, then a message should be added to the oneof content.

func (*AuditTrailEntry_Details_Experimental) Descriptor deprecated added in v3.13.0

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

Deprecated: Use AuditTrailEntry_Details_Experimental.ProtoReflect.Descriptor instead.

func (*AuditTrailEntry_Details_Experimental) GetContent added in v3.13.0

func (*AuditTrailEntry_Details_Experimental) ProtoMessage added in v3.13.0

func (*AuditTrailEntry_Details_Experimental) ProtoMessage()

func (*AuditTrailEntry_Details_Experimental) ProtoReflect added in v3.13.0

func (*AuditTrailEntry_Details_Experimental) Reset added in v3.13.0

func (*AuditTrailEntry_Details_Experimental) String added in v3.13.0

type AuditTrailEntry_Details_Experimental_ added in v3.13.0

type AuditTrailEntry_Details_Experimental_ struct {
	Experimental *AuditTrailEntry_Details_Experimental `protobuf:"bytes,1,opt,name=experimental,proto3,oneof"`
}

type AuditTrailEntry_Details_ProjectMemberChange added in v3.13.0

type AuditTrailEntry_Details_ProjectMemberChange struct {
	ChangeType AuditTrailEntry_Details_ProjectMemberChange_ChangeType `` /* 180-byte string literal not displayed */
	User       *User                                                  `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditTrailEntry_Details_ProjectMemberChange) Descriptor deprecated added in v3.13.0

Deprecated: Use AuditTrailEntry_Details_ProjectMemberChange.ProtoReflect.Descriptor instead.

func (*AuditTrailEntry_Details_ProjectMemberChange) GetChangeType added in v3.13.0

func (*AuditTrailEntry_Details_ProjectMemberChange) GetUser added in v3.13.0

func (*AuditTrailEntry_Details_ProjectMemberChange) ProtoMessage added in v3.13.0

func (*AuditTrailEntry_Details_ProjectMemberChange) ProtoReflect added in v3.13.0

func (*AuditTrailEntry_Details_ProjectMemberChange) Reset added in v3.13.0

func (*AuditTrailEntry_Details_ProjectMemberChange) String added in v3.13.0

type AuditTrailEntry_Details_ProjectMemberChange_ added in v3.13.0

type AuditTrailEntry_Details_ProjectMemberChange_ struct {
	ProjectMemberChange *AuditTrailEntry_Details_ProjectMemberChange `protobuf:"bytes,3,opt,name=project_member_change,json=projectMemberChange,proto3,oneof"`
}

type AuditTrailEntry_Details_ProjectMemberChange_ChangeType added in v3.13.0

type AuditTrailEntry_Details_ProjectMemberChange_ChangeType int32
const (
	AuditTrailEntry_Details_ProjectMemberChange_CHANGE_TYPE_UNSPECIFIED AuditTrailEntry_Details_ProjectMemberChange_ChangeType = 0
	AuditTrailEntry_Details_ProjectMemberChange_PROJECT_MEMBER_ADDED    AuditTrailEntry_Details_ProjectMemberChange_ChangeType = 1
	AuditTrailEntry_Details_ProjectMemberChange_PROJECT_MEMBER_REMOVED  AuditTrailEntry_Details_ProjectMemberChange_ChangeType = 2
)

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) Descriptor added in v3.13.0

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) Enum added in v3.13.0

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) EnumDescriptor deprecated added in v3.13.0

Deprecated: Use AuditTrailEntry_Details_ProjectMemberChange_ChangeType.Descriptor instead.

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) Number added in v3.13.0

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) String added in v3.13.0

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) Type added in v3.13.0

type AuditTrailEntry_Details_ProjectPlanDiffs added in v3.13.0

type AuditTrailEntry_Details_ProjectPlanDiffs struct {
	Diffs []*Diff `protobuf:"bytes,1,rep,name=diffs,proto3" json:"diffs,omitempty"`
	// the current project plan. The diffs led to this one.
	// using ProjectPlan from v1alpha leads to a cyclic dependency.
	// format json.
	SerializedProjectPlan string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AuditTrailEntry_Details_ProjectPlanDiffs) Descriptor deprecated added in v3.13.0

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

Deprecated: Use AuditTrailEntry_Details_ProjectPlanDiffs.ProtoReflect.Descriptor instead.

func (*AuditTrailEntry_Details_ProjectPlanDiffs) GetDiffs added in v3.13.0

func (*AuditTrailEntry_Details_ProjectPlanDiffs) GetSerializedProjectPlan added in v3.16.0

func (x *AuditTrailEntry_Details_ProjectPlanDiffs) GetSerializedProjectPlan() string

func (*AuditTrailEntry_Details_ProjectPlanDiffs) ProtoMessage added in v3.13.0

func (*AuditTrailEntry_Details_ProjectPlanDiffs) ProtoReflect added in v3.13.0

func (*AuditTrailEntry_Details_ProjectPlanDiffs) Reset added in v3.13.0

func (*AuditTrailEntry_Details_ProjectPlanDiffs) String added in v3.13.0

type AuditTrailEntry_Details_ProjectPlanDiffs_ added in v3.13.0

type AuditTrailEntry_Details_ProjectPlanDiffs_ struct {
	ProjectPlanDiffs *AuditTrailEntry_Details_ProjectPlanDiffs `protobuf:"bytes,2,opt,name=project_plan_diffs,json=projectPlanDiffs,proto3,oneof"`
}

type AuthMechanism

type AuthMechanism int32

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

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

func (AuthMechanism) Descriptor

func (AuthMechanism) Enum

func (x AuthMechanism) Enum() *AuthMechanism

func (AuthMechanism) EnumDescriptor deprecated

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

Deprecated: Use AuthMechanism.Descriptor instead.

func (AuthMechanism) Number

func (AuthMechanism) String

func (x AuthMechanism) String() string

func (AuthMechanism) Type

type AwsS3BucketLocation

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

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

Deprecated: Use AwsS3BucketLocation.ProtoReflect.Descriptor instead.

func (*AwsS3BucketLocation) GetAssumeRoleArn

func (x *AwsS3BucketLocation) GetAssumeRoleArn() string

func (*AwsS3BucketLocation) GetBucketName

func (x *AwsS3BucketLocation) GetBucketName() string

func (*AwsS3BucketLocation) GetCredentials

func (x *AwsS3BucketLocation) GetCredentials() string

func (*AwsS3BucketLocation) ProtoMessage

func (*AwsS3BucketLocation) ProtoMessage()

func (*AwsS3BucketLocation) ProtoReflect

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

func (*AwsS3BucketLocation) Reset

func (x *AwsS3BucketLocation) Reset()

func (*AwsS3BucketLocation) String

func (x *AwsS3BucketLocation) String() string

type AzureBlobStorageContainerLocation

type AzureBlobStorageContainerLocation struct {

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

func (*AzureBlobStorageContainerLocation) Descriptor deprecated

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

Deprecated: Use AzureBlobStorageContainerLocation.ProtoReflect.Descriptor instead.

func (*AzureBlobStorageContainerLocation) GetClientSecretCredential

func (x *AzureBlobStorageContainerLocation) GetClientSecretCredential() *AzureClientSecretCredential

func (*AzureBlobStorageContainerLocation) GetContainerName

func (x *AzureBlobStorageContainerLocation) GetContainerName() string

func (*AzureBlobStorageContainerLocation) GetStorageAccountUri

func (x *AzureBlobStorageContainerLocation) GetStorageAccountUri() string

func (*AzureBlobStorageContainerLocation) ProtoMessage

func (*AzureBlobStorageContainerLocation) ProtoMessage()

func (*AzureBlobStorageContainerLocation) ProtoReflect

func (*AzureBlobStorageContainerLocation) Reset

func (*AzureBlobStorageContainerLocation) String

type AzureClientSecretCredential

type AzureClientSecretCredential struct {

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

func (*AzureClientSecretCredential) Descriptor deprecated

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

Deprecated: Use AzureClientSecretCredential.ProtoReflect.Descriptor instead.

func (*AzureClientSecretCredential) GetClientId

func (x *AzureClientSecretCredential) GetClientId() string

func (*AzureClientSecretCredential) GetClientSecret

func (x *AzureClientSecretCredential) GetClientSecret() string

func (*AzureClientSecretCredential) GetTenantId

func (x *AzureClientSecretCredential) GetTenantId() string

func (*AzureClientSecretCredential) ProtoMessage

func (*AzureClientSecretCredential) ProtoMessage()

func (*AzureClientSecretCredential) ProtoReflect

func (*AzureClientSecretCredential) Reset

func (x *AzureClientSecretCredential) Reset()

func (*AzureClientSecretCredential) String

func (x *AzureClientSecretCredential) String() string

type BatchExporter

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

A batch exporter.

func (*BatchExporter) Descriptor deprecated

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

Deprecated: Use BatchExporter.ProtoReflect.Descriptor instead.

func (*BatchExporter) GetDataConnectorRef

func (x *BatchExporter) GetDataConnectorRef() *DataConnectorRef

func (*BatchExporter) GetIncludeExistingEvents

func (x *BatchExporter) GetIncludeExistingEvents() bool

func (*BatchExporter) GetInterval

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

func (*BatchExporter) GetKeyStreamRef

func (x *BatchExporter) GetKeyStreamRef() *KeyStreamRef

func (*BatchExporter) GetPathPrefix

func (x *BatchExporter) GetPathPrefix() string

func (*BatchExporter) GetRef

func (x *BatchExporter) GetRef() *BatchExporterRef

func (*BatchExporter) GetSinkName deprecated

func (x *BatchExporter) GetSinkName() string

Deprecated: Do not use.

func (*BatchExporter) GetStreamOrKeyStreamRef

func (m *BatchExporter) GetStreamOrKeyStreamRef() isBatchExporter_StreamOrKeyStreamRef

func (*BatchExporter) GetStreamRef

func (x *BatchExporter) GetStreamRef() *StreamRef

func (*BatchExporter) ProtoMessage

func (*BatchExporter) ProtoMessage()

func (*BatchExporter) ProtoReflect

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

func (*BatchExporter) Reset

func (x *BatchExporter) Reset()

func (*BatchExporter) String

func (x *BatchExporter) String() string

type BatchExporterRef

type BatchExporterRef struct {

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

func (*BatchExporterRef) Descriptor deprecated

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

Deprecated: Use BatchExporterRef.ProtoReflect.Descriptor instead.

func (*BatchExporterRef) GetBillingId deprecated

func (x *BatchExporterRef) GetBillingId() string

Deprecated: Do not use.

func (*BatchExporterRef) GetName

func (x *BatchExporterRef) GetName() string

func (*BatchExporterRef) GetProjectId

func (x *BatchExporterRef) GetProjectId() string

func (*BatchExporterRef) ProtoMessage

func (*BatchExporterRef) ProtoMessage()

func (*BatchExporterRef) ProtoReflect

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

func (*BatchExporterRef) Reset

func (x *BatchExporterRef) Reset()

func (*BatchExporterRef) String

func (x *BatchExporterRef) String() string

type BatchExporter_KeyStreamRef

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

type BatchExporter_StreamRef

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

type BatchJob

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

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

func (*BatchJob) Descriptor deprecated

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

Deprecated: Use BatchJob.ProtoReflect.Descriptor instead.

func (*BatchJob) GetConsent

func (x *BatchJob) GetConsent() *ConsentConfig

func (*BatchJob) GetDerivedData

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

func (*BatchJob) GetEncryptedData

func (x *BatchJob) GetEncryptedData() *EncryptedData

func (*BatchJob) GetEncryption

func (x *BatchJob) GetEncryption() *EncryptionConfig

func (*BatchJob) GetEncryptionKeysData

func (x *BatchJob) GetEncryptionKeysData() *EncryptionKeysData

func (*BatchJob) GetEventContractRef

func (x *BatchJob) GetEventContractRef() *EventContractRef

func (*BatchJob) GetPolicyId

func (x *BatchJob) GetPolicyId() string

func (*BatchJob) GetRef

func (x *BatchJob) GetRef() *BatchJobRef

func (*BatchJob) GetSourceData

func (x *BatchJob) GetSourceData() *DataConnectorAndType

func (*BatchJob) GetStates

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

func (*BatchJob) ProtoMessage

func (*BatchJob) ProtoMessage()

func (*BatchJob) ProtoReflect

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

func (*BatchJob) Reset

func (x *BatchJob) Reset()

func (*BatchJob) String

func (x *BatchJob) String() string

type BatchJobRef

type BatchJobRef struct {

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

func (*BatchJobRef) Descriptor deprecated

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

Deprecated: Use BatchJobRef.ProtoReflect.Descriptor instead.

func (*BatchJobRef) GetBillingId deprecated

func (x *BatchJobRef) GetBillingId() string

Deprecated: Do not use.

func (*BatchJobRef) GetId

func (x *BatchJobRef) GetId() string

func (*BatchJobRef) GetProjectId

func (x *BatchJobRef) GetProjectId() string

func (*BatchJobRef) ProtoMessage

func (*BatchJobRef) ProtoMessage()

func (*BatchJobRef) ProtoReflect

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

func (*BatchJobRef) Reset

func (x *BatchJobRef) Reset()

func (*BatchJobRef) String

func (x *BatchJobRef) String() string

type BatchJobState

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

func (*BatchJobState) Descriptor deprecated

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

Deprecated: Use BatchJobState.ProtoReflect.Descriptor instead.

func (*BatchJobState) GetMessage

func (x *BatchJobState) GetMessage() string

func (*BatchJobState) GetState

func (x *BatchJobState) GetState() BatchJobStateType

func (*BatchJobState) GetStateTime

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

func (*BatchJobState) ProtoMessage

func (*BatchJobState) ProtoMessage()

func (*BatchJobState) ProtoReflect

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

func (*BatchJobState) Reset

func (x *BatchJobState) Reset()

func (*BatchJobState) String

func (x *BatchJobState) String() string

type BatchJobStateType

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

func (BatchJobStateType) Descriptor

func (BatchJobStateType) Enum

func (BatchJobStateType) EnumDescriptor deprecated

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

Deprecated: Use BatchJobStateType.Descriptor instead.

func (BatchJobStateType) Number

func (BatchJobStateType) String

func (x BatchJobStateType) String() string

func (BatchJobStateType) Type

type BatchJobWrapper

type BatchJobWrapper struct {

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

func (*BatchJobWrapper) Descriptor deprecated

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

Deprecated: Use BatchJobWrapper.ProtoReflect.Descriptor instead.

func (*BatchJobWrapper) GetEncryptionBatchJob

func (x *BatchJobWrapper) GetEncryptionBatchJob() *BatchJob

func (*BatchJobWrapper) GetJob

func (m *BatchJobWrapper) GetJob() isBatchJobWrapper_Job

func (*BatchJobWrapper) GetMicroAggregationBatchJob

func (x *BatchJobWrapper) GetMicroAggregationBatchJob() *MicroAggregationBatchJob

func (*BatchJobWrapper) ProtoMessage

func (*BatchJobWrapper) ProtoMessage()

func (*BatchJobWrapper) ProtoReflect

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

func (*BatchJobWrapper) Reset

func (x *BatchJobWrapper) Reset()

func (*BatchJobWrapper) String

func (x *BatchJobWrapper) String() string

type BatchJobWrapper_EncryptionBatchJob

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

type BatchJobWrapper_MicroAggregationBatchJob

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

type BucketConfig

type BucketConfig struct {

	// constraints: validated via access check
	BucketName string `protobuf:"bytes,4,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// The credentials that are to be used to access the sink target (e.g. S3 or Google Cloud Storage)
	Credentials string `protobuf:"bytes,5,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// The ARN of the role to assume.
	// If present, start an AssumeRole flow to get temporary credentials in another AWS account.
	// This is used when the customer has a separate users account.
	// Default there is no assumed role.
	AssumeRoleArn string `protobuf:"bytes,6,opt,name=assume_role_arn,json=assumeRoleArn,proto3" json:"assume_role_arn,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketConfig) Descriptor deprecated

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

Deprecated: Use BucketConfig.ProtoReflect.Descriptor instead.

func (*BucketConfig) GetAssumeRoleArn

func (x *BucketConfig) GetAssumeRoleArn() string

func (*BucketConfig) GetBucketName

func (x *BucketConfig) GetBucketName() string

func (*BucketConfig) GetCredentials

func (x *BucketConfig) GetCredentials() string

func (*BucketConfig) ProtoMessage

func (*BucketConfig) ProtoMessage()

func (*BucketConfig) ProtoReflect

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

func (*BucketConfig) Reset

func (x *BucketConfig) Reset()

func (*BucketConfig) String

func (x *BucketConfig) String() string

type Comment

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

func (*Comment) Descriptor deprecated

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

Deprecated: Use Comment.ProtoReflect.Descriptor instead.

func (*Comment) GetContent

func (x *Comment) GetContent() string

func (*Comment) GetCreateTime

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

func (*Comment) GetCreator

func (x *Comment) GetCreator() *User

func (*Comment) GetEntityName added in v3.5.0

func (x *Comment) GetEntityName() string

func (*Comment) GetEntityRef

func (x *Comment) GetEntityRef() *GenericRef

func (*Comment) GetId

func (x *Comment) GetId() string

func (*Comment) GetProjectId added in v3.5.0

func (x *Comment) GetProjectId() string

func (*Comment) ProtoMessage

func (*Comment) ProtoMessage()

func (*Comment) ProtoReflect

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

func (*Comment) Reset

func (x *Comment) Reset()

func (*Comment) String

func (x *Comment) String() string

type ConsentConfig

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

func (*ConsentConfig) Descriptor deprecated

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

Deprecated: Use ConsentConfig.ProtoReflect.Descriptor instead.

func (*ConsentConfig) GetConsentLevelExtractor

func (x *ConsentConfig) GetConsentLevelExtractor() *ConsentLevelExtractor

func (*ConsentConfig) GetDefaultConsentLevels

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

func (*ConsentConfig) ProtoMessage

func (*ConsentConfig) ProtoMessage()

func (*ConsentConfig) ProtoReflect

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

func (*ConsentConfig) Reset

func (x *ConsentConfig) Reset()

func (*ConsentConfig) String

func (x *ConsentConfig) String() string

type ConsentLevelExtractor

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

func (*ConsentLevelExtractor) Descriptor deprecated

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

Deprecated: Use ConsentLevelExtractor.ProtoReflect.Descriptor instead.

func (*ConsentLevelExtractor) GetField

func (x *ConsentLevelExtractor) GetField() string

func (*ConsentLevelExtractor) GetFieldPatterns

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

func (*ConsentLevelExtractor) ProtoMessage

func (*ConsentLevelExtractor) ProtoMessage()

func (*ConsentLevelExtractor) ProtoReflect

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

func (*ConsentLevelExtractor) Reset

func (x *ConsentLevelExtractor) Reset()

func (*ConsentLevelExtractor) String

func (x *ConsentLevelExtractor) String() string

type ConsentLevelMapping

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

for descriptive purposes only.

func (*ConsentLevelMapping) Descriptor deprecated

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

Deprecated: Use ConsentLevelMapping.ProtoReflect.Descriptor instead.

func (*ConsentLevelMapping) GetName

func (x *ConsentLevelMapping) GetName() string

func (*ConsentLevelMapping) GetRef

func (*ConsentLevelMapping) ProtoMessage

func (*ConsentLevelMapping) ProtoMessage()

func (*ConsentLevelMapping) ProtoReflect

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

func (*ConsentLevelMapping) Reset

func (x *ConsentLevelMapping) Reset()

func (*ConsentLevelMapping) String

func (x *ConsentLevelMapping) String() string

type ConsentLevelMappingRef

type ConsentLevelMappingRef struct {

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

func (*ConsentLevelMappingRef) Descriptor deprecated

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

Deprecated: Use ConsentLevelMappingRef.ProtoReflect.Descriptor instead.

func (*ConsentLevelMappingRef) GetBillingId deprecated

func (x *ConsentLevelMappingRef) GetBillingId() string

Deprecated: Do not use.

func (*ConsentLevelMappingRef) GetLevel

func (x *ConsentLevelMappingRef) GetLevel() int32

func (*ConsentLevelMappingRef) GetProjectId

func (x *ConsentLevelMappingRef) GetProjectId() string

func (*ConsentLevelMappingRef) ProtoMessage

func (*ConsentLevelMappingRef) ProtoMessage()

func (*ConsentLevelMappingRef) ProtoReflect

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

func (*ConsentLevelMappingRef) Reset

func (x *ConsentLevelMappingRef) Reset()

func (*ConsentLevelMappingRef) String

func (x *ConsentLevelMappingRef) String() string

type ConsentLevelType

type ConsentLevelType int32

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

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

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

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

func (ConsentLevelType) Descriptor

func (ConsentLevelType) Enum

func (ConsentLevelType) EnumDescriptor deprecated

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

Deprecated: Use ConsentLevelType.Descriptor instead.

func (ConsentLevelType) Number

func (ConsentLevelType) String

func (x ConsentLevelType) String() string

func (ConsentLevelType) Type

type ConsentLevels

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

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

Deprecated: Use ConsentLevels.ProtoReflect.Descriptor instead.

func (*ConsentLevels) GetConsentLevels

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

func (*ConsentLevels) ProtoMessage

func (*ConsentLevels) ProtoMessage()

func (*ConsentLevels) ProtoReflect

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

func (*ConsentLevels) Reset

func (x *ConsentLevels) Reset()

func (*ConsentLevels) String

func (x *ConsentLevels) String() string

type Credentials

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

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

func (*Credentials) Descriptor deprecated

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

Deprecated: Use Credentials.ProtoReflect.Descriptor instead.

func (*Credentials) GetBillingId

func (x *Credentials) GetBillingId() string

func (*Credentials) GetClientId

func (x *Credentials) GetClientId() string

func (*Credentials) GetClientSecret

func (x *Credentials) GetClientSecret() string

func (*Credentials) GetProjectId

func (x *Credentials) GetProjectId() string

func (*Credentials) ProtoMessage

func (*Credentials) ProtoMessage()

func (*Credentials) ProtoReflect

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

func (*Credentials) Reset

func (x *Credentials) Reset()

func (*Credentials) String

func (x *Credentials) String() string

type CsvConfig

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

func (*CsvConfig) Descriptor deprecated

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

Deprecated: Use CsvConfig.ProtoReflect.Descriptor instead.

func (*CsvConfig) GetCharset

func (x *CsvConfig) GetCharset() string

func (*CsvConfig) ProtoMessage

func (*CsvConfig) ProtoMessage()

func (*CsvConfig) ProtoReflect

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

func (*CsvConfig) Reset

func (x *CsvConfig) Reset()

func (*CsvConfig) String

func (x *CsvConfig) String() string

type DataConnector

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

func (*DataConnector) Descriptor deprecated

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

Deprecated: Use DataConnector.ProtoReflect.Descriptor instead.

func (*DataConnector) GetAzureBlobStorageContainer

func (x *DataConnector) GetAzureBlobStorageContainer() *AzureBlobStorageContainerLocation

func (*DataConnector) GetDependentEntities

func (x *DataConnector) GetDependentEntities() *DataConnectorDependentEntities

func (*DataConnector) GetGoogleCloudStorageBucket

func (x *DataConnector) GetGoogleCloudStorageBucket() *GoogleCloudStorageBucketLocation

func (*DataConnector) GetJdbcLocation

func (x *DataConnector) GetJdbcLocation() *JdbcLocation

func (*DataConnector) GetLocation

func (m *DataConnector) GetLocation() isDataConnector_Location

func (*DataConnector) GetRef

func (x *DataConnector) GetRef() *DataConnectorRef

func (*DataConnector) GetS3Bucket

func (x *DataConnector) GetS3Bucket() *AwsS3BucketLocation

func (*DataConnector) GetUuid

func (x *DataConnector) GetUuid() string

func (*DataConnector) ProtoMessage

func (*DataConnector) ProtoMessage()

func (*DataConnector) ProtoReflect

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

func (*DataConnector) Reset

func (x *DataConnector) Reset()

func (*DataConnector) String

func (x *DataConnector) String() string

type DataConnectorAndType

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

func (*DataConnectorAndType) Descriptor deprecated

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

Deprecated: Use DataConnectorAndType.ProtoReflect.Descriptor instead.

func (*DataConnectorAndType) GetDataConnectorRef

func (x *DataConnectorAndType) GetDataConnectorRef() *DataConnectorRef

func (*DataConnectorAndType) GetDataType

func (x *DataConnectorAndType) GetDataType() *DataType

func (*DataConnectorAndType) GetFileName

func (x *DataConnectorAndType) GetFileName() string

func (*DataConnectorAndType) GetPathPrefix

func (x *DataConnectorAndType) GetPathPrefix() string

func (*DataConnectorAndType) ProtoMessage

func (*DataConnectorAndType) ProtoMessage()

func (*DataConnectorAndType) ProtoReflect

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

func (*DataConnectorAndType) Reset

func (x *DataConnectorAndType) Reset()

func (*DataConnectorAndType) String

func (x *DataConnectorAndType) String() string

type DataConnectorDependentEntities

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

func (*DataConnectorDependentEntities) Descriptor deprecated

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

Deprecated: Use DataConnectorDependentEntities.ProtoReflect.Descriptor instead.

func (*DataConnectorDependentEntities) GetBatchExporters

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

func (*DataConnectorDependentEntities) GetBatchJobs

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

func (*DataConnectorDependentEntities) GetMicroAggregationBatchJobs

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

func (*DataConnectorDependentEntities) ProtoMessage

func (*DataConnectorDependentEntities) ProtoMessage()

func (*DataConnectorDependentEntities) ProtoReflect

func (*DataConnectorDependentEntities) Reset

func (x *DataConnectorDependentEntities) Reset()

func (*DataConnectorDependentEntities) String

type DataConnectorRef

type DataConnectorRef struct {

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

func (*DataConnectorRef) Descriptor deprecated

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

Deprecated: Use DataConnectorRef.ProtoReflect.Descriptor instead.

func (*DataConnectorRef) GetBillingId deprecated

func (x *DataConnectorRef) GetBillingId() string

Deprecated: Do not use.

func (*DataConnectorRef) GetName

func (x *DataConnectorRef) GetName() string

func (*DataConnectorRef) GetProjectId

func (x *DataConnectorRef) GetProjectId() string

func (*DataConnectorRef) ProtoMessage

func (*DataConnectorRef) ProtoMessage()

func (*DataConnectorRef) ProtoReflect

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

func (*DataConnectorRef) Reset

func (x *DataConnectorRef) Reset()

func (*DataConnectorRef) String

func (x *DataConnectorRef) String() string

type DataConnector_AzureBlobStorageContainer

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

type DataConnector_GoogleCloudStorageBucket

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

type DataConnector_JdbcLocation

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

type DataConnector_S3Bucket

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

type DataContract

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

func (*DataContract) Descriptor deprecated

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

Deprecated: Use DataContract.ProtoReflect.Descriptor instead.

func (*DataContract) GetCreatorExternalUserId added in v3.8.0

func (x *DataContract) GetCreatorExternalUserId() string

func (*DataContract) GetDataSubjectField

func (x *DataContract) GetDataSubjectField() string

func (*DataContract) GetFieldMetadata

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

func (*DataContract) GetId

func (x *DataContract) GetId() string

func (*DataContract) GetIsPublic

func (x *DataContract) GetIsPublic() bool

func (*DataContract) GetKeyField

func (x *DataContract) GetKeyField() string

func (*DataContract) GetMetadata

func (x *DataContract) GetMetadata() *DataContractMetadata

func (*DataContract) GetPiiFields deprecated

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

Deprecated: Do not use.

func (*DataContract) GetProjectId

func (x *DataContract) GetProjectId() string

func (*DataContract) GetRef

func (x *DataContract) GetRef() *DataContractRef

func (*DataContract) GetSchema

func (x *DataContract) GetSchema() *Schema

func (*DataContract) GetState

func (x *DataContract) GetState() DataContract_State

func (*DataContract) GetValidations

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

func (*DataContract) ProtoMessage

func (*DataContract) ProtoMessage()

func (*DataContract) ProtoReflect

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

func (*DataContract) Reset

func (x *DataContract) Reset()

func (*DataContract) String

func (x *DataContract) String() string

type DataContractMetadata

type DataContractMetadata struct {

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

func (*DataContractMetadata) Descriptor deprecated

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

Deprecated: Use DataContractMetadata.ProtoReflect.Descriptor instead.

func (*DataContractMetadata) GetCreateTime

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

func (*DataContractMetadata) GetDescription

func (x *DataContractMetadata) GetDescription() string

func (*DataContractMetadata) GetDomains

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

func (*DataContractMetadata) GetIndustries

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

func (*DataContractMetadata) GetLabels

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

func (*DataContractMetadata) GetTitle

func (x *DataContractMetadata) GetTitle() string

func (*DataContractMetadata) ProtoMessage

func (*DataContractMetadata) ProtoMessage()

func (*DataContractMetadata) ProtoReflect

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

func (*DataContractMetadata) Reset

func (x *DataContractMetadata) Reset()

func (*DataContractMetadata) String

func (x *DataContractMetadata) String() string

type DataContractRef

type DataContractRef struct {

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

func (*DataContractRef) Descriptor deprecated

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

Deprecated: Use DataContractRef.ProtoReflect.Descriptor instead.

func (*DataContractRef) GetHandle

func (x *DataContractRef) GetHandle() string

func (*DataContractRef) GetName

func (x *DataContractRef) GetName() string

func (*DataContractRef) GetVersion

func (x *DataContractRef) GetVersion() string

func (*DataContractRef) ProtoMessage

func (*DataContractRef) ProtoMessage()

func (*DataContractRef) ProtoReflect

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

func (*DataContractRef) Reset

func (x *DataContractRef) Reset()

func (*DataContractRef) String

func (x *DataContractRef) String() string

type DataContract_State

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

func (DataContract_State) Descriptor

func (DataContract_State) Enum

func (DataContract_State) EnumDescriptor deprecated

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

Deprecated: Use DataContract_State.Descriptor instead.

func (DataContract_State) Number

func (DataContract_State) String

func (x DataContract_State) String() string

func (DataContract_State) Type

type DataType

type DataType struct {

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

func (*DataType) Descriptor deprecated

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

Deprecated: Use DataType.ProtoReflect.Descriptor instead.

func (*DataType) GetCsv

func (x *DataType) GetCsv() *CsvConfig

func (*DataType) GetDataType

func (m *DataType) GetDataType() isDataType_DataType

func (*DataType) GetDatabase

func (x *DataType) GetDatabase() *DatabaseConfig

func (*DataType) ProtoMessage

func (*DataType) ProtoMessage()

func (*DataType) ProtoReflect

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

func (*DataType) Reset

func (x *DataType) Reset()

func (*DataType) String

func (x *DataType) String() string

type DataType_Csv

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

type DataType_Database

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

type DatabaseConfig

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

func (*DatabaseConfig) Descriptor deprecated

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

Deprecated: Use DatabaseConfig.ProtoReflect.Descriptor instead.

func (*DatabaseConfig) GetColumns

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

func (*DatabaseConfig) GetSchema

func (x *DatabaseConfig) GetSchema() string

func (*DatabaseConfig) GetTable

func (x *DatabaseConfig) GetTable() string

func (*DatabaseConfig) ProtoMessage

func (*DatabaseConfig) ProtoMessage()

func (*DatabaseConfig) ProtoReflect

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

func (*DatabaseConfig) Reset

func (x *DatabaseConfig) Reset()

func (*DatabaseConfig) String

func (x *DatabaseConfig) String() string

type DatabaseType

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

func (DatabaseType) Descriptor

func (DatabaseType) Enum

func (x DatabaseType) Enum() *DatabaseType

func (DatabaseType) EnumDescriptor deprecated

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

Deprecated: Use DatabaseType.Descriptor instead.

func (DatabaseType) Number

func (DatabaseType) String

func (x DatabaseType) String() string

func (DatabaseType) Type

type DerivedData

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

func (*DerivedData) Descriptor deprecated

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

Deprecated: Use DerivedData.ProtoReflect.Descriptor instead.

func (*DerivedData) GetConsentLevelType

func (x *DerivedData) GetConsentLevelType() ConsentLevelType

func (*DerivedData) GetConsentLevels

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

func (*DerivedData) GetMaskedFields

func (x *DerivedData) GetMaskedFields() *MaskedFields

func (*DerivedData) GetTarget

func (x *DerivedData) GetTarget() *DataConnectorAndType

func (*DerivedData) ProtoMessage

func (*DerivedData) ProtoMessage()

func (*DerivedData) ProtoReflect

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

func (*DerivedData) Reset

func (x *DerivedData) Reset()

func (*DerivedData) String

func (x *DerivedData) String() string

type Diff added in v3.13.0

type Diff struct {
	DiffType Diff_DiffType `` /* 133-byte string literal not displayed */
	Path     string        `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Node     string        `protobuf:"bytes,3,opt,name=node,proto3" json:"node,omitempty"`
	Expected string        `protobuf:"bytes,4,opt,name=expected,proto3" json:"expected,omitempty"`
	// contains filtered or unexported fields
}

used for describing changes in json trees

func (*Diff) Descriptor deprecated added in v3.13.0

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

Deprecated: Use Diff.ProtoReflect.Descriptor instead.

func (*Diff) GetDiffType added in v3.13.0

func (x *Diff) GetDiffType() Diff_DiffType

func (*Diff) GetExpected added in v3.13.0

func (x *Diff) GetExpected() string

func (*Diff) GetNode added in v3.13.0

func (x *Diff) GetNode() string

func (*Diff) GetPath added in v3.13.0

func (x *Diff) GetPath() string

func (*Diff) ProtoMessage added in v3.13.0

func (*Diff) ProtoMessage()

func (*Diff) ProtoReflect added in v3.13.0

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

func (*Diff) Reset added in v3.13.0

func (x *Diff) Reset()

func (*Diff) String added in v3.13.0

func (x *Diff) String() string

type Diff_DiffType added in v3.13.0

type Diff_DiffType int32
const (
	Diff_DIFF_TYPE_UNSPECIFIED Diff_DiffType = 0
	Diff_MISSING               Diff_DiffType = 1
	Diff_UNEXPECTED            Diff_DiffType = 2
	Diff_DIFFERENT             Diff_DiffType = 3
)

func (Diff_DiffType) Descriptor added in v3.13.0

func (Diff_DiffType) Enum added in v3.13.0

func (x Diff_DiffType) Enum() *Diff_DiffType

func (Diff_DiffType) EnumDescriptor deprecated added in v3.13.0

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

Deprecated: Use Diff_DiffType.Descriptor instead.

func (Diff_DiffType) Number added in v3.13.0

func (Diff_DiffType) String added in v3.13.0

func (x Diff_DiffType) String() string

func (Diff_DiffType) Type added in v3.13.0

type EncryptedData

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

func (*EncryptedData) Descriptor deprecated

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

Deprecated: Use EncryptedData.ProtoReflect.Descriptor instead.

func (*EncryptedData) GetTarget

func (x *EncryptedData) GetTarget() *DataConnectorAndType

func (*EncryptedData) ProtoMessage

func (*EncryptedData) ProtoMessage()

func (*EncryptedData) ProtoReflect

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

func (*EncryptedData) Reset

func (x *EncryptedData) Reset()

func (*EncryptedData) String

func (x *EncryptedData) String() string

type EncryptionConfig

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

func (*EncryptionConfig) Descriptor deprecated

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

Deprecated: Use EncryptionConfig.ProtoReflect.Descriptor instead.

func (*EncryptionConfig) GetBatchJobGroupId

func (x *EncryptionConfig) GetBatchJobGroupId() string

func (*EncryptionConfig) GetTimestampConfig

func (x *EncryptionConfig) GetTimestampConfig() *TimestampConfig

func (*EncryptionConfig) ProtoMessage

func (*EncryptionConfig) ProtoMessage()

func (*EncryptionConfig) ProtoReflect

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

func (*EncryptionConfig) Reset

func (x *EncryptionConfig) Reset()

func (*EncryptionConfig) String

func (x *EncryptionConfig) String() string

type EncryptionKeysData

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

func (*EncryptionKeysData) Descriptor deprecated

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

Deprecated: Use EncryptionKeysData.ProtoReflect.Descriptor instead.

func (*EncryptionKeysData) GetTarget

func (x *EncryptionKeysData) GetTarget() *DataConnectorAndType

func (*EncryptionKeysData) ProtoMessage

func (*EncryptionKeysData) ProtoMessage()

func (*EncryptionKeysData) ProtoReflect

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

func (*EncryptionKeysData) Reset

func (x *EncryptionKeysData) Reset()

func (*EncryptionKeysData) String

func (x *EncryptionKeysData) String() string

type EventContract

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

func (*EventContract) Descriptor deprecated

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

Deprecated: Use EventContract.ProtoReflect.Descriptor instead.

func (*EventContract) GetDataSubjectField

func (x *EventContract) GetDataSubjectField() string

func (*EventContract) GetId

func (x *EventContract) GetId() string

func (*EventContract) GetIsPublic

func (x *EventContract) GetIsPublic() bool

func (*EventContract) GetKeyField

func (x *EventContract) GetKeyField() string

func (*EventContract) GetMetadata

func (x *EventContract) GetMetadata() *EventContractMetadata

func (*EventContract) GetPiiFields

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

func (*EventContract) GetRef

func (x *EventContract) GetRef() *EventContractRef

func (*EventContract) GetSchemaRef

func (x *EventContract) GetSchemaRef() *SchemaRef

func (*EventContract) GetState

func (x *EventContract) GetState() EventContract_State

func (*EventContract) GetValidations

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

func (*EventContract) ProtoMessage

func (*EventContract) ProtoMessage()

func (*EventContract) ProtoReflect

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

func (*EventContract) Reset

func (x *EventContract) Reset()

func (*EventContract) String

func (x *EventContract) String() string

type EventContractMetadata

type EventContractMetadata struct {

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

func (*EventContractMetadata) Descriptor deprecated

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

Deprecated: Use EventContractMetadata.ProtoReflect.Descriptor instead.

func (*EventContractMetadata) GetCreateTime

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

func (*EventContractMetadata) GetDescription

func (x *EventContractMetadata) GetDescription() string

func (*EventContractMetadata) GetDomains

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

func (*EventContractMetadata) GetIconUri

func (x *EventContractMetadata) GetIconUri() string

func (*EventContractMetadata) GetIndustries

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

func (*EventContractMetadata) GetLabels

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

func (*EventContractMetadata) GetTitle

func (x *EventContractMetadata) GetTitle() string

func (*EventContractMetadata) ProtoMessage

func (*EventContractMetadata) ProtoMessage()

func (*EventContractMetadata) ProtoReflect

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

func (*EventContractMetadata) Reset

func (x *EventContractMetadata) Reset()

func (*EventContractMetadata) String

func (x *EventContractMetadata) String() string

type EventContractRef

type EventContractRef struct {

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

func (*EventContractRef) Descriptor deprecated

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

Deprecated: Use EventContractRef.ProtoReflect.Descriptor instead.

func (*EventContractRef) GetHandle

func (x *EventContractRef) GetHandle() string

func (*EventContractRef) GetName

func (x *EventContractRef) GetName() string

func (*EventContractRef) GetVersion

func (x *EventContractRef) GetVersion() string

func (*EventContractRef) ProtoMessage

func (*EventContractRef) ProtoMessage()

func (*EventContractRef) ProtoReflect

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

func (*EventContractRef) Reset

func (x *EventContractRef) Reset()

func (*EventContractRef) String

func (x *EventContractRef) String() string

type EventContract_State

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

func (EventContract_State) Descriptor

func (EventContract_State) Enum

func (EventContract_State) EnumDescriptor deprecated

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

Deprecated: Use EventContract_State.Descriptor instead.

func (EventContract_State) Number

func (EventContract_State) String

func (x EventContract_State) String() string

func (EventContract_State) Type

type ExtendedBatchExporter

type ExtendedBatchExporter struct {

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

func (*ExtendedBatchExporter) Descriptor deprecated

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

Deprecated: Use ExtendedBatchExporter.ProtoReflect.Descriptor instead.

func (*ExtendedBatchExporter) GetExporter

func (x *ExtendedBatchExporter) GetExporter() *BatchExporter

func (*ExtendedBatchExporter) GetTopic

func (x *ExtendedBatchExporter) GetTopic() string

func (*ExtendedBatchExporter) GetUuid

func (x *ExtendedBatchExporter) GetUuid() string

func (*ExtendedBatchExporter) ProtoMessage

func (*ExtendedBatchExporter) ProtoMessage()

func (*ExtendedBatchExporter) ProtoReflect

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

func (*ExtendedBatchExporter) Reset

func (x *ExtendedBatchExporter) Reset()

func (*ExtendedBatchExporter) String

func (x *ExtendedBatchExporter) String() string

type ExtendedBatchJob

type ExtendedBatchJob struct {

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

func (*ExtendedBatchJob) Descriptor deprecated

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

Deprecated: Use ExtendedBatchJob.ProtoReflect.Descriptor instead.

func (*ExtendedBatchJob) GetBatchJob deprecated

func (x *ExtendedBatchJob) GetBatchJob() *BatchJob

Deprecated: Do not use.

func (*ExtendedBatchJob) GetJob

func (x *ExtendedBatchJob) GetJob() *BatchJobWrapper

func (*ExtendedBatchJob) ProtoMessage

func (*ExtendedBatchJob) ProtoMessage()

func (*ExtendedBatchJob) ProtoReflect

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

func (*ExtendedBatchJob) Reset

func (x *ExtendedBatchJob) Reset()

func (*ExtendedBatchJob) String

func (x *ExtendedBatchJob) String() string

type ExtendedStream

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

func (*ExtendedStream) Descriptor deprecated

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

Deprecated: Use ExtendedStream.ProtoReflect.Descriptor instead.

func (*ExtendedStream) GetKeyStream

func (x *ExtendedStream) GetKeyStream() bool

func (*ExtendedStream) GetStream

func (x *ExtendedStream) GetStream() *Stream

func (*ExtendedStream) GetTopic

func (x *ExtendedStream) GetTopic() string

func (*ExtendedStream) GetUuid

func (x *ExtendedStream) GetUuid() string

func (*ExtendedStream) ProtoMessage

func (*ExtendedStream) ProtoMessage()

func (*ExtendedStream) ProtoReflect

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

func (*ExtendedStream) Reset

func (x *ExtendedStream) Reset()

func (*ExtendedStream) String

func (x *ExtendedStream) String() string

type ExtendedStreamGroup

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

func (*ExtendedStreamGroup) Descriptor deprecated

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

Deprecated: Use ExtendedStreamGroup.ProtoReflect.Descriptor instead.

func (*ExtendedStreamGroup) GetDerivedStreams

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

func (*ExtendedStreamGroup) GetSourceStream

func (x *ExtendedStreamGroup) GetSourceStream() *ExtendedStream

func (*ExtendedStreamGroup) ProtoMessage

func (*ExtendedStreamGroup) ProtoMessage()

func (*ExtendedStreamGroup) ProtoReflect

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

func (*ExtendedStreamGroup) Reset

func (x *ExtendedStreamGroup) Reset()

func (*ExtendedStreamGroup) String

func (x *ExtendedStreamGroup) String() string

type FieldMetadata

type FieldMetadata struct {

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

func (*FieldMetadata) Descriptor deprecated

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

Deprecated: Use FieldMetadata.ProtoReflect.Descriptor instead.

func (*FieldMetadata) GetFieldName

func (x *FieldMetadata) GetFieldName() string

func (*FieldMetadata) GetNullHandlingConfig

func (x *FieldMetadata) GetNullHandlingConfig() *FieldMetadata_NullHandlingConfig

func (*FieldMetadata) GetOrdinalValues

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

func (*FieldMetadata) GetPersonalDataConfig

func (x *FieldMetadata) GetPersonalDataConfig() *FieldMetadata_PersonalDataConfig

func (*FieldMetadata) GetStatisticalDataType

func (x *FieldMetadata) GetStatisticalDataType() StatisticalDataType

func (*FieldMetadata) ProtoMessage

func (*FieldMetadata) ProtoMessage()

func (*FieldMetadata) ProtoReflect

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

func (*FieldMetadata) Reset

func (x *FieldMetadata) Reset()

func (*FieldMetadata) String

func (x *FieldMetadata) String() string

type FieldMetadata_NullHandlingConfig

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

func (*FieldMetadata_NullHandlingConfig) Descriptor deprecated

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

Deprecated: Use FieldMetadata_NullHandlingConfig.ProtoReflect.Descriptor instead.

func (*FieldMetadata_NullHandlingConfig) GetDefaultValue

func (x *FieldMetadata_NullHandlingConfig) GetDefaultValue() string

func (*FieldMetadata_NullHandlingConfig) GetType

func (*FieldMetadata_NullHandlingConfig) ProtoMessage

func (*FieldMetadata_NullHandlingConfig) ProtoMessage()

func (*FieldMetadata_NullHandlingConfig) ProtoReflect

func (*FieldMetadata_NullHandlingConfig) Reset

func (*FieldMetadata_NullHandlingConfig) String

type FieldMetadata_NullHandlingConfig_NullHandlingType

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

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Descriptor

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Enum

func (FieldMetadata_NullHandlingConfig_NullHandlingType) EnumDescriptor deprecated

Deprecated: Use FieldMetadata_NullHandlingConfig_NullHandlingType.Descriptor instead.

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Number

func (FieldMetadata_NullHandlingConfig_NullHandlingType) String

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Type

type FieldMetadata_PersonalDataConfig

type FieldMetadata_PersonalDataConfig struct {

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

func (*FieldMetadata_PersonalDataConfig) Descriptor deprecated

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

Deprecated: Use FieldMetadata_PersonalDataConfig.ProtoReflect.Descriptor instead.

func (*FieldMetadata_PersonalDataConfig) GetGdprSpecialPersonalDataType

func (x *FieldMetadata_PersonalDataConfig) GetGdprSpecialPersonalDataType() string

func (*FieldMetadata_PersonalDataConfig) GetIsPii

func (x *FieldMetadata_PersonalDataConfig) GetIsPii() bool

func (*FieldMetadata_PersonalDataConfig) GetIsQuasiId

func (x *FieldMetadata_PersonalDataConfig) GetIsQuasiId() bool

func (*FieldMetadata_PersonalDataConfig) GetPurposeLevel

func (x *FieldMetadata_PersonalDataConfig) GetPurposeLevel() int32

func (*FieldMetadata_PersonalDataConfig) ProtoMessage

func (*FieldMetadata_PersonalDataConfig) ProtoMessage()

func (*FieldMetadata_PersonalDataConfig) ProtoReflect

func (*FieldMetadata_PersonalDataConfig) Reset

func (*FieldMetadata_PersonalDataConfig) String

type FilterPublicPrivate

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

func (FilterPublicPrivate) Descriptor

func (FilterPublicPrivate) Enum

func (FilterPublicPrivate) EnumDescriptor deprecated

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

Deprecated: Use FilterPublicPrivate.Descriptor instead.

func (FilterPublicPrivate) Number

func (FilterPublicPrivate) String

func (x FilterPublicPrivate) String() string

func (FilterPublicPrivate) Type

type GenericRef

type GenericRef struct {
	Type GenericRef_GenericRefType `protobuf:"varint,1,opt,name=type,proto3,enum=strmprivacy.api.entities.v1.GenericRef_GenericRefType" json:"type,omitempty"`
	Id   string                    `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

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

func (*GenericRef) Descriptor deprecated

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

Deprecated: Use GenericRef.ProtoReflect.Descriptor instead.

func (*GenericRef) GetId

func (x *GenericRef) GetId() string

func (*GenericRef) GetType

func (*GenericRef) ProtoMessage

func (*GenericRef) ProtoMessage()

func (*GenericRef) ProtoReflect

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

func (*GenericRef) Reset

func (x *GenericRef) Reset()

func (*GenericRef) String

func (x *GenericRef) String() string

type GenericRef_GenericRefType

type GenericRef_GenericRefType int32
const (
	GenericRef_GENERIC_REF_TYPE_UNSPECIFIED GenericRef_GenericRefType = 0
	// id contains the data-contract uuid
	GenericRef_DATA_CONTRACT GenericRef_GenericRefType = 1
	// id contains the project uuid
	GenericRef_PROJECT GenericRef_GenericRefType = 2
	// id contains the stream uuid
	GenericRef_STREAM GenericRef_GenericRefType = 3
	// id = '<project-id>:<name>'
	GenericRef_BATCH_EXPORTER GenericRef_GenericRefType = 4
	// id = '<project-id>:<name>'
	GenericRef_DATA_CONNECTOR GenericRef_GenericRefType = 5
	// id = '<project-id>:<name>'
	GenericRef_KAFKA_EXPORTER GenericRef_GenericRefType = 6
	// id = project-plan id
	GenericRef_PROJECT_PLAN GenericRef_GenericRefType = 7
)

func (GenericRef_GenericRefType) Descriptor

func (GenericRef_GenericRefType) Enum

func (GenericRef_GenericRefType) EnumDescriptor deprecated

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

Deprecated: Use GenericRef_GenericRefType.Descriptor instead.

func (GenericRef_GenericRefType) Number

func (GenericRef_GenericRefType) String

func (x GenericRef_GenericRefType) String() string

func (GenericRef_GenericRefType) Type

type GoogleCloudStorageBucketLocation

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

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

Deprecated: Use GoogleCloudStorageBucketLocation.ProtoReflect.Descriptor instead.

func (*GoogleCloudStorageBucketLocation) GetBucketName

func (x *GoogleCloudStorageBucketLocation) GetBucketName() string

func (*GoogleCloudStorageBucketLocation) GetCredentials

func (x *GoogleCloudStorageBucketLocation) GetCredentials() string

func (*GoogleCloudStorageBucketLocation) ProtoMessage

func (*GoogleCloudStorageBucketLocation) ProtoMessage()

func (*GoogleCloudStorageBucketLocation) ProtoReflect

func (*GoogleCloudStorageBucketLocation) Reset

func (*GoogleCloudStorageBucketLocation) String

type JdbcLocation

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

func (*JdbcLocation) Descriptor deprecated

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

Deprecated: Use JdbcLocation.ProtoReflect.Descriptor instead.

func (*JdbcLocation) GetDatabaseType

func (x *JdbcLocation) GetDatabaseType() DatabaseType

func (*JdbcLocation) GetJdbcUri

func (x *JdbcLocation) GetJdbcUri() string

func (*JdbcLocation) GetPrivateKey

func (x *JdbcLocation) GetPrivateKey() string

func (*JdbcLocation) ProtoMessage

func (*JdbcLocation) ProtoMessage()

func (*JdbcLocation) ProtoReflect

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

func (*JdbcLocation) Reset

func (x *JdbcLocation) Reset()

func (*JdbcLocation) String

func (x *JdbcLocation) String() string

type KafkaCluster

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

Currently only our internal shared export cluster.

func (*KafkaCluster) Descriptor deprecated

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

Deprecated: Use KafkaCluster.ProtoReflect.Descriptor instead.

func (*KafkaCluster) GetAuthMechanism

func (x *KafkaCluster) GetAuthMechanism() AuthMechanism

func (*KafkaCluster) GetBootstrapServers

func (x *KafkaCluster) GetBootstrapServers() string

func (*KafkaCluster) GetRef

func (x *KafkaCluster) GetRef() *KafkaClusterRef

func (*KafkaCluster) GetTokenUri

func (x *KafkaCluster) GetTokenUri() string

func (*KafkaCluster) ProtoMessage

func (*KafkaCluster) ProtoMessage()

func (*KafkaCluster) ProtoReflect

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

func (*KafkaCluster) Reset

func (x *KafkaCluster) Reset()

func (*KafkaCluster) String

func (x *KafkaCluster) String() string

type KafkaClusterRef

type KafkaClusterRef struct {

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

How to refer to a certain Kafka cluster.

func (*KafkaClusterRef) Descriptor deprecated

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

Deprecated: Use KafkaClusterRef.ProtoReflect.Descriptor instead.

func (*KafkaClusterRef) GetBillingId

func (x *KafkaClusterRef) GetBillingId() string

func (*KafkaClusterRef) GetName

func (x *KafkaClusterRef) GetName() string

func (*KafkaClusterRef) GetProjectId

func (x *KafkaClusterRef) GetProjectId() string

func (*KafkaClusterRef) ProtoMessage

func (*KafkaClusterRef) ProtoMessage()

func (*KafkaClusterRef) ProtoReflect

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

func (*KafkaClusterRef) Reset

func (x *KafkaClusterRef) Reset()

func (*KafkaClusterRef) String

func (x *KafkaClusterRef) String() string

type KafkaExporter

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

func (*KafkaExporter) Descriptor deprecated

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

Deprecated: Use KafkaExporter.ProtoReflect.Descriptor instead.

func (*KafkaExporter) GetRef

func (x *KafkaExporter) GetRef() *KafkaExporterRef

func (*KafkaExporter) GetStreamRef

func (x *KafkaExporter) GetStreamRef() *StreamRef

func (*KafkaExporter) GetTarget

func (x *KafkaExporter) GetTarget() *KafkaExporterTarget

func (*KafkaExporter) GetUsers

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

func (*KafkaExporter) ProtoMessage

func (*KafkaExporter) ProtoMessage()

func (*KafkaExporter) ProtoReflect

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

func (*KafkaExporter) Reset

func (x *KafkaExporter) Reset()

func (*KafkaExporter) String

func (x *KafkaExporter) String() string

type KafkaExporterRef

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

func (*KafkaExporterRef) Descriptor deprecated

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

Deprecated: Use KafkaExporterRef.ProtoReflect.Descriptor instead.

func (*KafkaExporterRef) GetBillingId

func (x *KafkaExporterRef) GetBillingId() string

func (*KafkaExporterRef) GetName

func (x *KafkaExporterRef) GetName() string

func (*KafkaExporterRef) GetProjectId

func (x *KafkaExporterRef) GetProjectId() string

func (*KafkaExporterRef) ProtoMessage

func (*KafkaExporterRef) ProtoMessage()

func (*KafkaExporterRef) ProtoReflect

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

func (*KafkaExporterRef) Reset

func (x *KafkaExporterRef) Reset()

func (*KafkaExporterRef) String

func (x *KafkaExporterRef) String() string

type KafkaExporterTarget

type KafkaExporterTarget struct {

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

func (*KafkaExporterTarget) Descriptor deprecated

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

Deprecated: Use KafkaExporterTarget.ProtoReflect.Descriptor instead.

func (*KafkaExporterTarget) GetClientId

func (x *KafkaExporterTarget) GetClientId() string

func (*KafkaExporterTarget) GetClientSecret

func (x *KafkaExporterTarget) GetClientSecret() string

func (*KafkaExporterTarget) GetClusterRef

func (x *KafkaExporterTarget) GetClusterRef() *KafkaClusterRef

func (*KafkaExporterTarget) GetTopic

func (x *KafkaExporterTarget) GetTopic() string

func (*KafkaExporterTarget) ProtoMessage

func (*KafkaExporterTarget) ProtoMessage()

func (*KafkaExporterTarget) ProtoReflect

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

func (*KafkaExporterTarget) Reset

func (x *KafkaExporterTarget) Reset()

func (*KafkaExporterTarget) String

func (x *KafkaExporterTarget) String() string

type KafkaUser

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

User credentials to consume from topic produced by Kafka Exporter.

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

func (*KafkaUser) Descriptor deprecated

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

Deprecated: Use KafkaUser.ProtoReflect.Descriptor instead.

func (*KafkaUser) GetClientId

func (x *KafkaUser) GetClientId() string

func (*KafkaUser) GetClientSecret

func (x *KafkaUser) GetClientSecret() string

func (*KafkaUser) GetClusterRef

func (x *KafkaUser) GetClusterRef() *KafkaClusterRef

func (*KafkaUser) GetKafkaExporterName

func (x *KafkaUser) GetKafkaExporterName() string

func (*KafkaUser) GetRef

func (x *KafkaUser) GetRef() *KafkaUserRef

func (*KafkaUser) GetTopic

func (x *KafkaUser) GetTopic() string

func (*KafkaUser) ProtoMessage

func (*KafkaUser) ProtoMessage()

func (*KafkaUser) ProtoReflect

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

func (*KafkaUser) Reset

func (x *KafkaUser) Reset()

func (*KafkaUser) String

func (x *KafkaUser) String() string

type KafkaUserRef

type KafkaUserRef struct {

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

func (*KafkaUserRef) Descriptor deprecated

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

Deprecated: Use KafkaUserRef.ProtoReflect.Descriptor instead.

func (*KafkaUserRef) GetBillingId deprecated

func (x *KafkaUserRef) GetBillingId() string

Deprecated: Do not use.

func (*KafkaUserRef) GetName

func (x *KafkaUserRef) GetName() string

func (*KafkaUserRef) GetProjectId

func (x *KafkaUserRef) GetProjectId() string

func (*KafkaUserRef) ProtoMessage

func (*KafkaUserRef) ProtoMessage()

func (*KafkaUserRef) ProtoReflect

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

func (*KafkaUserRef) Reset

func (x *KafkaUserRef) Reset()

func (*KafkaUserRef) String

func (x *KafkaUserRef) String() string

type KeyStream

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

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

func (*KeyStream) Descriptor deprecated

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

Deprecated: Use KeyStream.ProtoReflect.Descriptor instead.

func (*KeyStream) GetKafkaTopic

func (x *KeyStream) GetKafkaTopic() string

func (*KeyStream) GetRef

func (x *KeyStream) GetRef() *KeyStreamRef

func (*KeyStream) GetStatus deprecated

func (x *KeyStream) GetStatus() string

Deprecated: Do not use.

func (*KeyStream) ProtoMessage

func (*KeyStream) ProtoMessage()

func (*KeyStream) ProtoReflect

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

func (*KeyStream) Reset

func (x *KeyStream) Reset()

func (*KeyStream) String

func (x *KeyStream) String() string

type KeyStreamRef

type KeyStreamRef struct {

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

refers to a key stream.

func (*KeyStreamRef) Descriptor deprecated

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

Deprecated: Use KeyStreamRef.ProtoReflect.Descriptor instead.

func (*KeyStreamRef) GetBillingId deprecated

func (x *KeyStreamRef) GetBillingId() string

Deprecated: Do not use.

func (*KeyStreamRef) GetName

func (x *KeyStreamRef) GetName() string

func (*KeyStreamRef) GetProjectId

func (x *KeyStreamRef) GetProjectId() string

func (*KeyStreamRef) ProtoMessage

func (*KeyStreamRef) ProtoMessage()

func (*KeyStreamRef) ProtoReflect

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

func (*KeyStreamRef) Reset

func (x *KeyStreamRef) Reset()

func (*KeyStreamRef) String

func (x *KeyStreamRef) String() string

type Label

type Label struct {

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

func (*Label) Descriptor deprecated

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

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) GetKey

func (x *Label) GetKey() string

func (*Label) GetValue

func (x *Label) GetValue() string

func (*Label) ProtoMessage

func (*Label) ProtoMessage()

func (*Label) ProtoReflect

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

func (*Label) Reset

func (x *Label) Reset()

func (*Label) String

func (x *Label) String() string

type Limits

type Limits struct {

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

func (*Limits) Descriptor deprecated

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

Deprecated: Use Limits.ProtoReflect.Descriptor instead.

func (*Limits) GetEventCount

func (x *Limits) GetEventCount() int64

func (*Limits) GetEventRate

func (x *Limits) GetEventRate() int64

func (*Limits) ProtoMessage

func (*Limits) ProtoMessage()

func (*Limits) ProtoReflect

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

func (*Limits) Reset

func (x *Limits) Reset()

func (*Limits) String

func (x *Limits) String() string

type MaskedFields

type MaskedFields struct {

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

func (*MaskedFields) Descriptor deprecated

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

Deprecated: Use MaskedFields.ProtoReflect.Descriptor instead.

func (*MaskedFields) GetFieldPatterns

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

func (*MaskedFields) GetHashType

func (x *MaskedFields) GetHashType() string

func (*MaskedFields) GetSeed

func (x *MaskedFields) GetSeed() string

func (*MaskedFields) ProtoMessage

func (*MaskedFields) ProtoMessage()

func (*MaskedFields) ProtoReflect

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

func (*MaskedFields) Reset

func (x *MaskedFields) Reset()

func (*MaskedFields) String

func (x *MaskedFields) String() string

type MaskedFields_PatternList

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

func (*MaskedFields_PatternList) Descriptor deprecated

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

Deprecated: Use MaskedFields_PatternList.ProtoReflect.Descriptor instead.

func (*MaskedFields_PatternList) GetFieldPatterns

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

func (*MaskedFields_PatternList) ProtoMessage

func (*MaskedFields_PatternList) ProtoMessage()

func (*MaskedFields_PatternList) ProtoReflect

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

func (*MaskedFields_PatternList) Reset

func (x *MaskedFields_PatternList) Reset()

func (*MaskedFields_PatternList) String

func (x *MaskedFields_PatternList) String() string

type MicroAggregationBatchJob

type MicroAggregationBatchJob struct {
	Ref             *BatchJobRef          `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	States          []*BatchJobState      `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
	SourceData      *DataConnectorAndType `protobuf:"bytes,3,opt,name=source_data,json=sourceData,proto3" json:"source_data,omitempty"`
	TargetData      *DataConnectorAndType `protobuf:"bytes,4,opt,name=target_data,json=targetData,proto3" json:"target_data,omitempty"`
	DataContractRef *DataContractRef      `protobuf:"bytes,5,opt,name=data_contract_ref,json=dataContractRef,proto3" json:"data_contract_ref,omitempty"`
	// Configuration specifically for the aggregation algorithm.
	AggregationConfig *MicroAggregationConfig `protobuf:"bytes,6,opt,name=aggregation_config,json=aggregationConfig,proto3" json:"aggregation_config,omitempty"`
	// contains filtered or unexported fields
}

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

func (*MicroAggregationBatchJob) Descriptor deprecated

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

Deprecated: Use MicroAggregationBatchJob.ProtoReflect.Descriptor instead.

func (*MicroAggregationBatchJob) GetAggregationConfig

func (x *MicroAggregationBatchJob) GetAggregationConfig() *MicroAggregationConfig

func (*MicroAggregationBatchJob) GetDataContractRef

func (x *MicroAggregationBatchJob) GetDataContractRef() *DataContractRef

func (*MicroAggregationBatchJob) GetRef

func (*MicroAggregationBatchJob) GetSourceData

func (x *MicroAggregationBatchJob) GetSourceData() *DataConnectorAndType

func (*MicroAggregationBatchJob) GetStates

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

func (*MicroAggregationBatchJob) GetTargetData

func (x *MicroAggregationBatchJob) GetTargetData() *DataConnectorAndType

func (*MicroAggregationBatchJob) ProtoMessage

func (*MicroAggregationBatchJob) ProtoMessage()

func (*MicroAggregationBatchJob) ProtoReflect

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

func (*MicroAggregationBatchJob) Reset

func (x *MicroAggregationBatchJob) Reset()

func (*MicroAggregationBatchJob) String

func (x *MicroAggregationBatchJob) String() string

type MicroAggregationConfig

type MicroAggregationConfig struct {

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

func (*MicroAggregationConfig) Descriptor deprecated

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

Deprecated: Use MicroAggregationConfig.ProtoReflect.Descriptor instead.

func (*MicroAggregationConfig) GetAggregationFields

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

func (*MicroAggregationConfig) GetMinimumKAnonymity

func (x *MicroAggregationConfig) GetMinimumKAnonymity() int32

func (*MicroAggregationConfig) ProtoMessage

func (*MicroAggregationConfig) ProtoMessage()

func (*MicroAggregationConfig) ProtoReflect

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

func (*MicroAggregationConfig) Reset

func (x *MicroAggregationConfig) Reset()

func (*MicroAggregationConfig) String

func (x *MicroAggregationConfig) String() string

type Policy

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

func (*Policy) Descriptor deprecated

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

Deprecated: Use Policy.ProtoReflect.Descriptor instead.

func (*Policy) GetDescription

func (x *Policy) GetDescription() string

func (*Policy) GetId

func (x *Policy) GetId() string

func (*Policy) GetLegalGrounds

func (x *Policy) GetLegalGrounds() string

func (*Policy) GetName

func (x *Policy) GetName() string

func (*Policy) GetRetentionDays

func (x *Policy) GetRetentionDays() int32

func (*Policy) GetState

func (x *Policy) GetState() Policy_State

func (*Policy) ProtoMessage

func (*Policy) ProtoMessage()

func (*Policy) ProtoReflect

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

func (*Policy) Reset

func (x *Policy) Reset()

func (*Policy) String

func (x *Policy) String() string

type Policy_State

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

func (Policy_State) Descriptor

func (Policy_State) Enum

func (x Policy_State) Enum() *Policy_State

func (Policy_State) EnumDescriptor deprecated

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

Deprecated: Use Policy_State.Descriptor instead.

func (Policy_State) Number

func (Policy_State) String

func (x Policy_State) String() string

func (Policy_State) Type

type Project

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

func (*Project) Descriptor deprecated

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

Deprecated: Use Project.ProtoReflect.Descriptor instead.

func (*Project) GetDescription

func (x *Project) GetDescription() string

func (*Project) GetId

func (x *Project) GetId() string

func (*Project) GetName

func (x *Project) GetName() string

func (*Project) GetOrganizationId

func (x *Project) GetOrganizationId() string

func (*Project) GetState

func (x *Project) GetState() Project_State

func (*Project) ProtoMessage

func (*Project) ProtoMessage()

func (*Project) ProtoReflect

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

func (*Project) Reset

func (x *Project) Reset()

func (*Project) String

func (x *Project) String() string

type Project_State

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

func (Project_State) Descriptor

func (Project_State) Enum

func (x Project_State) Enum() *Project_State

func (Project_State) EnumDescriptor deprecated

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

Deprecated: Use Project_State.Descriptor instead.

func (Project_State) Number

func (Project_State) String

func (x Project_State) String() string

func (Project_State) Type

type PurposeMapping

type PurposeMapping struct {

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

func (*PurposeMapping) Descriptor deprecated

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

Deprecated: Use PurposeMapping.ProtoReflect.Descriptor instead.

func (*PurposeMapping) GetDescription

func (x *PurposeMapping) GetDescription() string

func (*PurposeMapping) GetLevel

func (x *PurposeMapping) GetLevel() int32

func (*PurposeMapping) GetPurpose

func (x *PurposeMapping) GetPurpose() string

func (*PurposeMapping) ProtoMessage

func (*PurposeMapping) ProtoMessage()

func (*PurposeMapping) ProtoReflect

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

func (*PurposeMapping) Reset

func (x *PurposeMapping) Reset()

func (*PurposeMapping) String

func (x *PurposeMapping) String() string

type Schema

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

func (*Schema) Descriptor deprecated

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetDefinition

func (x *Schema) GetDefinition() string

func (*Schema) GetFingerprint

func (x *Schema) GetFingerprint() string

func (*Schema) GetId

func (x *Schema) GetId() string

func (*Schema) GetIsPublic

func (x *Schema) GetIsPublic() bool

func (*Schema) GetMetadata

func (x *Schema) GetMetadata() *SchemaMetadata

func (*Schema) GetRef

func (x *Schema) GetRef() *SchemaRef

func (*Schema) GetSimpleSchema

func (x *Schema) GetSimpleSchema() *Schema_SimpleSchemaDefinition

func (*Schema) GetState

func (x *Schema) GetState() Schema_State

func (*Schema) ProtoMessage

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect

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

func (*Schema) Reset

func (x *Schema) Reset()

func (*Schema) String

func (x *Schema) String() string

type SchemaMetadata

type SchemaMetadata struct {

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

func (*SchemaMetadata) Descriptor deprecated

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

Deprecated: Use SchemaMetadata.ProtoReflect.Descriptor instead.

func (*SchemaMetadata) GetCreateTime

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

func (*SchemaMetadata) GetDescription

func (x *SchemaMetadata) GetDescription() string

func (*SchemaMetadata) GetDomains

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

func (*SchemaMetadata) GetIconUri

func (x *SchemaMetadata) GetIconUri() string

func (*SchemaMetadata) GetIndustries

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

func (*SchemaMetadata) GetLabels

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

func (*SchemaMetadata) GetTitle

func (x *SchemaMetadata) GetTitle() string

func (*SchemaMetadata) ProtoMessage

func (*SchemaMetadata) ProtoMessage()

func (*SchemaMetadata) ProtoReflect

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

func (*SchemaMetadata) Reset

func (x *SchemaMetadata) Reset()

func (*SchemaMetadata) String

func (x *SchemaMetadata) String() string

type SchemaRef

type SchemaRef struct {

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

func (*SchemaRef) Descriptor deprecated

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

Deprecated: Use SchemaRef.ProtoReflect.Descriptor instead.

func (*SchemaRef) GetHandle

func (x *SchemaRef) GetHandle() string

func (*SchemaRef) GetName

func (x *SchemaRef) GetName() string

func (*SchemaRef) GetSchemaType

func (x *SchemaRef) GetSchemaType() SchemaType

func (*SchemaRef) GetVersion

func (x *SchemaRef) GetVersion() string

func (*SchemaRef) ProtoMessage

func (*SchemaRef) ProtoMessage()

func (*SchemaRef) ProtoReflect

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

func (*SchemaRef) Reset

func (x *SchemaRef) Reset()

func (*SchemaRef) String

func (x *SchemaRef) String() string

type SchemaType

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

func (SchemaType) Descriptor

func (SchemaType) Descriptor() protoreflect.EnumDescriptor

func (SchemaType) Enum

func (x SchemaType) Enum() *SchemaType

func (SchemaType) EnumDescriptor deprecated

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

Deprecated: Use SchemaType.Descriptor instead.

func (SchemaType) Number

func (x SchemaType) Number() protoreflect.EnumNumber

func (SchemaType) String

func (x SchemaType) String() string

func (SchemaType) Type

type Schema_SimpleSchemaDefinition

type Schema_SimpleSchemaDefinition struct {

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

constraints: overall size < 100000 TBD

func (*Schema_SimpleSchemaDefinition) Descriptor deprecated

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

Deprecated: Use Schema_SimpleSchemaDefinition.ProtoReflect.Descriptor instead.

func (*Schema_SimpleSchemaDefinition) GetAvroName

func (x *Schema_SimpleSchemaDefinition) GetAvroName() string

func (*Schema_SimpleSchemaDefinition) GetDoc

func (*Schema_SimpleSchemaDefinition) GetName

func (*Schema_SimpleSchemaDefinition) GetNamespace

func (x *Schema_SimpleSchemaDefinition) GetNamespace() string

func (*Schema_SimpleSchemaDefinition) GetNodes

func (*Schema_SimpleSchemaDefinition) ProtoMessage

func (*Schema_SimpleSchemaDefinition) ProtoMessage()

func (*Schema_SimpleSchemaDefinition) ProtoReflect

func (*Schema_SimpleSchemaDefinition) Reset

func (x *Schema_SimpleSchemaDefinition) Reset()

func (*Schema_SimpleSchemaDefinition) String

type Schema_State

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

func (Schema_State) Descriptor

func (Schema_State) Enum

func (x Schema_State) Enum() *Schema_State

func (Schema_State) EnumDescriptor deprecated

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

Deprecated: Use Schema_State.Descriptor instead.

func (Schema_State) Number

func (Schema_State) String

func (x Schema_State) String() string

func (Schema_State) Type

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

func (x *SimpleSchemaNode) GetAvroName() string

func (*SimpleSchemaNode) GetDoc

func (x *SimpleSchemaNode) GetDoc() string

func (*SimpleSchemaNode) GetName

func (x *SimpleSchemaNode) GetName() string

func (*SimpleSchemaNode) GetNodes

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

func (*SimpleSchemaNode) GetRepeated

func (x *SimpleSchemaNode) GetRepeated() bool

func (*SimpleSchemaNode) GetRequired

func (x *SimpleSchemaNode) GetRequired() bool

func (*SimpleSchemaNode) GetType

func (*SimpleSchemaNode) ProtoMessage

func (*SimpleSchemaNode) ProtoMessage()

func (*SimpleSchemaNode) ProtoReflect

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

func (*SimpleSchemaNode) Reset

func (x *SimpleSchemaNode) Reset()

func (*SimpleSchemaNode) String

func (x *SimpleSchemaNode) String() string

type SimpleSchemaNodeType

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

func (SimpleSchemaNodeType) Descriptor

func (SimpleSchemaNodeType) Enum

func (SimpleSchemaNodeType) EnumDescriptor deprecated

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

Deprecated: Use SimpleSchemaNodeType.Descriptor instead.

func (SimpleSchemaNodeType) Number

func (SimpleSchemaNodeType) String

func (x SimpleSchemaNodeType) String() string

func (SimpleSchemaNodeType) Type

type Sink

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

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

func (*Sink) Descriptor deprecated

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

Deprecated: Use Sink.ProtoReflect.Descriptor instead.

func (*Sink) GetBucket

func (x *Sink) GetBucket() *BucketConfig

func (*Sink) GetConfig

func (m *Sink) GetConfig() isSink_Config

func (*Sink) GetRef

func (x *Sink) GetRef() *SinkRef

func (*Sink) GetSinkType

func (x *Sink) GetSinkType() SinkType

func (*Sink) ProtoMessage

func (*Sink) ProtoMessage()

func (*Sink) ProtoReflect

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

func (*Sink) Reset

func (x *Sink) Reset()

func (*Sink) String

func (x *Sink) String() string

type SinkRef deprecated

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

Deprecated: Do not use.

func (*SinkRef) Descriptor deprecated

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

Deprecated: Use SinkRef.ProtoReflect.Descriptor instead.

func (*SinkRef) GetBillingId

func (x *SinkRef) GetBillingId() string

func (*SinkRef) GetName

func (x *SinkRef) GetName() string

func (*SinkRef) ProtoMessage

func (*SinkRef) ProtoMessage()

func (*SinkRef) ProtoReflect

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

func (*SinkRef) Reset

func (x *SinkRef) Reset()

func (*SinkRef) String

func (x *SinkRef) String() string

type SinkTree deprecated

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

Deprecated: Do not use.

func (*SinkTree) Descriptor deprecated

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

Deprecated: Use SinkTree.ProtoReflect.Descriptor instead.

func (*SinkTree) GetBatchExporters

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

func (*SinkTree) GetSink

func (x *SinkTree) GetSink() *Sink

func (*SinkTree) ProtoMessage

func (*SinkTree) ProtoMessage()

func (*SinkTree) ProtoReflect

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

func (*SinkTree) Reset

func (x *SinkTree) Reset()

func (*SinkTree) String

func (x *SinkTree) String() string

type SinkType deprecated

type SinkType int32

Deprecated: Do not use.

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

func (SinkType) Descriptor

func (SinkType) Descriptor() protoreflect.EnumDescriptor

func (SinkType) Enum

func (x SinkType) Enum() *SinkType

func (SinkType) EnumDescriptor deprecated

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

Deprecated: Use SinkType.Descriptor instead.

func (SinkType) Number

func (x SinkType) Number() protoreflect.EnumNumber

func (SinkType) String

func (x SinkType) String() string

func (SinkType) Type

type Sink_Bucket

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

type StatisticalDataType

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

func (StatisticalDataType) Descriptor

func (StatisticalDataType) Enum

func (StatisticalDataType) EnumDescriptor deprecated

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

Deprecated: Use StatisticalDataType.Descriptor instead.

func (StatisticalDataType) Number

func (StatisticalDataType) String

func (x StatisticalDataType) String() string

func (StatisticalDataType) Type

type Stream

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

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

func (*Stream) Descriptor deprecated

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetConsentLevelType

func (x *Stream) GetConsentLevelType() ConsentLevelType

func (*Stream) GetConsentLevels

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

func (*Stream) GetCredentials

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

func (*Stream) GetDescription

func (x *Stream) GetDescription() string

func (*Stream) GetEnabled

func (x *Stream) GetEnabled() bool

func (*Stream) GetKafkaTopic deprecated

func (x *Stream) GetKafkaTopic() string

Deprecated: Do not use.

func (*Stream) GetLimits

func (x *Stream) GetLimits() *Limits

func (*Stream) GetLinkedStream

func (x *Stream) GetLinkedStream() string

func (*Stream) GetMaskedFields

func (x *Stream) GetMaskedFields() *MaskedFields

func (*Stream) GetPolicyId

func (x *Stream) GetPolicyId() string

func (*Stream) GetRef

func (x *Stream) GetRef() *StreamRef

func (*Stream) GetTags

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

func (*Stream) ProtoMessage

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect

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

func (*Stream) Reset

func (x *Stream) Reset()

func (*Stream) String

func (x *Stream) String() string

type StreamRef

type StreamRef struct {

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

refers to a event stream.

func (*StreamRef) Descriptor deprecated

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

Deprecated: Use StreamRef.ProtoReflect.Descriptor instead.

func (*StreamRef) GetBillingId deprecated

func (x *StreamRef) GetBillingId() string

Deprecated: Do not use.

func (*StreamRef) GetName

func (x *StreamRef) GetName() string

func (*StreamRef) GetProjectId

func (x *StreamRef) GetProjectId() string

func (*StreamRef) ProtoMessage

func (*StreamRef) ProtoMessage()

func (*StreamRef) ProtoReflect

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

func (*StreamRef) Reset

func (x *StreamRef) Reset()

func (*StreamRef) String

func (x *StreamRef) String() string

type StreamTree

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

func (*StreamTree) Descriptor deprecated

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

Deprecated: Use StreamTree.ProtoReflect.Descriptor instead.

func (*StreamTree) GetBatchExporters

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

func (*StreamTree) GetDerived

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

func (*StreamTree) GetKafkaExporters

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

func (*StreamTree) GetKeyStream

func (x *StreamTree) GetKeyStream() *KeyStream

func (*StreamTree) GetStream

func (x *StreamTree) GetStream() *Stream

func (*StreamTree) ProtoMessage

func (*StreamTree) ProtoMessage()

func (*StreamTree) ProtoReflect

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

func (*StreamTree) Reset

func (x *StreamTree) Reset()

func (*StreamTree) String

func (x *StreamTree) String() string

type SubscriptionPlan

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

func (SubscriptionPlan) Descriptor

func (SubscriptionPlan) Enum

func (SubscriptionPlan) EnumDescriptor deprecated

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

Deprecated: Use SubscriptionPlan.Descriptor instead.

func (SubscriptionPlan) Number

func (SubscriptionPlan) String

func (x SubscriptionPlan) String() string

func (SubscriptionPlan) Type

type TimestampConfig

type TimestampConfig struct {

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

func (*TimestampConfig) Descriptor deprecated

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

Deprecated: Use TimestampConfig.ProtoReflect.Descriptor instead.

func (*TimestampConfig) GetDefaultTimeZone

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

func (*TimestampConfig) GetField

func (x *TimestampConfig) GetField() string

func (*TimestampConfig) GetFormat

func (x *TimestampConfig) GetFormat() string

func (*TimestampConfig) ProtoMessage

func (*TimestampConfig) ProtoMessage()

func (*TimestampConfig) ProtoReflect

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

func (*TimestampConfig) Reset

func (x *TimestampConfig) Reset()

func (*TimestampConfig) String

func (x *TimestampConfig) String() string

type User

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

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

aip.dev/not-precedent . --)

func (*User) Descriptor deprecated

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetEmail

func (x *User) GetEmail() string

func (*User) GetExternalUserId

func (x *User) GetExternalUserId() string

func (*User) GetFirstName

func (x *User) GetFirstName() string

func (*User) GetFunctionTitle

func (x *User) GetFunctionTitle() string

func (*User) GetLastName

func (x *User) GetLastName() string

func (*User) GetOrganizationId

func (x *User) GetOrganizationId() string

func (*User) GetUserRoles

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

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) ProtoReflect

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

func (*User) Reset

func (x *User) Reset()

func (*User) String

func (x *User) String() string

type UserRole

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

func (UserRole) Descriptor

func (UserRole) Descriptor() protoreflect.EnumDescriptor

func (UserRole) Enum

func (x UserRole) Enum() *UserRole

func (UserRole) EnumDescriptor deprecated

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

Deprecated: Use UserRole.Descriptor instead.

func (UserRole) Number

func (x UserRole) Number() protoreflect.EnumNumber

func (UserRole) String

func (x UserRole) String() string

func (UserRole) Type

type Validation

type Validation struct {

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

func (*Validation) Descriptor deprecated

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

Deprecated: Use Validation.ProtoReflect.Descriptor instead.

func (*Validation) GetField

func (x *Validation) GetField() string

func (*Validation) GetType

func (x *Validation) GetType() string

func (*Validation) GetValue

func (x *Validation) GetValue() string

func (*Validation) ProtoMessage

func (*Validation) ProtoMessage()

func (*Validation) ProtoReflect

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

func (*Validation) Reset

func (x *Validation) Reset()

func (*Validation) String

func (x *Validation) String() string

type WindowedEventCount

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

func (*WindowedEventCount) Descriptor deprecated

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

Deprecated: Use WindowedEventCount.ProtoReflect.Descriptor instead.

func (*WindowedEventCount) GetEndTime

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

func (*WindowedEventCount) GetEventCount

func (x *WindowedEventCount) GetEventCount() int64

func (*WindowedEventCount) GetStartTime

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

func (*WindowedEventCount) ProtoMessage

func (*WindowedEventCount) ProtoMessage()

func (*WindowedEventCount) ProtoReflect

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

func (*WindowedEventCount) Reset

func (x *WindowedEventCount) Reset()

func (*WindowedEventCount) String

func (x *WindowedEventCount) String() string

Jump to

Keyboard shortcuts

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