data_catalog

type CreateDataCatalogConnectionRequest struct {
	DataCatalog *DataCatalog `protobuf:"bytes,1,opt,name=data_catalog,json=dataCatalog,proto3" json:"data_catalog,omitempty"`
	// contains filtered or unexported fields
}

type CreateDataCatalogConnectionResponse struct {
	// contains filtered or unexported fields
}

type CreateDatasetContentsConnectionRequest struct {
	DatasetContentsConnection *DatasetContentsConnection `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CreateDatasetContentsConnectionResponse struct {
	// contains filtered or unexported fields
}

type Credentials struct {

	// urn uniquely identifies this entity within DCET
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// Types that are assignable to Authentication:
	//
	//	*Credentials_Unauthenticated_
	//	*Credentials_Basic_
	//	*Credentials_Bearer_
	Authentication isCredentials_Authentication `protobuf_oneof:"authentication"`
	// contains filtered or unexported fields
}

type Credentials_Basic struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

type Credentials_Basic_ struct {
	Basic *Credentials_Basic `protobuf:"bytes,3,opt,name=basic,proto3,oneof"`
}

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

type Credentials_Bearer_ struct {
	Bearer *Credentials_Bearer `protobuf:"bytes,4,opt,name=bearer,proto3,oneof"`
}

type Credentials_Unauthenticated struct {
	// contains filtered or unexported fields
}

type Credentials_Unauthenticated_ struct {
	Unauthenticated *Credentials_Unauthenticated `protobuf:"bytes,2,opt,name=unauthenticated,proto3,oneof"`
}

type DataCatalog struct {
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// urn uniquely identifies this platform within DCET
	Urn string `protobuf:"bytes,3,opt,name=urn,proto3" json:"urn,omitempty"`
	// Types that are assignable to Connection:
	//
	//	*DataCatalog_DatahubConnection
	//	*DataCatalog_OddConnection
	Connection isDataCatalog_Connection `protobuf_oneof:"connection"`
	// contains filtered or unexported fields
}

type DataCatalogServiceClient interface {
	GetDataCatalogConnection(ctx context.Context, in *GetDataCatalogConnectionRequest, opts ...grpc.CallOption) (*GetDataCatalogConnectionResponse, error)
	ListDataCatalogConnections(ctx context.Context, in *ListDataCatalogConnectionsRequest, opts ...grpc.CallOption) (*ListDataCatalogConnectionsResponse, error)
	CreateDataCatalogConnection(ctx context.Context, in *CreateDataCatalogConnectionRequest, opts ...grpc.CallOption) (*CreateDataCatalogConnectionResponse, error)
}

type DataCatalogServiceServer interface {
	GetDataCatalogConnection(context.Context, *GetDataCatalogConnectionRequest) (*GetDataCatalogConnectionResponse, error)
	ListDataCatalogConnections(context.Context, *ListDataCatalogConnectionsRequest) (*ListDataCatalogConnectionsResponse, error)
	CreateDataCatalogConnection(context.Context, *CreateDataCatalogConnectionRequest) (*CreateDataCatalogConnectionResponse, error)
}

type DataCatalog_DatahubConnection struct {
	DatahubConnection *DatahubConnection `protobuf:"bytes,4,opt,name=datahub_connection,json=datahubConnection,proto3,oneof"`
}

type DataCatalog_OddConnection struct {
	OddConnection *OpenDataDiscoveryConnection `protobuf:"bytes,5,opt,name=odd_connection,json=oddConnection,proto3,oneof"`
}

type DataPlatform struct {

	// urn uniquely identifies this platform within DCET
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// type is for instance Postgres, Kafka, CSV file, Databricks.
	Type DataPlatformType `protobuf:"varint,2,opt,name=type,proto3,enum=strmprivacy.api.data_catalog.v1.DataPlatformType" json:"type,omitempty"`
	// instance separates different instances. Postgres server 1, 2, ...
	Instance string `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
	// uri to find logo material
	LogoUri string `protobuf:"bytes,4,opt,name=logo_uri,json=logoUri,proto3" json:"logo_uri,omitempty"`
	// urn used on the data platform
	OriginUrn string `protobuf:"bytes,5,opt,name=origin_urn,json=originUrn,proto3" json:"origin_urn,omitempty"`
	// contains filtered or unexported fields
}

type DataPlatformType int32

type DatahubConnection struct {
	Credentials *Credentials `protobuf:"bytes,1,opt,name=credentials,proto3" json:"credentials,omitempty"`
	Uri         string       `protobuf:"bytes,4,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

type Dataset struct {

	// data catalog + urn to individual table/dataset (<database>.<database_schema>.<table>)
	// urn = data_catalog_urn + origin_urn
	Urn            string            `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	DataCatalogUrn string            `protobuf:"bytes,2,opt,name=data_catalog_urn,json=dataCatalogUrn,proto3" json:"data_catalog_urn,omitempty"`
	OriginUrn      string            `protobuf:"bytes,3,opt,name=origin_urn,json=originUrn,proto3" json:"origin_urn,omitempty"`
	DisplayName    string            `protobuf:"bytes,4,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	Schema         *Schema           `protobuf:"bytes,5,opt,name=schema,proto3" json:"schema,omitempty"`
	Tags           []*Tag            `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
	Relations      []*Relation       `protobuf:"bytes,7,rep,name=relations,proto3" json:"relations,omitempty"`
	Owners         []*Owner          `protobuf:"bytes,8,rep,name=owners,proto3" json:"owners,omitempty"`
	Properties     map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DatasetContentsConnection struct {
	DatasetUrn string `protobuf:"bytes,1,opt,name=dataset_urn,json=datasetUrn,proto3" json:"dataset_urn,omitempty"`
	// Types that are assignable to ConnectionConfig:
	//
	//	*DatasetContentsConnection_S3Bucket
	//	*DatasetContentsConnection_GoogleCloudStorageBucket
	//	*DatasetContentsConnection_AzureBlobStorageContainer
	//	*DatasetContentsConnection_JdbcLocation
	ConnectionConfig isDatasetContentsConnection_ConnectionConfig `protobuf_oneof:"connection_config"`
	// contains filtered or unexported fields
}

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

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

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

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

type DatasetsServiceClient interface {
	GetDataset(ctx context.Context, in *GetDatasetRequest, opts ...grpc.CallOption) (*GetDatasetResponse, error)
	GetDatasetSample(ctx context.Context, in *GetDatasetSampleRequest, opts ...grpc.CallOption) (*GetDatasetSampleResponse, error)
	GetDatasetMetrics(ctx context.Context, in *GetDatasetMetricsRequest, opts ...grpc.CallOption) (*GetDatasetMetricsResponse, error)
	ListDatasets(ctx context.Context, in *ListDatasetsRequest, opts ...grpc.CallOption) (*ListDatasetsResponse, error)
	UpdateDatasetTags(ctx context.Context, in *UpdateDatasetTagsRequest, opts ...grpc.CallOption) (*UpdateDatasetTagsResponse, error)
	UpdateSchemaFieldTags(ctx context.Context, in *UpdateSchemaFieldTagsRequest, opts ...grpc.CallOption) (*UpdateSchemaFieldTagsResponse, error)
	CreateDatasetContentsConnection(ctx context.Context, in *CreateDatasetContentsConnectionRequest, opts ...grpc.CallOption) (*CreateDatasetContentsConnectionResponse, error)
}

type DatasetsServiceServer interface {
	GetDataset(context.Context, *GetDatasetRequest) (*GetDatasetResponse, error)
	GetDatasetSample(context.Context, *GetDatasetSampleRequest) (*GetDatasetSampleResponse, error)
	GetDatasetMetrics(context.Context, *GetDatasetMetricsRequest) (*GetDatasetMetricsResponse, error)
	ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, error)
	UpdateDatasetTags(context.Context, *UpdateDatasetTagsRequest) (*UpdateDatasetTagsResponse, error)
	UpdateSchemaFieldTags(context.Context, *UpdateSchemaFieldTagsRequest) (*UpdateSchemaFieldTagsResponse, error)
	CreateDatasetContentsConnection(context.Context, *CreateDatasetContentsConnectionRequest) (*CreateDatasetContentsConnectionResponse, error)
}

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

type GetDataCatalogConnectionResponse struct {
	DataCatalog *DataCatalog `protobuf:"bytes,1,opt,name=data_catalog,json=dataCatalog,proto3" json:"data_catalog,omitempty"`
	// contains filtered or unexported fields
}

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

type GetDatasetMetricsResponse struct {

	// open-ended for now
	Json string `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"`
	// contains filtered or unexported fields
}

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

type GetDatasetResponse struct {
	Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

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

type GetDatasetSampleResponse struct {
	Data []string `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

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

type GetTagResponse struct {
	Tag *Tag `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

type ListDataCatalogConnectionsRequest struct {
	// contains filtered or unexported fields
}

type ListDataCatalogConnectionsResponse struct {
	DataCatalogConnections []*DataCatalog `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ListDatasetsRequest struct {
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	Count     int32  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// select subset of datasets
	Query string `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

type ListDatasetsResponse struct {
	Datasets      []*Dataset `protobuf:"bytes,1,rep,name=datasets,proto3" json:"datasets,omitempty"`
	NextPageToken string     `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// (-- api-linter: core::0132::response-unknown-fields=disabled
	//
	//	aip.dev/not-precedent: We really need this field because reasons. --)
	//
	// total number of datasets
	Total int32 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

type ListTagsRequest struct {
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	Count     int32  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// select subset of tags
	Query string `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

type ListTagsResponse struct {
	Tags          []*Tag `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// (-- api-linter: core::0132::response-unknown-fields=disabled
	//
	//	aip.dev/not-precedent: We really need this field because reasons. --)
	//
	// total number of tags
	Total int32 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

type OffsetPageToken struct {
	Start int32 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// contains filtered or unexported fields
}

type OpenDataDiscoveryConnection struct {

	// Currently only supports Unauthenticated
	Credentials *Credentials `protobuf:"bytes,1,opt,name=credentials,proto3" json:"credentials,omitempty"`
	Uri         string       `protobuf:"bytes,4,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

type Owner struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// urn uniquely identifies this owner within DCET
	Urn string `protobuf:"bytes,2,opt,name=urn,proto3" json:"urn,omitempty"`
	// urn used on the data platform
	OriginUrn string `protobuf:"bytes,3,opt,name=origin_urn,json=originUrn,proto3" json:"origin_urn,omitempty"`
	// contains filtered or unexported fields
}

type Relation struct {
	Direction Relation_Direction `` /* 128-byte string literal not displayed */
	Relation  string             `protobuf:"bytes,2,opt,name=relation,proto3" json:"relation,omitempty"`
	// urn uniquely identifies this relation within DCET
	Urn string `protobuf:"bytes,3,opt,name=urn,proto3" json:"urn,omitempty"`
	// urn used on the data platform
	OriginUrn string `protobuf:"bytes,4,opt,name=origin_urn,json=originUrn,proto3" json:"origin_urn,omitempty"`
	// contains filtered or unexported fields
}

type Relation_Direction int32

type Schema struct {
	SchemaFields []*SchemaField `protobuf:"bytes,1,rep,name=schema_fields,json=schemaFields,proto3" json:"schema_fields,omitempty"`
	// contains filtered or unexported fields
}

type SchemaField struct {

	// a dot separated exact path to the schema field
	// e.g. customer.id, customer.address.zip_code
	Path string          `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Type SchemaFieldType `protobuf:"varint,2,opt,name=type,proto3,enum=strmprivacy.api.data_catalog.v1.SchemaFieldType" json:"type,omitempty"`
	Tags []*Tag          `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// urn uniquely identifies this schema field within DCET
	Urn           string            `protobuf:"bytes,4,opt,name=urn,proto3" json:"urn,omitempty"`
	FieldMetaData *v1.FieldMetadata `protobuf:"bytes,5,opt,name=field_meta_data,json=fieldMetaData,proto3" json:"field_meta_data,omitempty"`
	// contains filtered or unexported fields
}

type SchemaFieldType int32

type Tag struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// urn uniquely identifies this tag within DCET
	Urn         string `protobuf:"bytes,2,opt,name=urn,proto3" json:"urn,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// css color
	Color string `protobuf:"bytes,4,opt,name=color,proto3" json:"color,omitempty"`
	// urn used on the data platform
	OriginUrn string `protobuf:"bytes,5,opt,name=origin_urn,json=originUrn,proto3" json:"origin_urn,omitempty"`
	// contains filtered or unexported fields
}

type TagsServiceClient interface {
	GetTag(ctx context.Context, in *GetTagRequest, opts ...grpc.CallOption) (*GetTagResponse, error)
	ListTags(ctx context.Context, in *ListTagsRequest, opts ...grpc.CallOption) (*ListTagsResponse, error)
}

type TagsServiceServer interface {
	GetTag(context.Context, *GetTagRequest) (*GetTagResponse, error)
	ListTags(context.Context, *ListTagsRequest) (*ListTagsResponse, error)
}

type UnimplementedDataCatalogServiceServer struct {
}

type UnimplementedDatasetsServiceServer struct {
}

type UnimplementedTagsServiceServer struct {
}

type UnsafeDataCatalogServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeDatasetsServiceServer interface {
	// contains filtered or unexported methods
}

type UnsafeTagsServiceServer interface {
	// contains filtered or unexported methods
}

type UpdateDatasetTagsRequest struct {
	DatasetUrn   string   `protobuf:"bytes,1,opt,name=dataset_urn,json=datasetUrn,proto3" json:"dataset_urn,omitempty"`
	AddTagUrn    []string `protobuf:"bytes,2,rep,name=add_tag_urn,json=addTagUrn,proto3" json:"add_tag_urn,omitempty"`
	RemoveTagUrn []string `protobuf:"bytes,3,rep,name=remove_tag_urn,json=removeTagUrn,proto3" json:"remove_tag_urn,omitempty"`
	// contains filtered or unexported fields
}

type UpdateDatasetTagsResponse struct {
	Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}

type UpdateSchemaFieldTagsRequest struct {
	DatasetUrn   string   `protobuf:"bytes,1,opt,name=dataset_urn,json=datasetUrn,proto3" json:"dataset_urn,omitempty"`
	Path         string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	AddTagUrn    []string `protobuf:"bytes,3,rep,name=add_tag_urn,json=addTagUrn,proto3" json:"add_tag_urn,omitempty"`
	RemoveTagUrn []string `protobuf:"bytes,4,rep,name=remove_tag_urn,json=removeTagUrn,proto3" json:"remove_tag_urn,omitempty"`
	// contains filtered or unexported fields
}

type UpdateSchemaFieldTagsResponse struct {
	Dataset *Dataset `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"`
	// contains filtered or unexported fields
}