mockup

Documentation

Index

• Constants
• type ClusterLister
  • func (m *ClusterLister) GetClusters() ([]multicluster.Cluster, error)
  • func (m *ClusterLister) IsMultiClusterSetup() bool
• type DataCatalogDummy
  • func NewTestCatalog() *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
  • func (m *MockPolicyManager) GetPoliciesDecisions(input *policymanager.GetPolicyDecisionsRequest, creds string) (*policymanager.GetPolicyDecisionsResponse, error)

Constants

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

const (
	DenyAction   = "Deny"
	RedactAction = "RedactAction"
	FilterAction = "FilterAction"
)

const (
	VaultAuthPath = "kubernetes"
)

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

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

func (d *DataCatalogDummy) CreateAsset(in *datacatalog.CreateAssetRequest, creds string) (*datacatalog.CreateAssetResponse, error)

func (*DataCatalogDummy) DeleteAsset

func (d *DataCatalogDummy) DeleteAsset(in *datacatalog.DeleteAssetRequest, creds string) (*datacatalog.DeleteAssetResponse, error)

func (*DataCatalogDummy) GetAssetInfo

func (d *DataCatalogDummy) GetAssetInfo(in *datacatalog.GetAssetRequest, creds string) (*datacatalog.GetAssetResponse, error)

func (*DataCatalogDummy) UpdateAsset

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