Documentation ¶
Index ¶
- Variables
- func RegisterDataCatalogServiceServer(s grpc.ServiceRegistrar, srv DataCatalogServiceServer)
- func RegisterPolicyManagerServiceServer(s grpc.ServiceRegistrar, srv PolicyManagerServiceServer)
- type AccessOperation
- func (*AccessOperation) Descriptor() ([]byte, []int)deprecated
- func (x *AccessOperation) GetDestination() string
- func (x *AccessOperation) GetType() AccessOperation_AccessType
- func (*AccessOperation) ProtoMessage()
- func (x *AccessOperation) ProtoReflect() protoreflect.Message
- func (x *AccessOperation) Reset()
- func (x *AccessOperation) String() string
- type AccessOperation_AccessType
- func (AccessOperation_AccessType) Descriptor() protoreflect.EnumDescriptor
- func (x AccessOperation_AccessType) Enum() *AccessOperation_AccessType
- func (AccessOperation_AccessType) EnumDescriptor() ([]byte, []int)deprecated
- func (x AccessOperation_AccessType) Number() protoreflect.EnumNumber
- func (x AccessOperation_AccessType) String() string
- func (AccessOperation_AccessType) Type() protoreflect.EnumType
- type ApplicationContext
- func (*ApplicationContext) Descriptor() ([]byte, []int)deprecated
- func (x *ApplicationContext) GetAppInfo() *ApplicationDetails
- func (x *ApplicationContext) GetCredentialPath() string
- func (x *ApplicationContext) GetDatasets() []*DatasetContext
- func (x *ApplicationContext) GetGeneralOperations() []*AccessOperation
- func (*ApplicationContext) ProtoMessage()
- func (x *ApplicationContext) ProtoReflect() protoreflect.Message
- func (x *ApplicationContext) Reset()
- func (x *ApplicationContext) String() string
- type ApplicationDetails
- func (*ApplicationDetails) Descriptor() ([]byte, []int)deprecated
- func (x *ApplicationDetails) GetProcessingGeography() string
- func (x *ApplicationDetails) GetProperties() map[string]string
- func (*ApplicationDetails) ProtoMessage()
- func (x *ApplicationDetails) ProtoReflect() protoreflect.Message
- func (x *ApplicationDetails) Reset()
- func (x *ApplicationDetails) String() string
- type CatalogDatasetInfo
- func (*CatalogDatasetInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CatalogDatasetInfo) GetDatasetId() string
- func (x *CatalogDatasetInfo) GetDetails() *DatasetDetails
- func (*CatalogDatasetInfo) ProtoMessage()
- func (x *CatalogDatasetInfo) ProtoReflect() protoreflect.Message
- func (x *CatalogDatasetInfo) Reset()
- func (x *CatalogDatasetInfo) String() string
- type CatalogDatasetRequest
- func (*CatalogDatasetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CatalogDatasetRequest) GetCredentialPath() string
- func (x *CatalogDatasetRequest) GetDatasetId() string
- func (*CatalogDatasetRequest) ProtoMessage()
- func (x *CatalogDatasetRequest) ProtoReflect() protoreflect.Message
- func (x *CatalogDatasetRequest) Reset()
- func (x *CatalogDatasetRequest) String() string
- type ComponentVersion
- func (*ComponentVersion) Descriptor() ([]byte, []int)deprecated
- func (x *ComponentVersion) GetId() string
- func (x *ComponentVersion) GetName() string
- func (x *ComponentVersion) GetVersion() string
- func (*ComponentVersion) ProtoMessage()
- func (x *ComponentVersion) ProtoReflect() protoreflect.Message
- func (x *ComponentVersion) Reset()
- func (x *ComponentVersion) String() string
- type Credentials
- func (*Credentials) Descriptor() ([]byte, []int)deprecated
- func (x *Credentials) GetAccessKey() string
- func (x *Credentials) GetApiKey() string
- func (x *Credentials) GetPassword() string
- func (x *Credentials) GetResourceInstanceId() string
- func (x *Credentials) GetSecretKey() string
- func (x *Credentials) GetUsername() string
- func (*Credentials) ProtoMessage()
- func (x *Credentials) ProtoReflect() protoreflect.Message
- func (x *Credentials) Reset()
- func (x *Credentials) String() string
- type CredentialsInfo
- type DataCatalogServiceClient
- type DataCatalogServiceServer
- type DataComponentMetadata
- func (*DataComponentMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *DataComponentMetadata) GetComponentType() string
- func (x *DataComponentMetadata) GetNamedMetadata() map[string]string
- func (x *DataComponentMetadata) GetTags() []string
- func (*DataComponentMetadata) ProtoMessage()
- func (x *DataComponentMetadata) ProtoReflect() protoreflect.Message
- func (x *DataComponentMetadata) Reset()
- func (x *DataComponentMetadata) String() string
- type DataStore
- func (*DataStore) Descriptor() ([]byte, []int)deprecated
- func (x *DataStore) GetDb2() *Db2DataStore
- func (x *DataStore) GetKafka() *KafkaDataStore
- func (x *DataStore) GetName() string
- func (x *DataStore) GetS3() *S3DataStore
- func (x *DataStore) GetType() DataStore_DataStoreType
- func (*DataStore) ProtoMessage()
- func (x *DataStore) ProtoReflect() protoreflect.Message
- func (x *DataStore) Reset()
- func (x *DataStore) String() string
- type DataStore_DataStoreType
- func (DataStore_DataStoreType) Descriptor() protoreflect.EnumDescriptor
- func (x DataStore_DataStoreType) Enum() *DataStore_DataStoreType
- func (DataStore_DataStoreType) EnumDescriptor() ([]byte, []int)deprecated
- func (x DataStore_DataStoreType) Number() protoreflect.EnumNumber
- func (x DataStore_DataStoreType) String() string
- func (DataStore_DataStoreType) Type() protoreflect.EnumType
- type DatasetContext
- func (*DatasetContext) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetContext) GetDataset() *DatasetIdentifier
- func (x *DatasetContext) GetOperation() *AccessOperation
- func (*DatasetContext) ProtoMessage()
- func (x *DatasetContext) ProtoReflect() protoreflect.Message
- func (x *DatasetContext) Reset()
- func (x *DatasetContext) String() string
- type DatasetDecision
- func (*DatasetDecision) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetDecision) GetDataset() *DatasetIdentifier
- func (x *DatasetDecision) GetDecisions() []*OperationDecision
- func (*DatasetDecision) ProtoMessage()
- func (x *DatasetDecision) ProtoReflect() protoreflect.Message
- func (x *DatasetDecision) Reset()
- func (x *DatasetDecision) String() string
- type DatasetDetails
- func (*DatasetDetails) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetDetails) GetCredentialsInfo() *CredentialsInfo
- func (x *DatasetDetails) GetDataFormat() string
- func (x *DatasetDetails) GetDataOwner() string
- func (x *DatasetDetails) GetDataStore() *DataStore
- func (x *DatasetDetails) GetGeo() string
- func (x *DatasetDetails) GetMetadata() *DatasetMetadata
- func (x *DatasetDetails) GetName() string
- func (*DatasetDetails) ProtoMessage()
- func (x *DatasetDetails) ProtoReflect() protoreflect.Message
- func (x *DatasetDetails) Reset()
- func (x *DatasetDetails) String() string
- type DatasetIdentifier
- type DatasetMetadata
- func (*DatasetMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetMetadata) GetComponentsMetadata() map[string]*DataComponentMetadata
- func (x *DatasetMetadata) GetDatasetNamedMetadata() map[string]string
- func (x *DatasetMetadata) GetDatasetTags() []string
- func (*DatasetMetadata) ProtoMessage()
- func (x *DatasetMetadata) ProtoReflect() protoreflect.Message
- func (x *DatasetMetadata) Reset()
- func (x *DatasetMetadata) String() string
- type Db2DataStore
- func (*Db2DataStore) Descriptor() ([]byte, []int)deprecated
- func (x *Db2DataStore) GetDatabase() string
- func (x *Db2DataStore) GetPort() string
- func (x *Db2DataStore) GetSsl() string
- func (x *Db2DataStore) GetTable() string
- func (x *Db2DataStore) GetUrl() string
- func (*Db2DataStore) ProtoMessage()
- func (x *Db2DataStore) ProtoReflect() protoreflect.Message
- func (x *Db2DataStore) Reset()
- func (x *Db2DataStore) String() string
- type EnforcementAction
- func (*EnforcementAction) Descriptor() ([]byte, []int)deprecated
- func (x *EnforcementAction) GetArgs() map[string]string
- func (x *EnforcementAction) GetId() string
- func (x *EnforcementAction) GetLevel() EnforcementAction_EnforcementActionLevel
- func (x *EnforcementAction) GetName() string
- func (*EnforcementAction) ProtoMessage()
- func (x *EnforcementAction) ProtoReflect() protoreflect.Message
- func (x *EnforcementAction) Reset()
- func (x *EnforcementAction) String() string
- type EnforcementAction_EnforcementActionLevel
- func (EnforcementAction_EnforcementActionLevel) Descriptor() protoreflect.EnumDescriptor
- func (x EnforcementAction_EnforcementActionLevel) Enum() *EnforcementAction_EnforcementActionLevel
- func (EnforcementAction_EnforcementActionLevel) EnumDescriptor() ([]byte, []int)deprecated
- func (x EnforcementAction_EnforcementActionLevel) Number() protoreflect.EnumNumber
- func (x EnforcementAction_EnforcementActionLevel) String() string
- func (EnforcementAction_EnforcementActionLevel) Type() protoreflect.EnumType
- type KafkaDataStore
- func (*KafkaDataStore) Descriptor() ([]byte, []int)deprecated
- func (x *KafkaDataStore) GetBootstrapServers() string
- func (x *KafkaDataStore) GetKeyDeserializer() string
- func (x *KafkaDataStore) GetSaslMechanism() string
- func (x *KafkaDataStore) GetSchemaRegistry() string
- func (x *KafkaDataStore) GetSecurityProtocol() string
- func (x *KafkaDataStore) GetSslTruststore() string
- func (x *KafkaDataStore) GetSslTruststorePassword() string
- func (x *KafkaDataStore) GetTopicName() string
- func (x *KafkaDataStore) GetValueDeserializer() string
- func (*KafkaDataStore) ProtoMessage()
- func (x *KafkaDataStore) ProtoReflect() protoreflect.Message
- func (x *KafkaDataStore) Reset()
- func (x *KafkaDataStore) String() string
- type OperationDecision
- func (*OperationDecision) Descriptor() ([]byte, []int)deprecated
- func (x *OperationDecision) GetEnforcementActions() []*EnforcementAction
- func (x *OperationDecision) GetOperation() *AccessOperation
- func (x *OperationDecision) GetUsedPolicies() []*Policy
- func (*OperationDecision) ProtoMessage()
- func (x *OperationDecision) ProtoReflect() protoreflect.Message
- func (x *OperationDecision) Reset()
- func (x *OperationDecision) String() string
- type PoliciesDecisions
- func (*PoliciesDecisions) Descriptor() ([]byte, []int)deprecated
- func (x *PoliciesDecisions) GetComponentVersions() []*ComponentVersion
- func (x *PoliciesDecisions) GetDatasetDecisions() []*DatasetDecision
- func (x *PoliciesDecisions) GetGeneralDecisions() []*OperationDecision
- func (*PoliciesDecisions) ProtoMessage()
- func (x *PoliciesDecisions) ProtoReflect() protoreflect.Message
- func (x *PoliciesDecisions) Reset()
- func (x *PoliciesDecisions) String() string
- type Policy
- func (*Policy) Descriptor() ([]byte, []int)deprecated
- func (x *Policy) GetDescription() string
- func (x *Policy) GetHierarchy() []string
- func (x *Policy) GetId() string
- func (x *Policy) GetName() string
- func (x *Policy) GetType() string
- func (*Policy) ProtoMessage()
- func (x *Policy) ProtoReflect() protoreflect.Message
- func (x *Policy) Reset()
- func (x *Policy) String() string
- type PolicyManagerServiceClient
- type PolicyManagerServiceServer
- type RegisterAssetRequest
- func (*RegisterAssetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterAssetRequest) GetCredentialPath() string
- func (x *RegisterAssetRequest) GetCreds() *Credentials
- func (x *RegisterAssetRequest) GetDatasetDetails() *DatasetDetails
- func (x *RegisterAssetRequest) GetDestinationCatalogId() string
- func (*RegisterAssetRequest) ProtoMessage()
- func (x *RegisterAssetRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterAssetRequest) Reset()
- func (x *RegisterAssetRequest) String() string
- type RegisterAssetResponse
- func (*RegisterAssetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterAssetResponse) GetAssetId() string
- func (*RegisterAssetResponse) ProtoMessage()
- func (x *RegisterAssetResponse) ProtoReflect() protoreflect.Message
- func (x *RegisterAssetResponse) Reset()
- func (x *RegisterAssetResponse) String() string
- type S3DataStore
- func (*S3DataStore) Descriptor() ([]byte, []int)deprecated
- func (x *S3DataStore) GetBucket() string
- func (x *S3DataStore) GetEndpoint() string
- func (x *S3DataStore) GetObjectKey() string
- func (x *S3DataStore) GetRegion() string
- func (*S3DataStore) ProtoMessage()
- func (x *S3DataStore) ProtoReflect() protoreflect.Message
- func (x *S3DataStore) Reset()
- func (x *S3DataStore) String() string
- type UnimplementedDataCatalogServiceServer
- type UnimplementedPolicyManagerServiceServer
- type UnsafeDataCatalogServiceServer
- type UnsafePolicyManagerServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( DataStore_DataStoreType_name = map[int32]string{ 0: "UNKNOWN", 1: "LOCAL", 2: "S3", 3: "DB2", 4: "KAFKA", } DataStore_DataStoreType_value = map[string]int32{ "UNKNOWN": 0, "LOCAL": 1, "S3": 2, "DB2": 3, "KAFKA": 4, } )
Enum value maps for DataStore_DataStoreType.
var ( AccessOperation_AccessType_name = map[int32]string{ 0: "UNKNOWN", 1: "READ", 2: "COPY", 3: "WRITE", } AccessOperation_AccessType_value = map[string]int32{ "UNKNOWN": 0, "READ": 1, "COPY": 2, "WRITE": 3, } )
Enum value maps for AccessOperation_AccessType.
var ( EnforcementAction_EnforcementActionLevel_name = map[int32]string{ 0: "UNKNOWN", 1: "DATASET", 2: "COLUMN", 3: "ROW", 4: "CELL", } EnforcementAction_EnforcementActionLevel_value = map[string]int32{ "UNKNOWN": 0, "DATASET": 1, "COLUMN": 2, "ROW": 3, "CELL": 4, } )
Enum value maps for EnforcementAction_EnforcementActionLevel.
var DataCatalogService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "connectors.DataCatalogService", HandlerType: (*DataCatalogServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetDatasetInfo", Handler: _DataCatalogService_GetDatasetInfo_Handler, }, { MethodName: "RegisterDatasetInfo", Handler: _DataCatalogService_RegisterDatasetInfo_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "data_catalog_service.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)
var File_credentials_proto protoreflect.FileDescriptor
var File_data_catalog_request_proto protoreflect.FileDescriptor
var File_data_catalog_response_proto protoreflect.FileDescriptor
var File_data_catalog_service_proto protoreflect.FileDescriptor
var File_dataset_details_proto protoreflect.FileDescriptor
var File_policy_manager_request_proto protoreflect.FileDescriptor
var File_policy_manager_response_proto protoreflect.FileDescriptor
var File_policy_manager_service_proto protoreflect.FileDescriptor
var File_register_asset_request_proto protoreflect.FileDescriptor
var File_register_asset_response_proto protoreflect.FileDescriptor
var PolicyManagerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "connectors.PolicyManagerService", HandlerType: (*PolicyManagerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetPoliciesDecisions", Handler: _PolicyManagerService_GetPoliciesDecisions_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "policy_manager_service.proto", }
PolicyManagerService_ServiceDesc is the grpc.ServiceDesc for PolicyManagerService 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 RegisterPolicyManagerServiceServer ¶
func RegisterPolicyManagerServiceServer(s grpc.ServiceRegistrar, srv PolicyManagerServiceServer)
Types ¶
type AccessOperation ¶
type AccessOperation struct { Type AccessOperation_AccessType `protobuf:"varint,1,opt,name=type,proto3,enum=connectors.AccessOperation_AccessType" json:"type,omitempty"` Destination string `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"` //Destination for transfer or write. // contains filtered or unexported fields }
func (*AccessOperation) Descriptor
deprecated
func (*AccessOperation) Descriptor() ([]byte, []int)
Deprecated: Use AccessOperation.ProtoReflect.Descriptor instead.
func (*AccessOperation) GetDestination ¶
func (x *AccessOperation) GetDestination() string
func (*AccessOperation) GetType ¶
func (x *AccessOperation) GetType() AccessOperation_AccessType
func (*AccessOperation) ProtoMessage ¶
func (*AccessOperation) ProtoMessage()
func (*AccessOperation) ProtoReflect ¶
func (x *AccessOperation) ProtoReflect() protoreflect.Message
func (*AccessOperation) Reset ¶
func (x *AccessOperation) Reset()
func (*AccessOperation) String ¶
func (x *AccessOperation) String() string
type AccessOperation_AccessType ¶
type AccessOperation_AccessType int32
const ( AccessOperation_UNKNOWN AccessOperation_AccessType = 0 AccessOperation_READ AccessOperation_AccessType = 1 AccessOperation_COPY AccessOperation_AccessType = 2 AccessOperation_WRITE AccessOperation_AccessType = 3 )
func (AccessOperation_AccessType) Descriptor ¶
func (AccessOperation_AccessType) Descriptor() protoreflect.EnumDescriptor
func (AccessOperation_AccessType) Enum ¶
func (x AccessOperation_AccessType) Enum() *AccessOperation_AccessType
func (AccessOperation_AccessType) EnumDescriptor
deprecated
func (AccessOperation_AccessType) EnumDescriptor() ([]byte, []int)
Deprecated: Use AccessOperation_AccessType.Descriptor instead.
func (AccessOperation_AccessType) Number ¶
func (x AccessOperation_AccessType) Number() protoreflect.EnumNumber
func (AccessOperation_AccessType) String ¶
func (x AccessOperation_AccessType) String() string
func (AccessOperation_AccessType) Type ¶
func (AccessOperation_AccessType) Type() protoreflect.EnumType
type ApplicationContext ¶
type ApplicationContext struct { CredentialPath string `protobuf:"bytes,1,opt,name=credential_path,json=credentialPath,proto3" json:"credential_path,omitempty"` // link to vault plugin for reading k8s secret with user credentials AppInfo *ApplicationDetails `protobuf:"bytes,2,opt,name=app_info,json=appInfo,proto3" json:"app_info,omitempty"` Datasets []*DatasetContext `protobuf:"bytes,3,rep,name=datasets,proto3" json:"datasets,omitempty"` GeneralOperations []*AccessOperation `protobuf:"bytes,4,rep,name=general_operations,json=generalOperations,proto3" json:"general_operations,omitempty"` // contains filtered or unexported fields }
func (*ApplicationContext) Descriptor
deprecated
func (*ApplicationContext) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationContext.ProtoReflect.Descriptor instead.
func (*ApplicationContext) GetAppInfo ¶
func (x *ApplicationContext) GetAppInfo() *ApplicationDetails
func (*ApplicationContext) GetCredentialPath ¶
func (x *ApplicationContext) GetCredentialPath() string
func (*ApplicationContext) GetDatasets ¶
func (x *ApplicationContext) GetDatasets() []*DatasetContext
func (*ApplicationContext) GetGeneralOperations ¶
func (x *ApplicationContext) GetGeneralOperations() []*AccessOperation
func (*ApplicationContext) ProtoMessage ¶
func (*ApplicationContext) ProtoMessage()
func (*ApplicationContext) ProtoReflect ¶
func (x *ApplicationContext) ProtoReflect() protoreflect.Message
func (*ApplicationContext) Reset ¶
func (x *ApplicationContext) Reset()
func (*ApplicationContext) String ¶
func (x *ApplicationContext) String() string
type ApplicationDetails ¶
type ApplicationDetails struct { ProcessingGeography string `protobuf:"bytes,1,opt,name=processing_geography,json=processingGeography,proto3" json:"processing_geography,omitempty"` Properties map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ApplicationDetails) Descriptor
deprecated
func (*ApplicationDetails) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationDetails.ProtoReflect.Descriptor instead.
func (*ApplicationDetails) GetProcessingGeography ¶
func (x *ApplicationDetails) GetProcessingGeography() string
func (*ApplicationDetails) GetProperties ¶
func (x *ApplicationDetails) GetProperties() map[string]string
func (*ApplicationDetails) ProtoMessage ¶
func (*ApplicationDetails) ProtoMessage()
func (*ApplicationDetails) ProtoReflect ¶
func (x *ApplicationDetails) ProtoReflect() protoreflect.Message
func (*ApplicationDetails) Reset ¶
func (x *ApplicationDetails) Reset()
func (*ApplicationDetails) String ¶
func (x *ApplicationDetails) String() string
type CatalogDatasetInfo ¶
type CatalogDatasetInfo struct { DatasetId string `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"` Details *DatasetDetails `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"` // contains filtered or unexported fields }
func (*CatalogDatasetInfo) Descriptor
deprecated
func (*CatalogDatasetInfo) Descriptor() ([]byte, []int)
Deprecated: Use CatalogDatasetInfo.ProtoReflect.Descriptor instead.
func (*CatalogDatasetInfo) GetDatasetId ¶
func (x *CatalogDatasetInfo) GetDatasetId() string
func (*CatalogDatasetInfo) GetDetails ¶
func (x *CatalogDatasetInfo) GetDetails() *DatasetDetails
func (*CatalogDatasetInfo) ProtoMessage ¶
func (*CatalogDatasetInfo) ProtoMessage()
func (*CatalogDatasetInfo) ProtoReflect ¶
func (x *CatalogDatasetInfo) ProtoReflect() protoreflect.Message
func (*CatalogDatasetInfo) Reset ¶
func (x *CatalogDatasetInfo) Reset()
func (*CatalogDatasetInfo) String ¶
func (x *CatalogDatasetInfo) String() string
type CatalogDatasetRequest ¶
type CatalogDatasetRequest struct { CredentialPath string `protobuf:"bytes,1,opt,name=credential_path,json=credentialPath,proto3" json:"credential_path,omitempty"` // link to vault plugin for reading k8s secret with user credentials DatasetId string `protobuf:"bytes,2,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"` // identifier of asset - always needed. JSON expected. Interpreted by the Connector, can contain any additional information as part of JSON // contains filtered or unexported fields }
func (*CatalogDatasetRequest) Descriptor
deprecated
func (*CatalogDatasetRequest) Descriptor() ([]byte, []int)
Deprecated: Use CatalogDatasetRequest.ProtoReflect.Descriptor instead.
func (*CatalogDatasetRequest) GetCredentialPath ¶
func (x *CatalogDatasetRequest) GetCredentialPath() string
func (*CatalogDatasetRequest) GetDatasetId ¶
func (x *CatalogDatasetRequest) GetDatasetId() string
func (*CatalogDatasetRequest) ProtoMessage ¶
func (*CatalogDatasetRequest) ProtoMessage()
func (*CatalogDatasetRequest) ProtoReflect ¶
func (x *CatalogDatasetRequest) ProtoReflect() protoreflect.Message
func (*CatalogDatasetRequest) Reset ¶
func (x *CatalogDatasetRequest) Reset()
func (*CatalogDatasetRequest) String ¶
func (x *CatalogDatasetRequest) String() string
type ComponentVersion ¶
type ComponentVersion struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*ComponentVersion) Descriptor
deprecated
func (*ComponentVersion) Descriptor() ([]byte, []int)
Deprecated: Use ComponentVersion.ProtoReflect.Descriptor instead.
func (*ComponentVersion) GetId ¶
func (x *ComponentVersion) GetId() string
func (*ComponentVersion) GetName ¶
func (x *ComponentVersion) GetName() string
func (*ComponentVersion) GetVersion ¶
func (x *ComponentVersion) GetVersion() string
func (*ComponentVersion) ProtoMessage ¶
func (*ComponentVersion) ProtoMessage()
func (*ComponentVersion) ProtoReflect ¶
func (x *ComponentVersion) ProtoReflect() protoreflect.Message
func (*ComponentVersion) Reset ¶
func (x *ComponentVersion) Reset()
func (*ComponentVersion) String ¶
func (x *ComponentVersion) String() string
type Credentials ¶
type Credentials struct { AccessKey string `protobuf:"bytes,1,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"` //access credential for the bucket where the asset is stored SecretKey string `protobuf:"bytes,2,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"` Username string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"` Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"` ApiKey string `protobuf:"bytes,5,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"` //api key assigned to the bucket in which the asset is stored ResourceInstanceId string `protobuf:"bytes,6,opt,name=resource_instance_id,json=resourceInstanceId,proto3" json:"resource_instance_id,omitempty"` //resource instance id for the bucket // contains filtered or unexported fields }
func (*Credentials) Descriptor
deprecated
func (*Credentials) Descriptor() ([]byte, []int)
Deprecated: Use Credentials.ProtoReflect.Descriptor instead.
func (*Credentials) GetAccessKey ¶
func (x *Credentials) GetAccessKey() string
func (*Credentials) GetApiKey ¶
func (x *Credentials) GetApiKey() string
func (*Credentials) GetPassword ¶
func (x *Credentials) GetPassword() string
func (*Credentials) GetResourceInstanceId ¶
func (x *Credentials) GetResourceInstanceId() string
func (*Credentials) GetSecretKey ¶
func (x *Credentials) GetSecretKey() string
func (*Credentials) GetUsername ¶
func (x *Credentials) GetUsername() 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 CredentialsInfo ¶
type CredentialsInfo struct { VaultSecretPath string `protobuf:"bytes,1,opt,name=vault_secret_path,json=vaultSecretPath,proto3" json:"vault_secret_path,omitempty"` // the path to Vault secret which is used to retrive the dataset credentials from the catalog. // contains filtered or unexported fields }
func (*CredentialsInfo) Descriptor
deprecated
func (*CredentialsInfo) Descriptor() ([]byte, []int)
Deprecated: Use CredentialsInfo.ProtoReflect.Descriptor instead.
func (*CredentialsInfo) GetVaultSecretPath ¶
func (x *CredentialsInfo) GetVaultSecretPath() string
func (*CredentialsInfo) ProtoMessage ¶
func (*CredentialsInfo) ProtoMessage()
func (*CredentialsInfo) ProtoReflect ¶
func (x *CredentialsInfo) ProtoReflect() protoreflect.Message
func (*CredentialsInfo) Reset ¶
func (x *CredentialsInfo) Reset()
func (*CredentialsInfo) String ¶
func (x *CredentialsInfo) String() string
type DataCatalogServiceClient ¶
type DataCatalogServiceClient interface { GetDatasetInfo(ctx context.Context, in *CatalogDatasetRequest, opts ...grpc.CallOption) (*CatalogDatasetInfo, error) RegisterDatasetInfo(ctx context.Context, in *RegisterAssetRequest, opts ...grpc.CallOption) (*RegisterAssetResponse, 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 { GetDatasetInfo(context.Context, *CatalogDatasetRequest) (*CatalogDatasetInfo, error) RegisterDatasetInfo(context.Context, *RegisterAssetRequest) (*RegisterAssetResponse, error) // contains filtered or unexported methods }
DataCatalogServiceServer is the server API for DataCatalogService service. All implementations must embed UnimplementedDataCatalogServiceServer for forward compatibility
type DataComponentMetadata ¶
type DataComponentMetadata struct { ComponentType string `protobuf:"bytes,1,opt,name=component_type,json=componentType,proto3" json:"component_type,omitempty"` // e.g., column //Named terms, that exist in Catalog toxonomy and the values for these terms //for columns we will have "SchemaDetails" key, that will include technical schema details for this column //TODO: Consider create special field for schema outside of metadata NamedMetadata map[string]string `` /* 188-byte string literal not displayed */ //Tags - can be any free text added to a component (no taxonomy) Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"` // contains filtered or unexported fields }
func (*DataComponentMetadata) Descriptor
deprecated
func (*DataComponentMetadata) Descriptor() ([]byte, []int)
Deprecated: Use DataComponentMetadata.ProtoReflect.Descriptor instead.
func (*DataComponentMetadata) GetComponentType ¶
func (x *DataComponentMetadata) GetComponentType() string
func (*DataComponentMetadata) GetNamedMetadata ¶
func (x *DataComponentMetadata) GetNamedMetadata() map[string]string
func (*DataComponentMetadata) GetTags ¶
func (x *DataComponentMetadata) GetTags() []string
func (*DataComponentMetadata) ProtoMessage ¶
func (*DataComponentMetadata) ProtoMessage()
func (*DataComponentMetadata) ProtoReflect ¶
func (x *DataComponentMetadata) ProtoReflect() protoreflect.Message
func (*DataComponentMetadata) Reset ¶
func (x *DataComponentMetadata) Reset()
func (*DataComponentMetadata) String ¶
func (x *DataComponentMetadata) String() string
type DataStore ¶
type DataStore struct { Type DataStore_DataStoreType `protobuf:"varint,1,opt,name=type,proto3,enum=connectors.DataStore_DataStoreType" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` //for auditing and readability. Can be same as location type or can have more info if availble from catalog // oneof location { // should have been oneof but for technical rasons, a problem to translate it to JSON, we remove the oneof for now //should have been local, db2, s3 without "location" but had a problem to compile it in proto - collision with proto name DataLocationDb2 Db2 *Db2DataStore `protobuf:"bytes,3,opt,name=db2,proto3" json:"db2,omitempty"` S3 *S3DataStore `protobuf:"bytes,4,opt,name=s3,proto3" json:"s3,omitempty"` Kafka *KafkaDataStore `protobuf:"bytes,5,opt,name=kafka,proto3" json:"kafka,omitempty"` // contains filtered or unexported fields }
func (*DataStore) Descriptor
deprecated
func (*DataStore) GetDb2 ¶
func (x *DataStore) GetDb2() *Db2DataStore
func (*DataStore) GetKafka ¶
func (x *DataStore) GetKafka() *KafkaDataStore
func (*DataStore) GetS3 ¶
func (x *DataStore) GetS3() *S3DataStore
func (*DataStore) GetType ¶
func (x *DataStore) GetType() DataStore_DataStoreType
func (*DataStore) ProtoMessage ¶
func (*DataStore) ProtoMessage()
func (*DataStore) ProtoReflect ¶
func (x *DataStore) ProtoReflect() protoreflect.Message
type DataStore_DataStoreType ¶
type DataStore_DataStoreType int32
const ( DataStore_UNKNOWN DataStore_DataStoreType = 0 DataStore_LOCAL DataStore_DataStoreType = 1 DataStore_S3 DataStore_DataStoreType = 2 DataStore_DB2 DataStore_DataStoreType = 3 DataStore_KAFKA DataStore_DataStoreType = 4 )
func (DataStore_DataStoreType) Descriptor ¶
func (DataStore_DataStoreType) Descriptor() protoreflect.EnumDescriptor
func (DataStore_DataStoreType) Enum ¶
func (x DataStore_DataStoreType) Enum() *DataStore_DataStoreType
func (DataStore_DataStoreType) EnumDescriptor
deprecated
func (DataStore_DataStoreType) EnumDescriptor() ([]byte, []int)
Deprecated: Use DataStore_DataStoreType.Descriptor instead.
func (DataStore_DataStoreType) Number ¶
func (x DataStore_DataStoreType) Number() protoreflect.EnumNumber
func (DataStore_DataStoreType) String ¶
func (x DataStore_DataStoreType) String() string
func (DataStore_DataStoreType) Type ¶
func (DataStore_DataStoreType) Type() protoreflect.EnumType
type DatasetContext ¶
type DatasetContext struct { Dataset *DatasetIdentifier `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"` Operation *AccessOperation `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"` // contains filtered or unexported fields }
func (*DatasetContext) Descriptor
deprecated
func (*DatasetContext) Descriptor() ([]byte, []int)
Deprecated: Use DatasetContext.ProtoReflect.Descriptor instead.
func (*DatasetContext) GetDataset ¶
func (x *DatasetContext) GetDataset() *DatasetIdentifier
func (*DatasetContext) GetOperation ¶
func (x *DatasetContext) GetOperation() *AccessOperation
func (*DatasetContext) ProtoMessage ¶
func (*DatasetContext) ProtoMessage()
func (*DatasetContext) ProtoReflect ¶
func (x *DatasetContext) ProtoReflect() protoreflect.Message
func (*DatasetContext) Reset ¶
func (x *DatasetContext) Reset()
func (*DatasetContext) String ¶
func (x *DatasetContext) String() string
type DatasetDecision ¶
type DatasetDecision struct { Dataset *DatasetIdentifier `protobuf:"bytes,1,opt,name=dataset,proto3" json:"dataset,omitempty"` Decisions []*OperationDecision `protobuf:"bytes,2,rep,name=decisions,proto3" json:"decisions,omitempty"` // contains filtered or unexported fields }
func (*DatasetDecision) Descriptor
deprecated
func (*DatasetDecision) Descriptor() ([]byte, []int)
Deprecated: Use DatasetDecision.ProtoReflect.Descriptor instead.
func (*DatasetDecision) GetDataset ¶
func (x *DatasetDecision) GetDataset() *DatasetIdentifier
func (*DatasetDecision) GetDecisions ¶
func (x *DatasetDecision) GetDecisions() []*OperationDecision
func (*DatasetDecision) ProtoMessage ¶
func (*DatasetDecision) ProtoMessage()
func (*DatasetDecision) ProtoReflect ¶
func (x *DatasetDecision) ProtoReflect() protoreflect.Message
func (*DatasetDecision) Reset ¶
func (x *DatasetDecision) Reset()
func (*DatasetDecision) String ¶
func (x *DatasetDecision) String() string
type DatasetDetails ¶
type DatasetDetails struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` //name in Catalog DataOwner string `protobuf:"bytes,2,opt,name=data_owner,json=dataOwner,proto3" json:"data_owner,omitempty"` //information on the owner of data asset - can have different formats for different catalogs DataStore *DataStore `protobuf:"bytes,3,opt,name=data_store,json=dataStore,proto3" json:"data_store,omitempty"` //All info about the data store DataFormat string `protobuf:"bytes,4,opt,name=data_format,json=dataFormat,proto3" json:"data_format,omitempty"` Geo string `protobuf:"bytes,5,opt,name=geo,proto3" json:"geo,omitempty"` //geography location where data resides (if this information available) //LocationType locationType = 10; //publicCloud/privateCloud etc. Should be filled later when we understand better if we have a closed set of values and how they are used. Metadata *DatasetMetadata `protobuf:"bytes,7,opt,name=metadata,proto3" json:"metadata,omitempty"` CredentialsInfo *CredentialsInfo `protobuf:"bytes,11,opt,name=credentials_info,json=credentialsInfo,proto3" json:"credentials_info,omitempty"` // information about how to retrive dataset credentials from the catalog. // contains filtered or unexported fields }
func (*DatasetDetails) Descriptor
deprecated
func (*DatasetDetails) Descriptor() ([]byte, []int)
Deprecated: Use DatasetDetails.ProtoReflect.Descriptor instead.
func (*DatasetDetails) GetCredentialsInfo ¶
func (x *DatasetDetails) GetCredentialsInfo() *CredentialsInfo
func (*DatasetDetails) GetDataFormat ¶
func (x *DatasetDetails) GetDataFormat() string
func (*DatasetDetails) GetDataOwner ¶
func (x *DatasetDetails) GetDataOwner() string
func (*DatasetDetails) GetDataStore ¶
func (x *DatasetDetails) GetDataStore() *DataStore
func (*DatasetDetails) GetGeo ¶
func (x *DatasetDetails) GetGeo() string
func (*DatasetDetails) GetMetadata ¶
func (x *DatasetDetails) GetMetadata() *DatasetMetadata
func (*DatasetDetails) GetName ¶
func (x *DatasetDetails) GetName() string
func (*DatasetDetails) ProtoMessage ¶
func (*DatasetDetails) ProtoMessage()
func (*DatasetDetails) ProtoReflect ¶
func (x *DatasetDetails) ProtoReflect() protoreflect.Message
func (*DatasetDetails) Reset ¶
func (x *DatasetDetails) Reset()
func (*DatasetDetails) String ¶
func (x *DatasetDetails) String() string
type DatasetIdentifier ¶
type DatasetIdentifier struct { DatasetId string `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"` // identifier of asset - always needed. JSON expected. Interpreted by the Connector, can contain any additional information as part of JSON // contains filtered or unexported fields }
func (*DatasetIdentifier) Descriptor
deprecated
func (*DatasetIdentifier) Descriptor() ([]byte, []int)
Deprecated: Use DatasetIdentifier.ProtoReflect.Descriptor instead.
func (*DatasetIdentifier) GetDatasetId ¶
func (x *DatasetIdentifier) GetDatasetId() string
func (*DatasetIdentifier) ProtoMessage ¶
func (*DatasetIdentifier) ProtoMessage()
func (*DatasetIdentifier) ProtoReflect ¶
func (x *DatasetIdentifier) ProtoReflect() protoreflect.Message
func (*DatasetIdentifier) Reset ¶
func (x *DatasetIdentifier) Reset()
func (*DatasetIdentifier) String ¶
func (x *DatasetIdentifier) String() string
type DatasetMetadata ¶
type DatasetMetadata struct { DatasetNamedMetadata map[string]string `` /* 211-byte string literal not displayed */ //Tags - can be any free text added to a component (no taxonomy) DatasetTags []string `protobuf:"bytes,2,rep,name=dataset_tags,json=datasetTags,proto3" json:"dataset_tags,omitempty"` //metadata for each component in asset. In tabular data each column is a component, then we will have: column name -> column metadata ComponentsMetadata map[string]*DataComponentMetadata `` /* 203-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DatasetMetadata) Descriptor
deprecated
func (*DatasetMetadata) Descriptor() ([]byte, []int)
Deprecated: Use DatasetMetadata.ProtoReflect.Descriptor instead.
func (*DatasetMetadata) GetComponentsMetadata ¶
func (x *DatasetMetadata) GetComponentsMetadata() map[string]*DataComponentMetadata
func (*DatasetMetadata) GetDatasetNamedMetadata ¶
func (x *DatasetMetadata) GetDatasetNamedMetadata() map[string]string
func (*DatasetMetadata) GetDatasetTags ¶
func (x *DatasetMetadata) GetDatasetTags() []string
func (*DatasetMetadata) ProtoMessage ¶
func (*DatasetMetadata) ProtoMessage()
func (*DatasetMetadata) ProtoReflect ¶
func (x *DatasetMetadata) ProtoReflect() protoreflect.Message
func (*DatasetMetadata) Reset ¶
func (x *DatasetMetadata) Reset()
func (*DatasetMetadata) String ¶
func (x *DatasetMetadata) String() string
type Db2DataStore ¶
type Db2DataStore struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` Database string `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"` Table string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"` // reformat to SCHEMA.TABLE struct Port string `protobuf:"bytes,4,opt,name=port,proto3" json:"port,omitempty"` Ssl string `protobuf:"bytes,5,opt,name=ssl,proto3" json:"ssl,omitempty"` //Note that bool value if set to "false" does not appear in the struct at all // contains filtered or unexported fields }
func (*Db2DataStore) Descriptor
deprecated
func (*Db2DataStore) Descriptor() ([]byte, []int)
Deprecated: Use Db2DataStore.ProtoReflect.Descriptor instead.
func (*Db2DataStore) GetDatabase ¶
func (x *Db2DataStore) GetDatabase() string
func (*Db2DataStore) GetPort ¶
func (x *Db2DataStore) GetPort() string
func (*Db2DataStore) GetSsl ¶
func (x *Db2DataStore) GetSsl() string
func (*Db2DataStore) GetTable ¶
func (x *Db2DataStore) GetTable() string
func (*Db2DataStore) GetUrl ¶
func (x *Db2DataStore) GetUrl() string
func (*Db2DataStore) ProtoMessage ¶
func (*Db2DataStore) ProtoMessage()
func (*Db2DataStore) ProtoReflect ¶
func (x *Db2DataStore) ProtoReflect() protoreflect.Message
func (*Db2DataStore) Reset ¶
func (x *Db2DataStore) Reset()
func (*Db2DataStore) String ¶
func (x *Db2DataStore) String() string
type EnforcementAction ¶
type EnforcementAction struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Level EnforcementAction_EnforcementActionLevel `protobuf:"varint,3,opt,name=level,proto3,enum=connectors.EnforcementAction_EnforcementActionLevel" json:"level,omitempty"` Args map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*EnforcementAction) Descriptor
deprecated
func (*EnforcementAction) Descriptor() ([]byte, []int)
Deprecated: Use EnforcementAction.ProtoReflect.Descriptor instead.
func (*EnforcementAction) GetArgs ¶
func (x *EnforcementAction) GetArgs() map[string]string
func (*EnforcementAction) GetId ¶
func (x *EnforcementAction) GetId() string
func (*EnforcementAction) GetLevel ¶
func (x *EnforcementAction) GetLevel() EnforcementAction_EnforcementActionLevel
func (*EnforcementAction) GetName ¶
func (x *EnforcementAction) GetName() string
func (*EnforcementAction) ProtoMessage ¶
func (*EnforcementAction) ProtoMessage()
func (*EnforcementAction) ProtoReflect ¶
func (x *EnforcementAction) ProtoReflect() protoreflect.Message
func (*EnforcementAction) Reset ¶
func (x *EnforcementAction) Reset()
func (*EnforcementAction) String ¶
func (x *EnforcementAction) String() string
type EnforcementAction_EnforcementActionLevel ¶
type EnforcementAction_EnforcementActionLevel int32
const ( EnforcementAction_UNKNOWN EnforcementAction_EnforcementActionLevel = 0 EnforcementAction_DATASET EnforcementAction_EnforcementActionLevel = 1 EnforcementAction_COLUMN EnforcementAction_EnforcementActionLevel = 2 EnforcementAction_ROW EnforcementAction_EnforcementActionLevel = 3 EnforcementAction_CELL EnforcementAction_EnforcementActionLevel = 4 )
func (EnforcementAction_EnforcementActionLevel) Descriptor ¶
func (EnforcementAction_EnforcementActionLevel) Descriptor() protoreflect.EnumDescriptor
func (EnforcementAction_EnforcementActionLevel) EnumDescriptor
deprecated
func (EnforcementAction_EnforcementActionLevel) EnumDescriptor() ([]byte, []int)
Deprecated: Use EnforcementAction_EnforcementActionLevel.Descriptor instead.
func (EnforcementAction_EnforcementActionLevel) Number ¶
func (x EnforcementAction_EnforcementActionLevel) Number() protoreflect.EnumNumber
func (EnforcementAction_EnforcementActionLevel) String ¶
func (x EnforcementAction_EnforcementActionLevel) String() string
func (EnforcementAction_EnforcementActionLevel) Type ¶
func (EnforcementAction_EnforcementActionLevel) Type() protoreflect.EnumType
type KafkaDataStore ¶
type KafkaDataStore struct { TopicName string `protobuf:"bytes,1,opt,name=topic_name,json=topicName,proto3" json:"topic_name,omitempty"` BootstrapServers string `protobuf:"bytes,2,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"` SchemaRegistry string `protobuf:"bytes,3,opt,name=schema_registry,json=schemaRegistry,proto3" json:"schema_registry,omitempty"` KeyDeserializer string `protobuf:"bytes,4,opt,name=key_deserializer,json=keyDeserializer,proto3" json:"key_deserializer,omitempty"` ValueDeserializer string `protobuf:"bytes,5,opt,name=value_deserializer,json=valueDeserializer,proto3" json:"value_deserializer,omitempty"` SecurityProtocol string `protobuf:"bytes,6,opt,name=security_protocol,json=securityProtocol,proto3" json:"security_protocol,omitempty"` SaslMechanism string `protobuf:"bytes,7,opt,name=sasl_mechanism,json=saslMechanism,proto3" json:"sasl_mechanism,omitempty"` SslTruststore string `protobuf:"bytes,8,opt,name=ssl_truststore,json=sslTruststore,proto3" json:"ssl_truststore,omitempty"` SslTruststorePassword string `` /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
func (*KafkaDataStore) Descriptor
deprecated
func (*KafkaDataStore) Descriptor() ([]byte, []int)
Deprecated: Use KafkaDataStore.ProtoReflect.Descriptor instead.
func (*KafkaDataStore) GetBootstrapServers ¶
func (x *KafkaDataStore) GetBootstrapServers() string
func (*KafkaDataStore) GetKeyDeserializer ¶
func (x *KafkaDataStore) GetKeyDeserializer() string
func (*KafkaDataStore) GetSaslMechanism ¶
func (x *KafkaDataStore) GetSaslMechanism() string
func (*KafkaDataStore) GetSchemaRegistry ¶
func (x *KafkaDataStore) GetSchemaRegistry() string
func (*KafkaDataStore) GetSecurityProtocol ¶
func (x *KafkaDataStore) GetSecurityProtocol() string
func (*KafkaDataStore) GetSslTruststore ¶
func (x *KafkaDataStore) GetSslTruststore() string
func (*KafkaDataStore) GetSslTruststorePassword ¶
func (x *KafkaDataStore) GetSslTruststorePassword() string
func (*KafkaDataStore) GetTopicName ¶
func (x *KafkaDataStore) GetTopicName() string
func (*KafkaDataStore) GetValueDeserializer ¶
func (x *KafkaDataStore) GetValueDeserializer() string
func (*KafkaDataStore) ProtoMessage ¶
func (*KafkaDataStore) ProtoMessage()
func (*KafkaDataStore) ProtoReflect ¶
func (x *KafkaDataStore) ProtoReflect() protoreflect.Message
func (*KafkaDataStore) Reset ¶
func (x *KafkaDataStore) Reset()
func (*KafkaDataStore) String ¶
func (x *KafkaDataStore) String() string
type OperationDecision ¶
type OperationDecision struct { Operation *AccessOperation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` EnforcementActions []*EnforcementAction `protobuf:"bytes,2,rep,name=enforcement_actions,json=enforcementActions,proto3" json:"enforcement_actions,omitempty"` UsedPolicies []*Policy `protobuf:"bytes,3,rep,name=used_policies,json=usedPolicies,proto3" json:"used_policies,omitempty"` // contains filtered or unexported fields }
func (*OperationDecision) Descriptor
deprecated
func (*OperationDecision) Descriptor() ([]byte, []int)
Deprecated: Use OperationDecision.ProtoReflect.Descriptor instead.
func (*OperationDecision) GetEnforcementActions ¶
func (x *OperationDecision) GetEnforcementActions() []*EnforcementAction
func (*OperationDecision) GetOperation ¶
func (x *OperationDecision) GetOperation() *AccessOperation
func (*OperationDecision) GetUsedPolicies ¶
func (x *OperationDecision) GetUsedPolicies() []*Policy
func (*OperationDecision) ProtoMessage ¶
func (*OperationDecision) ProtoMessage()
func (*OperationDecision) ProtoReflect ¶
func (x *OperationDecision) ProtoReflect() protoreflect.Message
func (*OperationDecision) Reset ¶
func (x *OperationDecision) Reset()
func (*OperationDecision) String ¶
func (x *OperationDecision) String() string
type PoliciesDecisions ¶
type PoliciesDecisions struct { ComponentVersions []*ComponentVersion `protobuf:"bytes,1,rep,name=component_versions,json=componentVersions,proto3" json:"component_versions,omitempty"` DatasetDecisions []*DatasetDecision `protobuf:"bytes,2,rep,name=dataset_decisions,json=datasetDecisions,proto3" json:"dataset_decisions,omitempty"` //one per dataset GeneralDecisions []*OperationDecision `protobuf:"bytes,3,rep,name=general_decisions,json=generalDecisions,proto3" json:"general_decisions,omitempty"` // contains filtered or unexported fields }
func (*PoliciesDecisions) Descriptor
deprecated
func (*PoliciesDecisions) Descriptor() ([]byte, []int)
Deprecated: Use PoliciesDecisions.ProtoReflect.Descriptor instead.
func (*PoliciesDecisions) GetComponentVersions ¶
func (x *PoliciesDecisions) GetComponentVersions() []*ComponentVersion
func (*PoliciesDecisions) GetDatasetDecisions ¶
func (x *PoliciesDecisions) GetDatasetDecisions() []*DatasetDecision
func (*PoliciesDecisions) GetGeneralDecisions ¶
func (x *PoliciesDecisions) GetGeneralDecisions() []*OperationDecision
func (*PoliciesDecisions) ProtoMessage ¶
func (*PoliciesDecisions) ProtoMessage()
func (*PoliciesDecisions) ProtoReflect ¶
func (x *PoliciesDecisions) ProtoReflect() protoreflect.Message
func (*PoliciesDecisions) Reset ¶
func (x *PoliciesDecisions) Reset()
func (*PoliciesDecisions) String ¶
func (x *PoliciesDecisions) 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"` Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` Hierarchy []string `protobuf:"bytes,5,rep,name=hierarchy,proto3" json:"hierarchy,omitempty"` // contains filtered or unexported fields }
func (*Policy) Descriptor
deprecated
func (*Policy) GetDescription ¶
func (*Policy) GetHierarchy ¶
func (*Policy) ProtoMessage ¶
func (*Policy) ProtoMessage()
func (*Policy) ProtoReflect ¶
func (x *Policy) ProtoReflect() protoreflect.Message
type PolicyManagerServiceClient ¶
type PolicyManagerServiceClient interface {
GetPoliciesDecisions(ctx context.Context, in *ApplicationContext, opts ...grpc.CallOption) (*PoliciesDecisions, error)
}
PolicyManagerServiceClient is the client API for PolicyManagerService 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 NewPolicyManagerServiceClient ¶
func NewPolicyManagerServiceClient(cc grpc.ClientConnInterface) PolicyManagerServiceClient
type PolicyManagerServiceServer ¶
type PolicyManagerServiceServer interface { GetPoliciesDecisions(context.Context, *ApplicationContext) (*PoliciesDecisions, error) // contains filtered or unexported methods }
PolicyManagerServiceServer is the server API for PolicyManagerService service. All implementations must embed UnimplementedPolicyManagerServiceServer for forward compatibility
type RegisterAssetRequest ¶
type RegisterAssetRequest struct { Creds *Credentials `protobuf:"bytes,1,opt,name=creds,proto3" json:"creds,omitempty"` DatasetDetails *DatasetDetails `protobuf:"bytes,2,opt,name=dataset_details,json=datasetDetails,proto3" json:"dataset_details,omitempty"` DestinationCatalogId string `protobuf:"bytes,3,opt,name=destination_catalog_id,json=destinationCatalogId,proto3" json:"destination_catalog_id,omitempty"` CredentialPath string `protobuf:"bytes,4,opt,name=credential_path,json=credentialPath,proto3" json:"credential_path,omitempty"` // link to vault plugin for reading k8s secret with user credentials // contains filtered or unexported fields }
func (*RegisterAssetRequest) Descriptor
deprecated
func (*RegisterAssetRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterAssetRequest.ProtoReflect.Descriptor instead.
func (*RegisterAssetRequest) GetCredentialPath ¶
func (x *RegisterAssetRequest) GetCredentialPath() string
func (*RegisterAssetRequest) GetCreds ¶
func (x *RegisterAssetRequest) GetCreds() *Credentials
func (*RegisterAssetRequest) GetDatasetDetails ¶
func (x *RegisterAssetRequest) GetDatasetDetails() *DatasetDetails
func (*RegisterAssetRequest) GetDestinationCatalogId ¶
func (x *RegisterAssetRequest) GetDestinationCatalogId() string
func (*RegisterAssetRequest) ProtoMessage ¶
func (*RegisterAssetRequest) ProtoMessage()
func (*RegisterAssetRequest) ProtoReflect ¶
func (x *RegisterAssetRequest) ProtoReflect() protoreflect.Message
func (*RegisterAssetRequest) Reset ¶
func (x *RegisterAssetRequest) Reset()
func (*RegisterAssetRequest) String ¶
func (x *RegisterAssetRequest) String() string
type RegisterAssetResponse ¶
type RegisterAssetResponse struct { AssetId string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"` // Returns the id of the new asset registered in a catalog // contains filtered or unexported fields }
func (*RegisterAssetResponse) Descriptor
deprecated
func (*RegisterAssetResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterAssetResponse.ProtoReflect.Descriptor instead.
func (*RegisterAssetResponse) GetAssetId ¶
func (x *RegisterAssetResponse) GetAssetId() string
func (*RegisterAssetResponse) ProtoMessage ¶
func (*RegisterAssetResponse) ProtoMessage()
func (*RegisterAssetResponse) ProtoReflect ¶
func (x *RegisterAssetResponse) ProtoReflect() protoreflect.Message
func (*RegisterAssetResponse) Reset ¶
func (x *RegisterAssetResponse) Reset()
func (*RegisterAssetResponse) String ¶
func (x *RegisterAssetResponse) String() string
type S3DataStore ¶
type S3DataStore struct { Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` Bucket string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"` ObjectKey string `protobuf:"bytes,3,opt,name=object_key,json=objectKey,proto3" json:"object_key,omitempty"` //can be object name or the prefix for dataset Region string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"` // WKC does not return it, it will stay empty in our case!!! // contains filtered or unexported fields }
func (*S3DataStore) Descriptor
deprecated
func (*S3DataStore) Descriptor() ([]byte, []int)
Deprecated: Use S3DataStore.ProtoReflect.Descriptor instead.
func (*S3DataStore) GetBucket ¶
func (x *S3DataStore) GetBucket() string
func (*S3DataStore) GetEndpoint ¶
func (x *S3DataStore) GetEndpoint() string
func (*S3DataStore) GetObjectKey ¶
func (x *S3DataStore) GetObjectKey() string
func (*S3DataStore) GetRegion ¶
func (x *S3DataStore) GetRegion() string
func (*S3DataStore) ProtoMessage ¶
func (*S3DataStore) ProtoMessage()
func (*S3DataStore) ProtoReflect ¶
func (x *S3DataStore) ProtoReflect() protoreflect.Message
func (*S3DataStore) Reset ¶
func (x *S3DataStore) Reset()
func (*S3DataStore) String ¶
func (x *S3DataStore) String() string
type UnimplementedDataCatalogServiceServer ¶
type UnimplementedDataCatalogServiceServer struct { }
UnimplementedDataCatalogServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedDataCatalogServiceServer) GetDatasetInfo ¶
func (UnimplementedDataCatalogServiceServer) GetDatasetInfo(context.Context, *CatalogDatasetRequest) (*CatalogDatasetInfo, error)
func (UnimplementedDataCatalogServiceServer) RegisterDatasetInfo ¶
func (UnimplementedDataCatalogServiceServer) RegisterDatasetInfo(context.Context, *RegisterAssetRequest) (*RegisterAssetResponse, error)
type UnimplementedPolicyManagerServiceServer ¶
type UnimplementedPolicyManagerServiceServer struct { }
UnimplementedPolicyManagerServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedPolicyManagerServiceServer) GetPoliciesDecisions ¶
func (UnimplementedPolicyManagerServiceServer) GetPoliciesDecisions(context.Context, *ApplicationContext) (*PoliciesDecisions, 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 UnsafePolicyManagerServiceServer ¶
type UnsafePolicyManagerServiceServer interface {
// contains filtered or unexported methods
}
UnsafePolicyManagerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PolicyManagerServiceServer will result in compilation errors.
Source Files ¶
- credentials.pb.go
- data_catalog_request.pb.go
- data_catalog_response.pb.go
- data_catalog_service.pb.go
- data_catalog_service_grpc.pb.go
- dataset_details.pb.go
- policy_manager_request.pb.go
- policy_manager_response.pb.go
- policy_manager_service.pb.go
- policy_manager_service_grpc.pb.go
- register_asset_request.pb.go
- register_asset_response.pb.go