datacatalogservice

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Serve 

func Serve(ctx context.Context, cfg *config.Config) error

Create and start the gRPC server and http healthcheck endpoint

func ServeHTTPHealthCheck 

func ServeHTTPHealthCheck(ctx context.Context, cfg *config.Config) error

ServeHTTPHealthCheck create a http healthcheck endpoint

func ServeInsecure 

func ServeInsecure(ctx context.Context, cfg *config.Config) error

Create and start the gRPC server

Types

type DataCatalogService 

type DataCatalogService struct {
	DatasetManager     interfaces.DatasetManager
	ArtifactManager    interfaces.ArtifactManager
	TagManager         interfaces.TagManager
	ReservationManager interfaces.ReservationManager
}

func NewDataCatalogService 

func NewDataCatalogService() *DataCatalogService

func (*DataCatalogService) AddTag 

func (s *DataCatalogService) AddTag(ctx context.Context, request *catalog.AddTagRequest) (*catalog.AddTagResponse, error)

func (*DataCatalogService) CreateArtifact 

func (s *DataCatalogService) CreateArtifact(ctx context.Context, request *catalog.CreateArtifactRequest) (*catalog.CreateArtifactResponse, error)

func (*DataCatalogService) CreateDataset 

func (s *DataCatalogService) CreateDataset(ctx context.Context, request *catalog.CreateDatasetRequest) (*catalog.CreateDatasetResponse, error)

func (*DataCatalogService) GetArtifact 

func (s *DataCatalogService) GetArtifact(ctx context.Context, request *catalog.GetArtifactRequest) (*catalog.GetArtifactResponse, error)

func (*DataCatalogService) GetDataset 

func (s *DataCatalogService) GetDataset(ctx context.Context, request *catalog.GetDatasetRequest) (*catalog.GetDatasetResponse, error)

func (*DataCatalogService) GetOrExtendReservation 

func (s *DataCatalogService) GetOrExtendReservation(ctx context.Context, request *catalog.GetOrExtendReservationRequest) (*catalog.GetOrExtendReservationResponse, error)

func (*DataCatalogService) ListArtifacts 

func (s *DataCatalogService) ListArtifacts(ctx context.Context, request *catalog.ListArtifactsRequest) (*catalog.ListArtifactsResponse, error)

func (*DataCatalogService) ListDatasets 

func (s *DataCatalogService) ListDatasets(ctx context.Context, request *catalog.ListDatasetsRequest) (*catalog.ListDatasetsResponse, error)

func (*DataCatalogService) ReleaseReservation 

func (s *DataCatalogService) ReleaseReservation(ctx context.Context, request *catalog.ReleaseReservationRequest) (*catalog.ReleaseReservationResponse, error)

func (*DataCatalogService) UpdateArtifact 

func (s *DataCatalogService) UpdateArtifact(ctx context.Context, request *catalog.UpdateArtifactRequest) (*catalog.UpdateArtifactResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.