Documentation
¶
Index ¶
- Constants
- type ClusterLister
- type DataCatalogDummy
- func (d *DataCatalogDummy) Close() error
- func (d *DataCatalogDummy) CreateAsset(in *datacatalog.CreateAssetRequest, creds string) (*datacatalog.CreateAssetResponse, error)
- func (d *DataCatalogDummy) DeleteAsset(in *datacatalog.DeleteAssetRequest, creds string) (*datacatalog.DeleteAssetResponse, error)
- func (d *DataCatalogDummy) GetAssetInfo(in *datacatalog.GetAssetRequest, creds string) (*datacatalog.GetAssetResponse, error)
- func (m *DataCatalogDummy) UpdateAsset(in *datacatalog.UpdateAssetRequest, creds string) (*datacatalog.UpdateAssetResponse, error)
- type MockPolicyManager
Constants ¶
View Source
const ( S3 taxonomy.ConnectionType = "s3" Kafka taxonomy.ConnectionType = "kafka" JdbcDB2 taxonomy.ConnectionType = "db2" ArrowFlight taxonomy.ConnectionType = "fybrik-arrow-flight" Parquet taxonomy.DataFormat = "parquet" CSV taxonomy.DataFormat = "csv" )
connection types and formats used in tests and mockup connectors
View Source
const ( DenyAction = "Deny" RedactAction = "RedactAction" FilterAction = "FilterAction" )
View Source
const (
VaultAuthPath = "kubernetes"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterLister ¶
type ClusterLister struct {
}
ClusterLister is a mockup cluster manager
func (*ClusterLister) GetClusters ¶
func (m *ClusterLister) GetClusters() ([]multicluster.Cluster, error)
GetClusters returns the cluster config for testing
func (*ClusterLister) IsMultiClusterSetup ¶ added in v1.0.0
func (m *ClusterLister) IsMultiClusterSetup() bool
type DataCatalogDummy ¶
type DataCatalogDummy struct {
// contains filtered or unexported fields
}
func NewTestCatalog ¶
func NewTestCatalog() *DataCatalogDummy
func (*DataCatalogDummy) Close ¶
func (d *DataCatalogDummy) Close() error
func (*DataCatalogDummy) CreateAsset ¶ added in v0.7.0
func (d *DataCatalogDummy) CreateAsset(in *datacatalog.CreateAssetRequest, creds string) (*datacatalog.CreateAssetResponse, error)
func (*DataCatalogDummy) DeleteAsset ¶ added in v0.7.0
func (d *DataCatalogDummy) DeleteAsset(in *datacatalog.DeleteAssetRequest, creds string) (*datacatalog.DeleteAssetResponse, error)
func (*DataCatalogDummy) GetAssetInfo ¶ added in v0.6.0
func (d *DataCatalogDummy) GetAssetInfo(in *datacatalog.GetAssetRequest, creds string) (*datacatalog.GetAssetResponse, error)
func (*DataCatalogDummy) UpdateAsset ¶ added in v0.7.0
func (m *DataCatalogDummy) UpdateAsset(in *datacatalog.UpdateAssetRequest, creds string) (*datacatalog.UpdateAssetResponse, error)
type MockPolicyManager ¶
type MockPolicyManager struct {
connectors.PolicyManager
}
MockPolicyManager is a mock for PolicyManager interface used in tests
func (*MockPolicyManager) GetPoliciesDecisions ¶
func (m *MockPolicyManager) GetPoliciesDecisions(input *policymanager.GetPolicyDecisionsRequest, creds string) (*policymanager.GetPolicyDecisionsResponse, error)
GetPoliciesDecisions implements the PolicyCompiler interface
Source Files
Click to show internal directories.
Click to hide internal directories.