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

func (AuditTrailEntry_Action) Enum added in v3.13.0 

func (x AuditTrailEntry_Action) Enum() *AuditTrailEntry_Action

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

func (AuditTrailEntry_Action) String added in v3.13.0 

func (x AuditTrailEntry_Action) String() string

func (AuditTrailEntry_Action) Type added in v3.13.0 

func (AuditTrailEntry_Action) Type() protoreflect.EnumType

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

func (AuditTrailEntry_Category) Enum added in v3.13.0 

func (x AuditTrailEntry_Category) Enum() *AuditTrailEntry_Category

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

func (AuditTrailEntry_Category) String added in v3.13.0 

func (x AuditTrailEntry_Category) String() string

func (AuditTrailEntry_Category) Type added in v3.13.0 

func (AuditTrailEntry_Category) Type() protoreflect.EnumType

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 (x *AuditTrailEntry_Details) GetExperimental() *AuditTrailEntry_Details_Experimental

func (*AuditTrailEntry_Details) GetProjectMemberChange added in v3.13.0 

func (x *AuditTrailEntry_Details) GetProjectMemberChange() *AuditTrailEntry_Details_ProjectMemberChange

func (*AuditTrailEntry_Details) GetProjectPlanDiffs added in v3.13.0 

func (x *AuditTrailEntry_Details) GetProjectPlanDiffs() *AuditTrailEntry_Details_ProjectPlanDiffs

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 (x *AuditTrailEntry_Details_Experimental) GetContent() string

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

func (*AuditTrailEntry_Details_Experimental) Reset added in v3.13.0 

func (x *AuditTrailEntry_Details_Experimental) Reset()

func (*AuditTrailEntry_Details_Experimental) String added in v3.13.0 

func (x *AuditTrailEntry_Details_Experimental) String() string

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 

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

Deprecated: Use AuditTrailEntry_Details_ProjectMemberChange.ProtoReflect.Descriptor instead.

func (*AuditTrailEntry_Details_ProjectMemberChange) GetChangeType added in v3.13.0 

func (x *AuditTrailEntry_Details_ProjectMemberChange) GetChangeType() AuditTrailEntry_Details_ProjectMemberChange_ChangeType

func (*AuditTrailEntry_Details_ProjectMemberChange) GetUser added in v3.13.0 

func (x *AuditTrailEntry_Details_ProjectMemberChange) GetUser() *User

func (*AuditTrailEntry_Details_ProjectMemberChange) ProtoMessage added in v3.13.0 

func (*AuditTrailEntry_Details_ProjectMemberChange) ProtoMessage()

func (*AuditTrailEntry_Details_ProjectMemberChange) ProtoReflect added in v3.13.0 

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

func (*AuditTrailEntry_Details_ProjectMemberChange) Reset added in v3.13.0 

func (x *AuditTrailEntry_Details_ProjectMemberChange) Reset()

func (*AuditTrailEntry_Details_ProjectMemberChange) String added in v3.13.0 

func (x *AuditTrailEntry_Details_ProjectMemberChange) String() string

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

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) Enum added in v3.13.0 

func (x AuditTrailEntry_Details_ProjectMemberChange_ChangeType) Enum() *AuditTrailEntry_Details_ProjectMemberChange_ChangeType

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) EnumDescriptor deprecated added in v3.13.0 

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

Deprecated: Use AuditTrailEntry_Details_ProjectMemberChange_ChangeType.Descriptor instead.

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) Number added in v3.13.0 

func (x AuditTrailEntry_Details_ProjectMemberChange_ChangeType) Number() protoreflect.EnumNumber

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) String added in v3.13.0 

func (x AuditTrailEntry_Details_ProjectMemberChange_ChangeType) String() string

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) Type added in v3.13.0 

func (AuditTrailEntry_Details_ProjectMemberChange_ChangeType) Type() protoreflect.EnumType

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 (x *AuditTrailEntry_Details_ProjectPlanDiffs) GetDiffs() []*Diff

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) ProtoMessage()

func (*AuditTrailEntry_Details_ProjectPlanDiffs) ProtoReflect added in v3.13.0 

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

func (*AuditTrailEntry_Details_ProjectPlanDiffs) Reset added in v3.13.0 

func (x *AuditTrailEntry_Details_ProjectPlanDiffs) Reset()

func (*AuditTrailEntry_Details_ProjectPlanDiffs) String added in v3.13.0 

func (x *AuditTrailEntry_Details_ProjectPlanDiffs) String() string

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

func (AuthMechanism) Enum 

func (x AuthMechanism) Enum() *AuthMechanism

func (AuthMechanism) EnumDescriptor deprecated 

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

Deprecated: Use AuthMechanism.Descriptor instead.

func (AuthMechanism) Number 

func (x AuthMechanism) Number() protoreflect.EnumNumber

func (AuthMechanism) String 

func (x AuthMechanism) String() string

func (AuthMechanism) Type 

func (AuthMechanism) Type() protoreflect.EnumType

type AwsS3BucketLocation 

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

func (*AzureBlobStorageContainerLocation) Reset 

func (x *AzureBlobStorageContainerLocation) Reset()

func (*AzureBlobStorageContainerLocation) String 

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

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

func (BatchJobStateType) Enum 

func (x BatchJobStateType) Enum() *BatchJobStateType

func (BatchJobStateType) EnumDescriptor deprecated 

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

Deprecated: Use BatchJobStateType.Descriptor instead.

func (BatchJobStateType) Number 

func (x BatchJobStateType) Number() protoreflect.EnumNumber

func (BatchJobStateType) String 

func (x BatchJobStateType) String() string

func (BatchJobStateType) Type 

func (BatchJobStateType) Type() protoreflect.EnumType

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

func (*ConsentLevelMapping) ProtoMessage 

func (*ConsentLevelMapping) ProtoMessage()

func (*ConsentLevelMapping) ProtoReflect 

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

func (*ConsentLevelMapping) Reset 

func (x *ConsentLevelMapping) Reset()

func (*ConsentLevelMapping) String 

func (x *ConsentLevelMapping) String() string

type ConsentLevelMappingRef 

type ConsentLevelMappingRef struct {

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

func (*ConsentLevelMappingRef) Descriptor deprecated 

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

Deprecated: Use ConsentLevelMappingRef.ProtoReflect.Descriptor instead.

func (*ConsentLevelMappingRef) GetBillingId deprecated 

func (x *ConsentLevelMappingRef) GetBillingId() string

Deprecated: Do not use.

func (*ConsentLevelMappingRef) GetLevel 

func (x *ConsentLevelMappingRef) GetLevel() int32

func (*ConsentLevelMappingRef) GetProjectId 

func (x *ConsentLevelMappingRef) GetProjectId() string

func (*ConsentLevelMappingRef) ProtoMessage 

func (*ConsentLevelMappingRef) ProtoMessage()

func (*ConsentLevelMappingRef) ProtoReflect 

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

func (*ConsentLevelMappingRef) Reset 

func (x *ConsentLevelMappingRef) Reset()

func (*ConsentLevelMappingRef) String 

func (x *ConsentLevelMappingRef) String() string

type ConsentLevelType 

type ConsentLevelType int32

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

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

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

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

func (ConsentLevelType) Descriptor 

func (ConsentLevelType) Descriptor() protoreflect.EnumDescriptor

func (ConsentLevelType) Enum 

func (x ConsentLevelType) Enum() *ConsentLevelType

func (ConsentLevelType) EnumDescriptor deprecated 

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

Deprecated: Use ConsentLevelType.Descriptor instead.

func (ConsentLevelType) Number 

func (x ConsentLevelType) Number() protoreflect.EnumNumber

func (ConsentLevelType) String 

func (x ConsentLevelType) String() string

func (ConsentLevelType) Type 

func (ConsentLevelType) Type() protoreflect.EnumType

type ConsentLevels 

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

func (*DataConnectorDependentEntities) Reset 

func (x *DataConnectorDependentEntities) Reset()

func (*DataConnectorDependentEntities) String 

func (x *DataConnectorDependentEntities) String() 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) Descriptor() protoreflect.EnumDescriptor

func (DataContract_State) Enum 

func (x DataContract_State) Enum() *DataContract_State

func (DataContract_State) EnumDescriptor deprecated 

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

Deprecated: Use DataContract_State.Descriptor instead.

func (DataContract_State) Number 

func (x DataContract_State) Number() protoreflect.EnumNumber

func (DataContract_State) String 

func (x DataContract_State) String() string

func (DataContract_State) Type 

func (DataContract_State) Type() protoreflect.EnumType

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

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

func (DatabaseType) String 

func (x DatabaseType) String() string

func (DatabaseType) Type 

func (DatabaseType) Type() protoreflect.EnumType

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

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

func (Diff_DiffType) String added in v3.13.0 

func (x Diff_DiffType) String() string

func (Diff_DiffType) Type added in v3.13.0 

func (Diff_DiffType) Type() protoreflect.EnumType

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

func (EventContract_State) Enum 

func (x EventContract_State) Enum() *EventContract_State

func (EventContract_State) EnumDescriptor deprecated 

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

Deprecated: Use EventContract_State.Descriptor instead.

func (EventContract_State) Number 

func (x EventContract_State) Number() protoreflect.EnumNumber

func (EventContract_State) String 

func (x EventContract_State) String() string

func (EventContract_State) Type 

func (EventContract_State) Type() protoreflect.EnumType

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 (x *FieldMetadata_NullHandlingConfig) GetType() FieldMetadata_NullHandlingConfig_NullHandlingType

func (*FieldMetadata_NullHandlingConfig) ProtoMessage 

func (*FieldMetadata_NullHandlingConfig) ProtoMessage()

func (*FieldMetadata_NullHandlingConfig) ProtoReflect 

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

func (*FieldMetadata_NullHandlingConfig) Reset 

func (x *FieldMetadata_NullHandlingConfig) Reset()

func (*FieldMetadata_NullHandlingConfig) String 

func (x *FieldMetadata_NullHandlingConfig) String() 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) Descriptor() protoreflect.EnumDescriptor

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Enum 

func (x FieldMetadata_NullHandlingConfig_NullHandlingType) Enum() *FieldMetadata_NullHandlingConfig_NullHandlingType

func (FieldMetadata_NullHandlingConfig_NullHandlingType) EnumDescriptor deprecated 

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

Deprecated: Use FieldMetadata_NullHandlingConfig_NullHandlingType.Descriptor instead.

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Number 

func (x FieldMetadata_NullHandlingConfig_NullHandlingType) Number() protoreflect.EnumNumber

func (FieldMetadata_NullHandlingConfig_NullHandlingType) String 

func (x FieldMetadata_NullHandlingConfig_NullHandlingType) String() string

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Type 

func (FieldMetadata_NullHandlingConfig_NullHandlingType) Type() protoreflect.EnumType

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

func (*FieldMetadata_PersonalDataConfig) Reset 

func (x *FieldMetadata_PersonalDataConfig) Reset()

func (*FieldMetadata_PersonalDataConfig) String 

func (x *FieldMetadata_PersonalDataConfig) String() string

type FilterPublicPrivate 

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

func (FilterPublicPrivate) Descriptor 

func (FilterPublicPrivate) Descriptor() protoreflect.EnumDescriptor

func (FilterPublicPrivate) Enum 

func (x FilterPublicPrivate) Enum() *FilterPublicPrivate

func (FilterPublicPrivate) EnumDescriptor deprecated 

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

Deprecated: Use FilterPublicPrivate.Descriptor instead.

func (FilterPublicPrivate) Number 

func (x FilterPublicPrivate) Number() protoreflect.EnumNumber

func (FilterPublicPrivate) String 

func (x FilterPublicPrivate) String() string

func (FilterPublicPrivate) Type 

func (FilterPublicPrivate) Type() protoreflect.EnumType

type 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 (x *GenericRef) GetType() GenericRef_GenericRefType

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

func (GenericRef_GenericRefType) Enum 

func (x GenericRef_GenericRefType) Enum() *GenericRef_GenericRefType

func (GenericRef_GenericRefType) EnumDescriptor deprecated 

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

Deprecated: Use GenericRef_GenericRefType.Descriptor instead.

func (GenericRef_GenericRefType) Number 

func (x GenericRef_GenericRefType) Number() protoreflect.EnumNumber

func (GenericRef_GenericRefType) String 

func (x GenericRef_GenericRefType) String() string

func (GenericRef_GenericRefType) Type 

func (GenericRef_GenericRefType) Type() protoreflect.EnumType

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

func (*GoogleCloudStorageBucketLocation) Reset 

func (x *GoogleCloudStorageBucketLocation) Reset()

func (*GoogleCloudStorageBucketLocation) String 

func (x *GoogleCloudStorageBucketLocation) String() 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 (x *MicroAggregationBatchJob) GetRef() *BatchJobRef

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

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

func (Policy_State) String 

func (x Policy_State) String() string

func (Policy_State) Type 

func (Policy_State) Type() protoreflect.EnumType

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

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

func (Project_State) String 

func (x Project_State) String() string

func (Project_State) Type 

func (Project_State) Type() protoreflect.EnumType

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 

func (SchemaType) Type() protoreflect.EnumType

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 (x *Schema_SimpleSchemaDefinition) GetDoc() string

func (*Schema_SimpleSchemaDefinition) GetName 

func (x *Schema_SimpleSchemaDefinition) GetName() string

func (*Schema_SimpleSchemaDefinition) GetNamespace 

func (x *Schema_SimpleSchemaDefinition) GetNamespace() string

func (*Schema_SimpleSchemaDefinition) GetNodes 

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

func (*Schema_SimpleSchemaDefinition) ProtoMessage 

func (*Schema_SimpleSchemaDefinition) ProtoMessage()

func (*Schema_SimpleSchemaDefinition) ProtoReflect 

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

func (*Schema_SimpleSchemaDefinition) Reset 

func (x *Schema_SimpleSchemaDefinition) Reset()

func (*Schema_SimpleSchemaDefinition) String 

func (x *Schema_SimpleSchemaDefinition) String() string

type Schema_State 

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

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

func (Schema_State) String 

func (x Schema_State) String() string

func (Schema_State) Type 

func (Schema_State) Type() protoreflect.EnumType

type SimpleSchemaNode 

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

func (*SimpleSchemaNode) Descriptor deprecated 

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

Deprecated: Use SimpleSchemaNode.ProtoReflect.Descriptor instead.

func (*SimpleSchemaNode) GetAvroName 

func (x *SimpleSchemaNode) GetAvroName() string

func (*SimpleSchemaNode) GetDoc 

func (x *SimpleSchemaNode) GetDoc() string

func (*SimpleSchemaNode) GetName 

func (x *SimpleSchemaNode) GetName() string

func (*SimpleSchemaNode) GetNodes 

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

func (*SimpleSchemaNode) GetRepeated 

func (x *SimpleSchemaNode) GetRepeated() bool

func (*SimpleSchemaNode) GetRequired 

func (x *SimpleSchemaNode) GetRequired() bool

func (*SimpleSchemaNode) GetType 

func (x *SimpleSchemaNode) GetType() SimpleSchemaNodeType

func (*SimpleSchemaNode) ProtoMessage 

func (*SimpleSchemaNode) ProtoMessage()

func (*SimpleSchemaNode) ProtoReflect 

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

func (*SimpleSchemaNode) Reset 

func (x *SimpleSchemaNode) Reset()

func (*SimpleSchemaNode) String 

func (x *SimpleSchemaNode) String() string

type SimpleSchemaNodeType 

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

func (SimpleSchemaNodeType) Descriptor 

func (SimpleSchemaNodeType) Descriptor() protoreflect.EnumDescriptor

func (SimpleSchemaNodeType) Enum 

func (x SimpleSchemaNodeType) Enum() *SimpleSchemaNodeType

func (SimpleSchemaNodeType) EnumDescriptor deprecated 

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

Deprecated: Use SimpleSchemaNodeType.Descriptor instead.

func (SimpleSchemaNodeType) Number 

func (x SimpleSchemaNodeType) Number() protoreflect.EnumNumber

func (SimpleSchemaNodeType) String 

func (x SimpleSchemaNodeType) String() string

func (SimpleSchemaNodeType) Type 

func (SimpleSchemaNodeType) Type() protoreflect.EnumType

type Sink 

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

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

func (*Sink) Descriptor deprecated 

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

Deprecated: Use Sink.ProtoReflect.Descriptor instead.

func (*Sink) GetBucket 

func (x *Sink) GetBucket() *BucketConfig

func (*Sink) GetConfig 

func (m *Sink) GetConfig() isSink_Config

func (*Sink) GetRef 

func (x *Sink) GetRef() *SinkRef

func (*Sink) GetSinkType 

func (x *Sink) GetSinkType() SinkType

func (*Sink) ProtoMessage 

func (*Sink) ProtoMessage()

func (*Sink) ProtoReflect 

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

func (*Sink) Reset 

func (x *Sink) Reset()

func (*Sink) String 

func (x *Sink) String() string

type SinkRef deprecated 

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

Deprecated: Do not use.

func (*SinkRef) Descriptor deprecated 

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

Deprecated: Use SinkRef.ProtoReflect.Descriptor instead.

func (*SinkRef) GetBillingId 

func (x *SinkRef) GetBillingId() string

func (*SinkRef) GetName 

func (x *SinkRef) GetName() string

func (*SinkRef) ProtoMessage 

func (*SinkRef) ProtoMessage()

func (*SinkRef) ProtoReflect 

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

func (*SinkRef) Reset 

func (x *SinkRef) Reset()

func (*SinkRef) String 

func (x *SinkRef) String() string

type SinkTree deprecated 

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

Deprecated: Do not use.

func (*SinkTree) Descriptor deprecated 

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

Deprecated: Use SinkTree.ProtoReflect.Descriptor instead.

func (*SinkTree) GetBatchExporters 

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

func (*SinkTree) GetSink 

func (x *SinkTree) GetSink() *Sink

func (*SinkTree) ProtoMessage 

func (*SinkTree) ProtoMessage()

func (*SinkTree) ProtoReflect 

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

func (*SinkTree) Reset 

func (x *SinkTree) Reset()

func (*SinkTree) String 

func (x *SinkTree) String() string

type SinkType deprecated 

type SinkType int32

Deprecated: Do not use. 

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

func (SinkType) Descriptor 

func (SinkType) Descriptor() protoreflect.EnumDescriptor

func (SinkType) Enum 

func (x SinkType) Enum() *SinkType

func (SinkType) EnumDescriptor deprecated 

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

Deprecated: Use SinkType.Descriptor instead.

func (SinkType) Number 

func (x SinkType) Number() protoreflect.EnumNumber

func (SinkType) String 

func (x SinkType) String() string

func (SinkType) Type 

func (SinkType) Type() protoreflect.EnumType

type Sink_Bucket 

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

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

func (StatisticalDataType) Enum 

func (x StatisticalDataType) Enum() *StatisticalDataType

func (StatisticalDataType) EnumDescriptor deprecated 

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

Deprecated: Use StatisticalDataType.Descriptor instead.

func (StatisticalDataType) Number 

func (x StatisticalDataType) Number() protoreflect.EnumNumber

func (StatisticalDataType) String 

func (x StatisticalDataType) String() string

func (StatisticalDataType) Type 

func (StatisticalDataType) Type() protoreflect.EnumType

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

func (SubscriptionPlan) Enum 

func (x SubscriptionPlan) Enum() *SubscriptionPlan

func (SubscriptionPlan) EnumDescriptor deprecated 

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

Deprecated: Use SubscriptionPlan.Descriptor instead.

func (SubscriptionPlan) Number 

func (x SubscriptionPlan) Number() protoreflect.EnumNumber

func (SubscriptionPlan) String 

func (x SubscriptionPlan) String() string

func (SubscriptionPlan) Type 

func (SubscriptionPlan) Type() protoreflect.EnumType

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 

func (UserRole) Type() protoreflect.EnumType

type Validation 

type Validation struct {

	// constraint: valid field path, follows avro constraints + slashes
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// constraint: one of the validator types. handled by code
	// 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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