clients

Documentation

Index

• func ConvertDataCatalogGrpcRespToOpenAPIResp(result *pb.CatalogDatasetInfo) (*datacatalog.GetAssetResponse, error)
• func ConvertDataCatalogOpenAPIReqToGrpcReq(in *datacatalog.GetAssetRequest, creds string) (*pb.CatalogDatasetRequest, error)
• type DataCatalog
  • func NewDataCatalog(catalogProviderName, catalogConnectorAddress string, ...) (DataCatalog, error)
  • func NewGrpcDataCatalog(name string, connectionURL string, connectionTimeout time.Duration) (DataCatalog, error)
  • func NewOpenAPIDataCatalog(name string, connectionURL string, connectionTimeout time.Duration) DataCatalog

Functions

func ConvertDataCatalogGrpcRespToOpenAPIResp

func ConvertDataCatalogGrpcRespToOpenAPIResp(result *pb.CatalogDatasetInfo) (*datacatalog.GetAssetResponse, error)

func ConvertDataCatalogOpenAPIReqToGrpcReq

func ConvertDataCatalogOpenAPIReqToGrpcReq(in *datacatalog.GetAssetRequest, creds string) (*pb.CatalogDatasetRequest, error)

Types

type DataCatalog

type DataCatalog interface {
	GetAssetInfo(in *datacatalog.GetAssetRequest, creds string) (*datacatalog.GetAssetResponse, error)
	io.Closer
}

DataCatalog is an interface of a facade to a data catalog.

func NewDataCatalog

func NewDataCatalog(catalogProviderName, catalogConnectorAddress string, connectionTimeout time.Duration) (DataCatalog, error)

func NewGrpcDataCatalog

func NewGrpcDataCatalog(name string, connectionURL string, connectionTimeout time.Duration) (DataCatalog, error)

NewGrpcDataCatalog creates a DataCatalog facade that connects to a GRPC service You must call .Close() when you are done using the created instance

func NewOpenAPIDataCatalog

func NewOpenAPIDataCatalog(name string, connectionURL string, connectionTimeout time.Duration) DataCatalog

NewopenApiDataCatalog creates a DataCatalog facade that connects to a openApi service