data_catalog

package
v3.0.1 Latest Latest
Warning

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

 Go to latest Published: Jun 22, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SchemaFieldType_name = map[int32]string{
		0: "SCHEMA_FIELD_TYPE_UNSPECIFIED",
		1: "STRING",
		2: "INT_32",
		3: "INT_64",
		4: "BOOLEAN",
	}
	SchemaFieldType_value = map[string]int32{
		"SCHEMA_FIELD_TYPE_UNSPECIFIED": 0,
		"STRING":                        1,
		"INT_32":                        2,
		"INT_64":                        3,
		"BOOLEAN":                       4,
	}
)

Enum value maps for SchemaFieldType.

View Source 
var (
	DataPlatformType_name = map[int32]string{
		0:  "DATA_PLATFORM_TYPE_UNSPECIFIED",
		1:  "OPEN_API",
		2:  "ADLS_GEN_1",
		3:  "ADLS_GEN_2",
		4:  "AIRFLOW",
		5:  "AMBRY",
		6:  "ATHENA",
		7:  "BIGQUERY",
		8:  "CLICKHOUSE",
		9:  "COUCHBASE",
		10: "DATABRICKS",
		11: "DBT",
		12: "DELTA_LAKE",
		13: "DRUID",
		14: "ELASTICSEARCH",
		15: "EXTERNAL",
		16: "FEAST",
		17: "GLUE",
		18: "GREAT_EXPECTATIONS",
		19: "HANA",
		20: "HDFS",
		21: "HIVE",
		22: "ICEBERG",
		23: "KAFKA",
		24: "KAFKA_CONNECT",
		25: "KUSTO",
		26: "LOOKER",
		27: "MARIADB",
		28: "METABASE",
		29: "MODE",
		30: "MONGODB",
		31: "MSSQL",
		32: "MYSQL",
		33: "NIFI",
		34: "ORACLE",
		35: "PINOT",
		36: "POSTGRES",
		37: "POWERBI",
		38: "PRESTO",
		39: "PRESTO_ON_HIVE",
		40: "PULSAR",
		41: "REDASH",
		42: "REDSHIFT",
		43: "AWS_S3",
		44: "SAGEMAKER",
		45: "SALESFORCE",
		46: "SNOWFLAKE",
		47: "SPARK",
		48: "SUPERSET",
		49: "TABLEAU",
		50: "TERADATA",
		51: "TRINO",
		52: "UNKNOWN",
		53: "VERTICA",
		54: "VOLDEMORT",
	}
	DataPlatformType_value = map[string]int32{
		"DATA_PLATFORM_TYPE_UNSPECIFIED": 0,
		"OPEN_API":                       1,
		"ADLS_GEN_1":                     2,
		"ADLS_GEN_2":                     3,
		"AIRFLOW":                        4,
		"AMBRY":                          5,
		"ATHENA":                         6,
		"BIGQUERY":                       7,
		"CLICKHOUSE":                     8,
		"COUCHBASE":                      9,
		"DATABRICKS":                     10,
		"DBT":                            11,
		"DELTA_LAKE":                     12,
		"DRUID":                          13,
		"ELASTICSEARCH":                  14,
		"EXTERNAL":                       15,
		"FEAST":                          16,
		"GLUE":                           17,
		"GREAT_EXPECTATIONS":             18,
		"HANA":                           19,
		"HDFS":                           20,
		"HIVE":                           21,
		"ICEBERG":                        22,
		"KAFKA":                          23,
		"KAFKA_CONNECT":                  24,
		"KUSTO":                          25,
		"LOOKER":                         26,
		"MARIADB":                        27,
		"METABASE":                       28,
		"MODE":                           29,
		"MONGODB":                        30,
		"MSSQL":                          31,
		"MYSQL":                          32,
		"NIFI":                           33,
		"ORACLE":                         34,
		"PINOT":                          35,
		"POSTGRES":                       36,
		"POWERBI":                        37,
		"PRESTO":                         38,
		"PRESTO_ON_HIVE":                 39,
		"PULSAR":                         40,
		"REDASH":                         41,
		"REDSHIFT":                       42,
		"AWS_S3":                         43,
		"SAGEMAKER":                      44,
		"SALESFORCE":                     45,
		"SNOWFLAKE":                      46,
		"SPARK":                          47,
		"SUPERSET":                       48,
		"TABLEAU":                        49,
		"TERADATA":                       50,
		"TRINO":                          51,
		"UNKNOWN":                        52,
		"VERTICA":                        53,
		"VOLDEMORT":                      54,
	}
)

Enum value maps for DataPlatformType.

View Source 
var (
	Relation_Direction_name = map[int32]string{
		0: "DIRECTION_UNSPECIFIED",
		1: "IN",
		2: "OUT",
		3: "IN_OUT",
	}
	Relation_Direction_value = map[string]int32{
		"DIRECTION_UNSPECIFIED": 0,
		"IN":                    1,
		"OUT":                   2,
		"IN_OUT":                3,
	}
)

Enum value maps for Relation_Direction.

View Source 
var DataCatalogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.data_catalog.v1.DataCatalogService",
	HandlerType: (*DataCatalogServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDataCatalogConnection",
			Handler:    _DataCatalogService_GetDataCatalogConnection_Handler,
		},
		{
			MethodName: "ListDataCatalogConnections",
			Handler:    _DataCatalogService_ListDataCatalogConnections_Handler,
		},
		{
			MethodName: "CreateDataCatalogConnection",
			Handler:    _DataCatalogService_CreateDataCatalogConnection_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/data_catalog/v1/data_catalog_v1.proto",
}

DataCatalogService_ServiceDesc is the grpc.ServiceDesc for DataCatalogService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DatasetsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.data_catalog.v1.DatasetsService",
	HandlerType: (*DatasetsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDataset",
			Handler:    _DatasetsService_GetDataset_Handler,
		},
		{
			MethodName: "GetDatasetSample",
			Handler:    _DatasetsService_GetDatasetSample_Handler,
		},
		{
			MethodName: "GetDatasetMetrics",
			Handler:    _DatasetsService_GetDatasetMetrics_Handler,
		},
		{
			MethodName: "ListDatasets",
			Handler:    _DatasetsService_ListDatasets_Handler,
		},
		{
			MethodName: "UpdateDatasetTags",
			Handler:    _DatasetsService_UpdateDatasetTags_Handler,
		},
		{
			MethodName: "UpdateSchemaFieldTags",
			Handler:    _DatasetsService_UpdateSchemaFieldTags_Handler,
		},
		{
			MethodName: "CreateDatasetContentsConnection",
			Handler:    _DatasetsService_CreateDatasetContentsConnection_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/data_catalog/v1/datasets_v1.proto",
}

DatasetsService_ServiceDesc is the grpc.ServiceDesc for DatasetsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_strmprivacy_api_data_catalog_v1_data_catalog_v1_proto protoreflect.FileDescriptor
View Source 
var File_strmprivacy_api_data_catalog_v1_datasets_v1_proto protoreflect.FileDescriptor
View Source 
var File_strmprivacy_api_data_catalog_v1_entities_v1_proto protoreflect.FileDescriptor
View Source 
var File_strmprivacy_api_data_catalog_v1_tags_proto protoreflect.FileDescriptor
View Source 
var TagsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.data_catalog.v1.TagsService",
	HandlerType: (*TagsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetTag",
			Handler:    _TagsService_GetTag_Handler,
		},
		{
			MethodName: "ListTags",
			Handler:    _TagsService_ListTags_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/data_catalog/v1/tags.proto",
}

TagsService_ServiceDesc is the grpc.ServiceDesc for TagsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterDataCatalogServiceServer 

func RegisterDataCatalogServiceServer(s grpc.ServiceRegistrar, srv DataCatalogServiceServer)

func RegisterDatasetsServiceServer 

func RegisterDatasetsServiceServer(s grpc.ServiceRegistrar, srv DatasetsServiceServer)

func RegisterTagsServiceServer 

func RegisterTagsServiceServer(s grpc.ServiceRegistrar, srv TagsServiceServer)

Types

type CreateDataCatalogConnectionRequest 

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

func (*CreateDataCatalogConnectionRequest) Descriptor deprecated 

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

Deprecated: Use CreateDataCatalogConnectionRequest.ProtoReflect.Descriptor instead.

func (*CreateDataCatalogConnectionRequest) GetDataCatalog 

func (x *CreateDataCatalogConnectionRequest) GetDataCatalog() *DataCatalog

func (*CreateDataCatalogConnectionRequest) ProtoMessage 

func (*CreateDataCatalogConnectionRequest) ProtoMessage()

func (*CreateDataCatalogConnectionRequest) ProtoReflect 

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

func (*CreateDataCatalogConnectionRequest) Reset 

func (x *CreateDataCatalogConnectionRequest) Reset()

func (*CreateDataCatalogConnectionRequest) String 

func (x *CreateDataCatalogConnectionRequest) String() string

type CreateDataCatalogConnectionResponse 

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

func (*CreateDataCatalogConnectionResponse) Descriptor deprecated 

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

Deprecated: Use CreateDataCatalogConnectionResponse.ProtoReflect.Descriptor instead.

func (*CreateDataCatalogConnectionResponse) ProtoMessage 

func (*CreateDataCatalogConnectionResponse) ProtoMessage()

func (*CreateDataCatalogConnectionResponse) ProtoReflect 

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

func (*CreateDataCatalogConnectionResponse) Reset 

func (x *CreateDataCatalogConnectionResponse) Reset()

func (*CreateDataCatalogConnectionResponse) String 

func (x *CreateDataCatalogConnectionResponse) String() string

type CreateDatasetContentsConnectionRequest 

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

func (*CreateDatasetContentsConnectionRequest) Descriptor deprecated 

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

Deprecated: Use CreateDatasetContentsConnectionRequest.ProtoReflect.Descriptor instead.

func (*CreateDatasetContentsConnectionRequest) GetDatasetContentsConnection 

func (x *CreateDatasetContentsConnectionRequest) GetDatasetContentsConnection() *DatasetContentsConnection

func (*CreateDatasetContentsConnectionRequest) ProtoMessage 

func (*CreateDatasetContentsConnectionRequest) ProtoMessage()

func (*CreateDatasetContentsConnectionRequest) ProtoReflect 

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

func (*CreateDatasetContentsConnectionRequest) Reset 

func (x *CreateDatasetContentsConnectionRequest) Reset()

func (*CreateDatasetContentsConnectionRequest) String 

func (x *CreateDatasetContentsConnectionRequest) String() string

type CreateDatasetContentsConnectionResponse 

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

func (*CreateDatasetContentsConnectionResponse) Descriptor deprecated 

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

Deprecated: Use CreateDatasetContentsConnectionResponse.ProtoReflect.Descriptor instead.

func (*CreateDatasetContentsConnectionResponse) ProtoMessage 

func (*CreateDatasetContentsConnectionResponse) ProtoMessage()

func (*CreateDatasetContentsConnectionResponse) ProtoReflect 

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

func (*CreateDatasetContentsConnectionResponse) Reset 

func (x *CreateDatasetContentsConnectionResponse) Reset()

func (*CreateDatasetContentsConnectionResponse) String 

func (x *CreateDatasetContentsConnectionResponse) String() string

type Credentials 

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
}

func (*Credentials) Descriptor deprecated 

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

Deprecated: Use Credentials.ProtoReflect.Descriptor instead.

func (*Credentials) GetAuthentication 

func (m *Credentials) GetAuthentication() isCredentials_Authentication

func (*Credentials) GetBasic 

func (x *Credentials) GetBasic() *Credentials_Basic

func (*Credentials) GetBearer 

func (x *Credentials) GetBearer() *Credentials_Bearer

func (*Credentials) GetUnauthenticated 

func (x *Credentials) GetUnauthenticated() *Credentials_Unauthenticated

func (*Credentials) GetUrn 

func (x *Credentials) GetUrn() 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 Credentials_Basic 

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
}

func (*Credentials_Basic) Descriptor deprecated 

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

Deprecated: Use Credentials_Basic.ProtoReflect.Descriptor instead.

func (*Credentials_Basic) GetPassword 

func (x *Credentials_Basic) GetPassword() string

func (*Credentials_Basic) GetUsername 

func (x *Credentials_Basic) GetUsername() string

func (*Credentials_Basic) ProtoMessage 

func (*Credentials_Basic) ProtoMessage()

func (*Credentials_Basic) ProtoReflect 

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

func (*Credentials_Basic) Reset 

func (x *Credentials_Basic) Reset()

func (*Credentials_Basic) String 

func (x *Credentials_Basic) String() string

type Credentials_Basic_ 

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

type Credentials_Bearer 

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

func (*Credentials_Bearer) Descriptor deprecated 

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

Deprecated: Use Credentials_Bearer.ProtoReflect.Descriptor instead.

func (*Credentials_Bearer) GetToken 

func (x *Credentials_Bearer) GetToken() string

func (*Credentials_Bearer) ProtoMessage 

func (*Credentials_Bearer) ProtoMessage()

func (*Credentials_Bearer) ProtoReflect 

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

func (*Credentials_Bearer) Reset 

func (x *Credentials_Bearer) Reset()

func (*Credentials_Bearer) String 

func (x *Credentials_Bearer) String() string

type Credentials_Bearer_ 

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

type Credentials_Unauthenticated 

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

func (*Credentials_Unauthenticated) Descriptor deprecated 

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

Deprecated: Use Credentials_Unauthenticated.ProtoReflect.Descriptor instead.

func (*Credentials_Unauthenticated) ProtoMessage 

func (*Credentials_Unauthenticated) ProtoMessage()

func (*Credentials_Unauthenticated) ProtoReflect 

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

func (*Credentials_Unauthenticated) Reset 

func (x *Credentials_Unauthenticated) Reset()

func (*Credentials_Unauthenticated) String 

func (x *Credentials_Unauthenticated) String() string

type Credentials_Unauthenticated_ 

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

type DataCatalog 

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
}

func (*DataCatalog) Descriptor deprecated 

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

Deprecated: Use DataCatalog.ProtoReflect.Descriptor instead.

func (*DataCatalog) GetConnection 

func (m *DataCatalog) GetConnection() isDataCatalog_Connection

func (*DataCatalog) GetDatahubConnection 

func (x *DataCatalog) GetDatahubConnection() *DatahubConnection

func (*DataCatalog) GetName 

func (x *DataCatalog) GetName() string

func (*DataCatalog) GetOddConnection 

func (x *DataCatalog) GetOddConnection() *OpenDataDiscoveryConnection

func (*DataCatalog) GetUrn 

func (x *DataCatalog) GetUrn() string

func (*DataCatalog) ProtoMessage 

func (*DataCatalog) ProtoMessage()

func (*DataCatalog) ProtoReflect 

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

func (*DataCatalog) Reset 

func (x *DataCatalog) Reset()

func (*DataCatalog) String 

func (x *DataCatalog) String() string

type DataCatalogServiceClient 

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

DataCatalogServiceClient is the client API for DataCatalogService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDataCatalogServiceClient 

func NewDataCatalogServiceClient(cc grpc.ClientConnInterface) DataCatalogServiceClient

type DataCatalogServiceServer 

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

DataCatalogServiceServer is the server API for DataCatalogService service. All implementations should embed UnimplementedDataCatalogServiceServer for forward compatibility

type DataCatalog_DatahubConnection 

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

type DataCatalog_OddConnection 

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

type DataPlatform 

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
}

The data platform responsible for storage (and processing).

func (*DataPlatform) Descriptor deprecated 

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

Deprecated: Use DataPlatform.ProtoReflect.Descriptor instead.

func (*DataPlatform) GetInstance 

func (x *DataPlatform) GetInstance() string

func (*DataPlatform) GetLogoUri 

func (x *DataPlatform) GetLogoUri() string

func (*DataPlatform) GetOriginUrn 

func (x *DataPlatform) GetOriginUrn() string

func (*DataPlatform) GetType 

func (x *DataPlatform) GetType() DataPlatformType

func (*DataPlatform) GetUrn 

func (x *DataPlatform) GetUrn() string

func (*DataPlatform) ProtoMessage 

func (*DataPlatform) ProtoMessage()

func (*DataPlatform) ProtoReflect 

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

func (*DataPlatform) Reset 

func (x *DataPlatform) Reset()

func (*DataPlatform) String 

func (x *DataPlatform) String() string

type DataPlatformType 

type DataPlatformType int32
const (
	DataPlatformType_DATA_PLATFORM_TYPE_UNSPECIFIED DataPlatformType = 0
	DataPlatformType_OPEN_API                       DataPlatformType = 1
	DataPlatformType_ADLS_GEN_1                     DataPlatformType = 2
	DataPlatformType_ADLS_GEN_2                     DataPlatformType = 3
	DataPlatformType_AIRFLOW                        DataPlatformType = 4
	DataPlatformType_AMBRY                          DataPlatformType = 5
	DataPlatformType_ATHENA                         DataPlatformType = 6
	DataPlatformType_BIGQUERY                       DataPlatformType = 7
	DataPlatformType_CLICKHOUSE                     DataPlatformType = 8
	DataPlatformType_COUCHBASE                      DataPlatformType = 9
	DataPlatformType_DATABRICKS                     DataPlatformType = 10
	DataPlatformType_DBT                            DataPlatformType = 11
	DataPlatformType_DELTA_LAKE                     DataPlatformType = 12
	DataPlatformType_DRUID                          DataPlatformType = 13
	DataPlatformType_ELASTICSEARCH                  DataPlatformType = 14
	DataPlatformType_EXTERNAL                       DataPlatformType = 15
	DataPlatformType_FEAST                          DataPlatformType = 16
	DataPlatformType_GLUE                           DataPlatformType = 17
	DataPlatformType_GREAT_EXPECTATIONS             DataPlatformType = 18
	DataPlatformType_HANA                           DataPlatformType = 19
	DataPlatformType_HDFS                           DataPlatformType = 20
	DataPlatformType_HIVE                           DataPlatformType = 21
	DataPlatformType_ICEBERG                        DataPlatformType = 22
	DataPlatformType_KAFKA                          DataPlatformType = 23
	DataPlatformType_KAFKA_CONNECT                  DataPlatformType = 24
	DataPlatformType_KUSTO                          DataPlatformType = 25
	DataPlatformType_LOOKER                         DataPlatformType = 26
	DataPlatformType_MARIADB                        DataPlatformType = 27
	DataPlatformType_METABASE                       DataPlatformType = 28
	DataPlatformType_MODE                           DataPlatformType = 29
	DataPlatformType_MONGODB                        DataPlatformType = 30
	DataPlatformType_MSSQL                          DataPlatformType = 31
	DataPlatformType_MYSQL                          DataPlatformType = 32
	DataPlatformType_NIFI                           DataPlatformType = 33
	DataPlatformType_ORACLE                         DataPlatformType = 34
	DataPlatformType_PINOT                          DataPlatformType = 35
	DataPlatformType_POSTGRES                       DataPlatformType = 36
	DataPlatformType_POWERBI                        DataPlatformType = 37
	DataPlatformType_PRESTO                         DataPlatformType = 38
	DataPlatformType_PRESTO_ON_HIVE                 DataPlatformType = 39
	DataPlatformType_PULSAR                         DataPlatformType = 40
	DataPlatformType_REDASH                         DataPlatformType = 41
	DataPlatformType_REDSHIFT                       DataPlatformType = 42
	DataPlatformType_AWS_S3                         DataPlatformType = 43
	DataPlatformType_SAGEMAKER                      DataPlatformType = 44
	DataPlatformType_SALESFORCE                     DataPlatformType = 45
	DataPlatformType_SNOWFLAKE                      DataPlatformType = 46
	DataPlatformType_SPARK                          DataPlatformType = 47
	DataPlatformType_SUPERSET                       DataPlatformType = 48
	DataPlatformType_TABLEAU                        DataPlatformType = 49
	DataPlatformType_TERADATA                       DataPlatformType = 50
	DataPlatformType_TRINO                          DataPlatformType = 51
	DataPlatformType_UNKNOWN                        DataPlatformType = 52
	DataPlatformType_VERTICA                        DataPlatformType = 53
	DataPlatformType_VOLDEMORT                      DataPlatformType = 54
)

func (DataPlatformType) Descriptor 

func (DataPlatformType) Descriptor() protoreflect.EnumDescriptor

func (DataPlatformType) Enum 

func (x DataPlatformType) Enum() *DataPlatformType

func (DataPlatformType) EnumDescriptor deprecated 

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

Deprecated: Use DataPlatformType.Descriptor instead.

func (DataPlatformType) Number 

func (x DataPlatformType) Number() protoreflect.EnumNumber

func (DataPlatformType) String 

func (x DataPlatformType) String() string

func (DataPlatformType) Type 

func (DataPlatformType) Type() protoreflect.EnumType

type DatahubConnection 

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
}

func (*DatahubConnection) Descriptor deprecated 

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

Deprecated: Use DatahubConnection.ProtoReflect.Descriptor instead.

func (*DatahubConnection) GetCredentials 

func (x *DatahubConnection) GetCredentials() *Credentials

func (*DatahubConnection) GetUri 

func (x *DatahubConnection) GetUri() string

func (*DatahubConnection) ProtoMessage 

func (*DatahubConnection) ProtoMessage()

func (*DatahubConnection) ProtoReflect 

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

func (*DatahubConnection) Reset 

func (x *DatahubConnection) Reset()

func (*DatahubConnection) String 

func (x *DatahubConnection) String() string

type Dataset 

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
}

TODO add validations! a collection of structured data, which is given structure by a schema

func (*Dataset) Descriptor deprecated 

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

Deprecated: Use Dataset.ProtoReflect.Descriptor instead.

func (*Dataset) GetDataCatalogUrn 

func (x *Dataset) GetDataCatalogUrn() string

func (*Dataset) GetDisplayName 

func (x *Dataset) GetDisplayName() string

func (*Dataset) GetOriginUrn 

func (x *Dataset) GetOriginUrn() string

func (*Dataset) GetOwners 

func (x *Dataset) GetOwners() []*Owner

func (*Dataset) GetProperties 

func (x *Dataset) GetProperties() map[string]string

func (*Dataset) GetRelations 

func (x *Dataset) GetRelations() []*Relation

func (*Dataset) GetSchema 

func (x *Dataset) GetSchema() *Schema

func (*Dataset) GetTags 

func (x *Dataset) GetTags() []*Tag

func (*Dataset) GetUrn 

func (x *Dataset) GetUrn() string

func (*Dataset) ProtoMessage 

func (*Dataset) ProtoMessage()

func (*Dataset) ProtoReflect 

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

func (*Dataset) Reset 

func (x *Dataset) Reset()

func (*Dataset) String 

func (x *Dataset) String() string

type DatasetContentsConnection 

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
}

func (*DatasetContentsConnection) Descriptor deprecated 

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

Deprecated: Use DatasetContentsConnection.ProtoReflect.Descriptor instead.

func (*DatasetContentsConnection) GetAzureBlobStorageContainer 

func (x *DatasetContentsConnection) GetAzureBlobStorageContainer() *v1.AzureBlobStorageContainerLocation

func (*DatasetContentsConnection) GetConnectionConfig 

func (m *DatasetContentsConnection) GetConnectionConfig() isDatasetContentsConnection_ConnectionConfig

func (*DatasetContentsConnection) GetDatasetUrn 

func (x *DatasetContentsConnection) GetDatasetUrn() string

func (*DatasetContentsConnection) GetGoogleCloudStorageBucket 

func (x *DatasetContentsConnection) GetGoogleCloudStorageBucket() *v1.GoogleCloudStorageBucketLocation

func (*DatasetContentsConnection) GetJdbcLocation 

func (x *DatasetContentsConnection) GetJdbcLocation() *v1.JdbcLocation

func (*DatasetContentsConnection) GetS3Bucket 

func (x *DatasetContentsConnection) GetS3Bucket() *v1.AwsS3BucketLocation

func (*DatasetContentsConnection) ProtoMessage 

func (*DatasetContentsConnection) ProtoMessage()

func (*DatasetContentsConnection) ProtoReflect 

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

func (*DatasetContentsConnection) Reset 

func (x *DatasetContentsConnection) Reset()

func (*DatasetContentsConnection) String 

func (x *DatasetContentsConnection) String() string

type DatasetContentsConnection_AzureBlobStorageContainer 

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

type DatasetContentsConnection_GoogleCloudStorageBucket 

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

type DatasetContentsConnection_JdbcLocation 

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

type DatasetContentsConnection_S3Bucket 

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

type DatasetsServiceClient 

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

DatasetsServiceClient is the client API for DatasetsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDatasetsServiceClient 

func NewDatasetsServiceClient(cc grpc.ClientConnInterface) DatasetsServiceClient

type DatasetsServiceServer 

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

DatasetsServiceServer is the server API for DatasetsService service. All implementations should embed UnimplementedDatasetsServiceServer for forward compatibility

type GetDataCatalogConnectionRequest 

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

func (*GetDataCatalogConnectionRequest) Descriptor deprecated 

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

Deprecated: Use GetDataCatalogConnectionRequest.ProtoReflect.Descriptor instead.

func (*GetDataCatalogConnectionRequest) GetUrn 

func (x *GetDataCatalogConnectionRequest) GetUrn() string

func (*GetDataCatalogConnectionRequest) ProtoMessage 

func (*GetDataCatalogConnectionRequest) ProtoMessage()

func (*GetDataCatalogConnectionRequest) ProtoReflect 

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

func (*GetDataCatalogConnectionRequest) Reset 

func (x *GetDataCatalogConnectionRequest) Reset()

func (*GetDataCatalogConnectionRequest) String 

func (x *GetDataCatalogConnectionRequest) String() string

type GetDataCatalogConnectionResponse 

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

func (*GetDataCatalogConnectionResponse) Descriptor deprecated 

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

Deprecated: Use GetDataCatalogConnectionResponse.ProtoReflect.Descriptor instead.

func (*GetDataCatalogConnectionResponse) GetDataCatalog 

func (x *GetDataCatalogConnectionResponse) GetDataCatalog() *DataCatalog

func (*GetDataCatalogConnectionResponse) ProtoMessage 

func (*GetDataCatalogConnectionResponse) ProtoMessage()

func (*GetDataCatalogConnectionResponse) ProtoReflect 

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

func (*GetDataCatalogConnectionResponse) Reset 

func (x *GetDataCatalogConnectionResponse) Reset()

func (*GetDataCatalogConnectionResponse) String 

func (x *GetDataCatalogConnectionResponse) String() string

type GetDatasetMetricsRequest 

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

func (*GetDatasetMetricsRequest) Descriptor deprecated 

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

Deprecated: Use GetDatasetMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetDatasetMetricsRequest) GetUrn 

func (x *GetDatasetMetricsRequest) GetUrn() string

func (*GetDatasetMetricsRequest) ProtoMessage 

func (*GetDatasetMetricsRequest) ProtoMessage()

func (*GetDatasetMetricsRequest) ProtoReflect 

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

func (*GetDatasetMetricsRequest) Reset 

func (x *GetDatasetMetricsRequest) Reset()

func (*GetDatasetMetricsRequest) String 

func (x *GetDatasetMetricsRequest) String() string

type GetDatasetMetricsResponse 

type GetDatasetMetricsResponse struct {

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

func (*GetDatasetMetricsResponse) Descriptor deprecated 

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

Deprecated: Use GetDatasetMetricsResponse.ProtoReflect.Descriptor instead.

func (*GetDatasetMetricsResponse) GetJson 

func (x *GetDatasetMetricsResponse) GetJson() string

func (*GetDatasetMetricsResponse) ProtoMessage 

func (*GetDatasetMetricsResponse) ProtoMessage()

func (*GetDatasetMetricsResponse) ProtoReflect 

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

func (*GetDatasetMetricsResponse) Reset 

func (x *GetDatasetMetricsResponse) Reset()

func (*GetDatasetMetricsResponse) String 

func (x *GetDatasetMetricsResponse) String() string

type GetDatasetRequest 

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

func (*GetDatasetRequest) Descriptor deprecated 

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

Deprecated: Use GetDatasetRequest.ProtoReflect.Descriptor instead.

func (*GetDatasetRequest) GetUrn 

func (x *GetDatasetRequest) GetUrn() string

func (*GetDatasetRequest) ProtoMessage 

func (*GetDatasetRequest) ProtoMessage()

func (*GetDatasetRequest) ProtoReflect 

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

func (*GetDatasetRequest) Reset 

func (x *GetDatasetRequest) Reset()

func (*GetDatasetRequest) String 

func (x *GetDatasetRequest) String() string

type GetDatasetResponse 

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

func (*GetDatasetResponse) Descriptor deprecated 

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

Deprecated: Use GetDatasetResponse.ProtoReflect.Descriptor instead.

func (*GetDatasetResponse) GetDataset 

func (x *GetDatasetResponse) GetDataset() *Dataset

func (*GetDatasetResponse) ProtoMessage 

func (*GetDatasetResponse) ProtoMessage()

func (*GetDatasetResponse) ProtoReflect 

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

func (*GetDatasetResponse) Reset 

func (x *GetDatasetResponse) Reset()

func (*GetDatasetResponse) String 

func (x *GetDatasetResponse) String() string

type GetDatasetSampleRequest 

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

func (*GetDatasetSampleRequest) Descriptor deprecated 

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

Deprecated: Use GetDatasetSampleRequest.ProtoReflect.Descriptor instead.

func (*GetDatasetSampleRequest) GetUrn 

func (x *GetDatasetSampleRequest) GetUrn() string

func (*GetDatasetSampleRequest) ProtoMessage 

func (*GetDatasetSampleRequest) ProtoMessage()

func (*GetDatasetSampleRequest) ProtoReflect 

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

func (*GetDatasetSampleRequest) Reset 

func (x *GetDatasetSampleRequest) Reset()

func (*GetDatasetSampleRequest) String 

func (x *GetDatasetSampleRequest) String() string

type GetDatasetSampleResponse 

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

func (*GetDatasetSampleResponse) Descriptor deprecated 

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

Deprecated: Use GetDatasetSampleResponse.ProtoReflect.Descriptor instead.

func (*GetDatasetSampleResponse) GetData 

func (x *GetDatasetSampleResponse) GetData() []string

func (*GetDatasetSampleResponse) ProtoMessage 

func (*GetDatasetSampleResponse) ProtoMessage()

func (*GetDatasetSampleResponse) ProtoReflect 

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

func (*GetDatasetSampleResponse) Reset 

func (x *GetDatasetSampleResponse) Reset()

func (*GetDatasetSampleResponse) String 

func (x *GetDatasetSampleResponse) String() string

type GetTagRequest 

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

func (*GetTagRequest) Descriptor deprecated 

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

Deprecated: Use GetTagRequest.ProtoReflect.Descriptor instead.

func (*GetTagRequest) GetUrn 

func (x *GetTagRequest) GetUrn() string

func (*GetTagRequest) ProtoMessage 

func (*GetTagRequest) ProtoMessage()

func (*GetTagRequest) ProtoReflect 

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

func (*GetTagRequest) Reset 

func (x *GetTagRequest) Reset()

func (*GetTagRequest) String 

func (x *GetTagRequest) String() string

type GetTagResponse 

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

func (*GetTagResponse) Descriptor deprecated 

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

Deprecated: Use GetTagResponse.ProtoReflect.Descriptor instead.

func (*GetTagResponse) GetTag 

func (x *GetTagResponse) GetTag() *Tag

func (*GetTagResponse) ProtoMessage 

func (*GetTagResponse) ProtoMessage()

func (*GetTagResponse) ProtoReflect 

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

func (*GetTagResponse) Reset 

func (x *GetTagResponse) Reset()

func (*GetTagResponse) String 

func (x *GetTagResponse) String() string

type ListDataCatalogConnectionsRequest 

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

func (*ListDataCatalogConnectionsRequest) Descriptor deprecated 

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

Deprecated: Use ListDataCatalogConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ListDataCatalogConnectionsRequest) ProtoMessage 

func (*ListDataCatalogConnectionsRequest) ProtoMessage()

func (*ListDataCatalogConnectionsRequest) ProtoReflect 

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

func (*ListDataCatalogConnectionsRequest) Reset 

func (x *ListDataCatalogConnectionsRequest) Reset()

func (*ListDataCatalogConnectionsRequest) String 

func (x *ListDataCatalogConnectionsRequest) String() string

type ListDataCatalogConnectionsResponse 

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

func (*ListDataCatalogConnectionsResponse) Descriptor deprecated 

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

Deprecated: Use ListDataCatalogConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ListDataCatalogConnectionsResponse) GetDataCatalogConnections 

func (x *ListDataCatalogConnectionsResponse) GetDataCatalogConnections() []*DataCatalog

func (*ListDataCatalogConnectionsResponse) ProtoMessage 

func (*ListDataCatalogConnectionsResponse) ProtoMessage()

func (*ListDataCatalogConnectionsResponse) ProtoReflect 

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

func (*ListDataCatalogConnectionsResponse) Reset 

func (x *ListDataCatalogConnectionsResponse) Reset()

func (*ListDataCatalogConnectionsResponse) String 

func (x *ListDataCatalogConnectionsResponse) String() string

type ListDatasetsRequest 

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
}

func (*ListDatasetsRequest) Descriptor deprecated 

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

Deprecated: Use ListDatasetsRequest.ProtoReflect.Descriptor instead.

func (*ListDatasetsRequest) GetCount 

func (x *ListDatasetsRequest) GetCount() int32

func (*ListDatasetsRequest) GetPageToken 

func (x *ListDatasetsRequest) GetPageToken() string

func (*ListDatasetsRequest) GetQuery 

func (x *ListDatasetsRequest) GetQuery() string

func (*ListDatasetsRequest) ProtoMessage 

func (*ListDatasetsRequest) ProtoMessage()

func (*ListDatasetsRequest) ProtoReflect 

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

func (*ListDatasetsRequest) Reset 

func (x *ListDatasetsRequest) Reset()

func (*ListDatasetsRequest) String 

func (x *ListDatasetsRequest) String() string

type ListDatasetsResponse 

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
}

func (*ListDatasetsResponse) Descriptor deprecated 

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

Deprecated: Use ListDatasetsResponse.ProtoReflect.Descriptor instead.

func (*ListDatasetsResponse) GetDatasets 

func (x *ListDatasetsResponse) GetDatasets() []*Dataset

func (*ListDatasetsResponse) GetNextPageToken 

func (x *ListDatasetsResponse) GetNextPageToken() string

func (*ListDatasetsResponse) GetTotal 

func (x *ListDatasetsResponse) GetTotal() int32

func (*ListDatasetsResponse) ProtoMessage 

func (*ListDatasetsResponse) ProtoMessage()

func (*ListDatasetsResponse) ProtoReflect 

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

func (*ListDatasetsResponse) Reset 

func (x *ListDatasetsResponse) Reset()

func (*ListDatasetsResponse) String 

func (x *ListDatasetsResponse) String() string

type ListTagsRequest 

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
}

func (*ListTagsRequest) Descriptor deprecated 

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

Deprecated: Use ListTagsRequest.ProtoReflect.Descriptor instead.

func (*ListTagsRequest) GetCount 

func (x *ListTagsRequest) GetCount() int32

func (*ListTagsRequest) GetPageToken 

func (x *ListTagsRequest) GetPageToken() string

func (*ListTagsRequest) GetQuery 

func (x *ListTagsRequest) GetQuery() string

func (*ListTagsRequest) ProtoMessage 

func (*ListTagsRequest) ProtoMessage()

func (*ListTagsRequest) ProtoReflect 

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

func (*ListTagsRequest) Reset 

func (x *ListTagsRequest) Reset()

func (*ListTagsRequest) String 

func (x *ListTagsRequest) String() string

type ListTagsResponse 

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
}

func (*ListTagsResponse) Descriptor deprecated 

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

Deprecated: Use ListTagsResponse.ProtoReflect.Descriptor instead.

func (*ListTagsResponse) GetNextPageToken 

func (x *ListTagsResponse) GetNextPageToken() string

func (*ListTagsResponse) GetTags 

func (x *ListTagsResponse) GetTags() []*Tag

func (*ListTagsResponse) GetTotal 

func (x *ListTagsResponse) GetTotal() int32

func (*ListTagsResponse) ProtoMessage 

func (*ListTagsResponse) ProtoMessage()

func (*ListTagsResponse) ProtoReflect 

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

func (*ListTagsResponse) Reset 

func (x *ListTagsResponse) Reset()

func (*ListTagsResponse) String 

func (x *ListTagsResponse) String() string

type OffsetPageToken 

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

The page token for listing datasets, which is serialized as base64, as per Google Protobuf / gRPC recommendations: https://cloud.google.com/apis/design/design_patterns#list_pagination

func (*OffsetPageToken) Descriptor deprecated 

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

Deprecated: Use OffsetPageToken.ProtoReflect.Descriptor instead.

func (*OffsetPageToken) GetStart 

func (x *OffsetPageToken) GetStart() int32

func (*OffsetPageToken) ProtoMessage 

func (*OffsetPageToken) ProtoMessage()

func (*OffsetPageToken) ProtoReflect 

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

func (*OffsetPageToken) Reset 

func (x *OffsetPageToken) Reset()

func (*OffsetPageToken) String 

func (x *OffsetPageToken) String() string

type OpenDataDiscoveryConnection 

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
}

func (*OpenDataDiscoveryConnection) Descriptor deprecated 

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

Deprecated: Use OpenDataDiscoveryConnection.ProtoReflect.Descriptor instead.

func (*OpenDataDiscoveryConnection) GetCredentials 

func (x *OpenDataDiscoveryConnection) GetCredentials() *Credentials

func (*OpenDataDiscoveryConnection) GetUri 

func (x *OpenDataDiscoveryConnection) GetUri() string

func (*OpenDataDiscoveryConnection) ProtoMessage 

func (*OpenDataDiscoveryConnection) ProtoMessage()

func (*OpenDataDiscoveryConnection) ProtoReflect 

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

func (*OpenDataDiscoveryConnection) Reset 

func (x *OpenDataDiscoveryConnection) Reset()

func (*OpenDataDiscoveryConnection) String 

func (x *OpenDataDiscoveryConnection) String() string

type Owner 

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
}

func (*Owner) Descriptor deprecated 

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

Deprecated: Use Owner.ProtoReflect.Descriptor instead.

func (*Owner) GetName 

func (x *Owner) GetName() string

func (*Owner) GetOriginUrn 

func (x *Owner) GetOriginUrn() string

func (*Owner) GetUrn 

func (x *Owner) GetUrn() string

func (*Owner) ProtoMessage 

func (*Owner) ProtoMessage()

func (*Owner) ProtoReflect 

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

func (*Owner) Reset 

func (x *Owner) Reset()

func (*Owner) String 

func (x *Owner) String() string

type Relation 

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
}

func (*Relation) Descriptor deprecated 

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

Deprecated: Use Relation.ProtoReflect.Descriptor instead.

func (*Relation) GetDirection 

func (x *Relation) GetDirection() Relation_Direction

func (*Relation) GetOriginUrn 

func (x *Relation) GetOriginUrn() string

func (*Relation) GetRelation 

func (x *Relation) GetRelation() string

func (*Relation) GetUrn 

func (x *Relation) GetUrn() string

func (*Relation) ProtoMessage 

func (*Relation) ProtoMessage()

func (*Relation) ProtoReflect 

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

func (*Relation) Reset 

func (x *Relation) Reset()

func (*Relation) String 

func (x *Relation) String() string

type Relation_Direction 

type Relation_Direction int32
const (
	Relation_DIRECTION_UNSPECIFIED Relation_Direction = 0
	Relation_IN                    Relation_Direction = 1
	Relation_OUT                   Relation_Direction = 2
	Relation_IN_OUT                Relation_Direction = 3
)

func (Relation_Direction) Descriptor 

func (Relation_Direction) Descriptor() protoreflect.EnumDescriptor

func (Relation_Direction) Enum 

func (x Relation_Direction) Enum() *Relation_Direction

func (Relation_Direction) EnumDescriptor deprecated 

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

Deprecated: Use Relation_Direction.Descriptor instead.

func (Relation_Direction) Number 

func (x Relation_Direction) Number() protoreflect.EnumNumber

func (Relation_Direction) String 

func (x Relation_Direction) String() string

func (Relation_Direction) Type 

func (Relation_Direction) Type() protoreflect.EnumType

type Schema 

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

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetSchemaFields 

func (x *Schema) GetSchemaFields() []*SchemaField

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 SchemaField 

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
}

func (*SchemaField) Descriptor deprecated 

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

Deprecated: Use SchemaField.ProtoReflect.Descriptor instead.

func (*SchemaField) GetFieldMetaData 

func (x *SchemaField) GetFieldMetaData() *v1.FieldMetadata

func (*SchemaField) GetPath 

func (x *SchemaField) GetPath() string

func (*SchemaField) GetTags 

func (x *SchemaField) GetTags() []*Tag

func (*SchemaField) GetType 

func (x *SchemaField) GetType() SchemaFieldType

func (*SchemaField) GetUrn 

func (x *SchemaField) GetUrn() string

func (*SchemaField) ProtoMessage 

func (*SchemaField) ProtoMessage()

func (*SchemaField) ProtoReflect 

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

func (*SchemaField) Reset 

func (x *SchemaField) Reset()

func (*SchemaField) String 

func (x *SchemaField) String() string

type SchemaFieldType 

type SchemaFieldType int32
const (
	SchemaFieldType_SCHEMA_FIELD_TYPE_UNSPECIFIED SchemaFieldType = 0
	SchemaFieldType_STRING                        SchemaFieldType = 1
	SchemaFieldType_INT_32                        SchemaFieldType = 2
	SchemaFieldType_INT_64                        SchemaFieldType = 3
	SchemaFieldType_BOOLEAN                       SchemaFieldType = 4
)

func (SchemaFieldType) Descriptor 

func (SchemaFieldType) Descriptor() protoreflect.EnumDescriptor

func (SchemaFieldType) Enum 

func (x SchemaFieldType) Enum() *SchemaFieldType

func (SchemaFieldType) EnumDescriptor deprecated 

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

Deprecated: Use SchemaFieldType.Descriptor instead.

func (SchemaFieldType) Number 

func (x SchemaFieldType) Number() protoreflect.EnumNumber

func (SchemaFieldType) String 

func (x SchemaFieldType) String() string

func (SchemaFieldType) Type 

func (SchemaFieldType) Type() protoreflect.EnumType

type Tag 

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
}

A tag classifies and categorizes data assets in data catalogs, behavior of systems can be altered based on tags. The purpose is to put a label on "something" to be able to recognize it as belonging to that collection.

func (*Tag) Descriptor deprecated 

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

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetColor 

func (x *Tag) GetColor() string

func (*Tag) GetDescription 

func (x *Tag) GetDescription() string

func (*Tag) GetName 

func (x *Tag) GetName() string

func (*Tag) GetOriginUrn 

func (x *Tag) GetOriginUrn() string

func (*Tag) GetUrn 

func (x *Tag) GetUrn() string

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect 

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

func (*Tag) Reset 

func (x *Tag) Reset()

func (*Tag) String 

func (x *Tag) String() string

type TagsServiceClient 

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

TagsServiceClient is the client API for TagsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTagsServiceClient 

func NewTagsServiceClient(cc grpc.ClientConnInterface) TagsServiceClient

type TagsServiceServer 

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

TagsServiceServer is the server API for TagsService service. All implementations should embed UnimplementedTagsServiceServer for forward compatibility

type UnimplementedDataCatalogServiceServer 

type UnimplementedDataCatalogServiceServer struct {
}

UnimplementedDataCatalogServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDataCatalogServiceServer) CreateDataCatalogConnection 

func (UnimplementedDataCatalogServiceServer) CreateDataCatalogConnection(context.Context, *CreateDataCatalogConnectionRequest) (*CreateDataCatalogConnectionResponse, error)

func (UnimplementedDataCatalogServiceServer) GetDataCatalogConnection 

func (UnimplementedDataCatalogServiceServer) GetDataCatalogConnection(context.Context, *GetDataCatalogConnectionRequest) (*GetDataCatalogConnectionResponse, error)

func (UnimplementedDataCatalogServiceServer) ListDataCatalogConnections 

func (UnimplementedDataCatalogServiceServer) ListDataCatalogConnections(context.Context, *ListDataCatalogConnectionsRequest) (*ListDataCatalogConnectionsResponse, error)

type UnimplementedDatasetsServiceServer 

type UnimplementedDatasetsServiceServer struct {
}

UnimplementedDatasetsServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDatasetsServiceServer) CreateDatasetContentsConnection 

func (UnimplementedDatasetsServiceServer) CreateDatasetContentsConnection(context.Context, *CreateDatasetContentsConnectionRequest) (*CreateDatasetContentsConnectionResponse, error)

func (UnimplementedDatasetsServiceServer) GetDataset 

func (UnimplementedDatasetsServiceServer) GetDataset(context.Context, *GetDatasetRequest) (*GetDatasetResponse, error)

func (UnimplementedDatasetsServiceServer) GetDatasetMetrics 

func (UnimplementedDatasetsServiceServer) GetDatasetMetrics(context.Context, *GetDatasetMetricsRequest) (*GetDatasetMetricsResponse, error)

func (UnimplementedDatasetsServiceServer) GetDatasetSample 

func (UnimplementedDatasetsServiceServer) GetDatasetSample(context.Context, *GetDatasetSampleRequest) (*GetDatasetSampleResponse, error)

func (UnimplementedDatasetsServiceServer) ListDatasets 

func (UnimplementedDatasetsServiceServer) ListDatasets(context.Context, *ListDatasetsRequest) (*ListDatasetsResponse, error)

func (UnimplementedDatasetsServiceServer) UpdateDatasetTags 

func (UnimplementedDatasetsServiceServer) UpdateDatasetTags(context.Context, *UpdateDatasetTagsRequest) (*UpdateDatasetTagsResponse, error)

func (UnimplementedDatasetsServiceServer) UpdateSchemaFieldTags 

func (UnimplementedDatasetsServiceServer) UpdateSchemaFieldTags(context.Context, *UpdateSchemaFieldTagsRequest) (*UpdateSchemaFieldTagsResponse, error)

type UnimplementedTagsServiceServer 

type UnimplementedTagsServiceServer struct {
}

UnimplementedTagsServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTagsServiceServer) GetTag 

func (UnimplementedTagsServiceServer) GetTag(context.Context, *GetTagRequest) (*GetTagResponse, error)

func (UnimplementedTagsServiceServer) ListTags 

func (UnimplementedTagsServiceServer) ListTags(context.Context, *ListTagsRequest) (*ListTagsResponse, error)

type UnsafeDataCatalogServiceServer 

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

UnsafeDataCatalogServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataCatalogServiceServer will result in compilation errors.

type UnsafeDatasetsServiceServer 

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

UnsafeDatasetsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatasetsServiceServer will result in compilation errors.

type UnsafeTagsServiceServer 

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

UnsafeTagsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TagsServiceServer will result in compilation errors.

type UpdateDatasetTagsRequest 

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
}

(-- api-linter: core::0134::request-mask-required=disabled 

aip.dev/not-precedent: We choose for the simple approach now --)

func (*UpdateDatasetTagsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateDatasetTagsRequest.ProtoReflect.Descriptor instead.

func (*UpdateDatasetTagsRequest) GetAddTagUrn 

func (x *UpdateDatasetTagsRequest) GetAddTagUrn() []string

func (*UpdateDatasetTagsRequest) GetDatasetUrn 

func (x *UpdateDatasetTagsRequest) GetDatasetUrn() string

func (*UpdateDatasetTagsRequest) GetRemoveTagUrn 

func (x *UpdateDatasetTagsRequest) GetRemoveTagUrn() []string

func (*UpdateDatasetTagsRequest) ProtoMessage 

func (*UpdateDatasetTagsRequest) ProtoMessage()

func (*UpdateDatasetTagsRequest) ProtoReflect 

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

func (*UpdateDatasetTagsRequest) Reset 

func (x *UpdateDatasetTagsRequest) Reset()

func (*UpdateDatasetTagsRequest) String 

func (x *UpdateDatasetTagsRequest) String() string

type UpdateDatasetTagsResponse 

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

func (*UpdateDatasetTagsResponse) Descriptor deprecated 

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

Deprecated: Use UpdateDatasetTagsResponse.ProtoReflect.Descriptor instead.

func (*UpdateDatasetTagsResponse) GetDataset 

func (x *UpdateDatasetTagsResponse) GetDataset() *Dataset

func (*UpdateDatasetTagsResponse) ProtoMessage 

func (*UpdateDatasetTagsResponse) ProtoMessage()

func (*UpdateDatasetTagsResponse) ProtoReflect 

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

func (*UpdateDatasetTagsResponse) Reset 

func (x *UpdateDatasetTagsResponse) Reset()

func (*UpdateDatasetTagsResponse) String 

func (x *UpdateDatasetTagsResponse) String() string

type UpdateSchemaFieldTagsRequest 

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
}

(-- api-linter: core::0134::request-mask-required=disabled 

aip.dev/not-precedent: We choose for the simple approach now --)

func (*UpdateSchemaFieldTagsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSchemaFieldTagsRequest.ProtoReflect.Descriptor instead.

func (*UpdateSchemaFieldTagsRequest) GetAddTagUrn 

func (x *UpdateSchemaFieldTagsRequest) GetAddTagUrn() []string

func (*UpdateSchemaFieldTagsRequest) GetDatasetUrn 

func (x *UpdateSchemaFieldTagsRequest) GetDatasetUrn() string

func (*UpdateSchemaFieldTagsRequest) GetPath 

func (x *UpdateSchemaFieldTagsRequest) GetPath() string

func (*UpdateSchemaFieldTagsRequest) GetRemoveTagUrn 

func (x *UpdateSchemaFieldTagsRequest) GetRemoveTagUrn() []string

func (*UpdateSchemaFieldTagsRequest) ProtoMessage 

func (*UpdateSchemaFieldTagsRequest) ProtoMessage()

func (*UpdateSchemaFieldTagsRequest) ProtoReflect 

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

func (*UpdateSchemaFieldTagsRequest) Reset 

func (x *UpdateSchemaFieldTagsRequest) Reset()

func (*UpdateSchemaFieldTagsRequest) String 

func (x *UpdateSchemaFieldTagsRequest) String() string

type UpdateSchemaFieldTagsResponse 

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

func (*UpdateSchemaFieldTagsResponse) Descriptor deprecated 

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

Deprecated: Use UpdateSchemaFieldTagsResponse.ProtoReflect.Descriptor instead.

func (*UpdateSchemaFieldTagsResponse) GetDataset 

func (x *UpdateSchemaFieldTagsResponse) GetDataset() *Dataset

func (*UpdateSchemaFieldTagsResponse) ProtoMessage 

func (*UpdateSchemaFieldTagsResponse) ProtoMessage()

func (*UpdateSchemaFieldTagsResponse) ProtoReflect 

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

func (*UpdateSchemaFieldTagsResponse) Reset 

func (x *UpdateSchemaFieldTagsResponse) Reset()

func (*UpdateSchemaFieldTagsResponse) String 

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