protobuf

package
v0.5.3 Latest Latest
Warning

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

Go to latest
Published: Jan 11, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
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)

View Source
var File_credentials_proto protoreflect.FileDescriptor
View Source
var File_data_catalog_request_proto protoreflect.FileDescriptor
View Source
var File_data_catalog_response_proto protoreflect.FileDescriptor
View Source
var File_data_catalog_service_proto protoreflect.FileDescriptor
View Source
var File_dataset_details_proto protoreflect.FileDescriptor
View Source
var File_policy_manager_request_proto protoreflect.FileDescriptor
View Source
var File_policy_manager_response_proto protoreflect.FileDescriptor
View Source
var File_policy_manager_service_proto protoreflect.FileDescriptor
View Source
var File_register_asset_request_proto protoreflect.FileDescriptor
View Source
var File_register_asset_response_proto protoreflect.FileDescriptor
View Source
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 (*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) Enum

func (AccessOperation_AccessType) EnumDescriptor deprecated

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

Deprecated: Use AccessOperation_AccessType.Descriptor instead.

func (AccessOperation_AccessType) Number

func (AccessOperation_AccessType) String

func (AccessOperation_AccessType) Type

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.

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) Descriptor() ([]byte, []int)

Deprecated: Use DataStore.ProtoReflect.Descriptor instead.

func (*DataStore) GetDb2

func (x *DataStore) GetDb2() *Db2DataStore

func (*DataStore) GetKafka

func (x *DataStore) GetKafka() *KafkaDataStore

func (*DataStore) GetName

func (x *DataStore) GetName() string

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

func (*DataStore) Reset

func (x *DataStore) Reset()

func (*DataStore) String

func (x *DataStore) String() string

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

func (DataStore_DataStoreType) EnumDescriptor deprecated

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

Deprecated: Use DataStore_DataStoreType.Descriptor instead.

func (DataStore_DataStoreType) Number

func (DataStore_DataStoreType) String

func (x DataStore_DataStoreType) String() string

func (DataStore_DataStoreType) Type

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 (*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) Enum

func (EnforcementAction_EnforcementActionLevel) EnumDescriptor deprecated

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

Deprecated: Use EnforcementAction_EnforcementActionLevel.Descriptor instead.

func (EnforcementAction_EnforcementActionLevel) Number

func (EnforcementAction_EnforcementActionLevel) String

func (EnforcementAction_EnforcementActionLevel) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Policy.ProtoReflect.Descriptor instead.

func (*Policy) GetDescription

func (x *Policy) GetDescription() string

func (*Policy) GetHierarchy

func (x *Policy) GetHierarchy() []string

func (*Policy) GetId

func (x *Policy) GetId() string

func (*Policy) GetName

func (x *Policy) GetName() string

func (*Policy) GetType

func (x *Policy) GetType() string

func (*Policy) ProtoMessage

func (*Policy) ProtoMessage()

func (*Policy) ProtoReflect

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

func (*Policy) Reset

func (x *Policy) Reset()

func (*Policy) String

func (x *Policy) String() string

type 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.

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

type UnimplementedPolicyManagerServiceServer

type UnimplementedPolicyManagerServiceServer struct {
}

UnimplementedPolicyManagerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPolicyManagerServiceServer) GetPoliciesDecisions

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.

Jump to

Keyboard shortcuts

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