datacatalogservice

Documentation

Index

• func Serve(ctx context.Context, cfg *config.Config) error
• func ServeHTTPHealthCheck(ctx context.Context, cfg *config.Config) error
• func ServeInsecure(ctx context.Context, cfg *config.Config) error
• type DataCatalogService
  • func NewDataCatalogService() *DataCatalogService
  • func (s *DataCatalogService) AddTag(ctx context.Context, request *catalog.AddTagRequest) (*catalog.AddTagResponse, error)
  • func (s *DataCatalogService) CreateArtifact(ctx context.Context, request *catalog.CreateArtifactRequest) (*catalog.CreateArtifactResponse, error)
  • func (s *DataCatalogService) CreateDataset(ctx context.Context, request *catalog.CreateDatasetRequest) (*catalog.CreateDatasetResponse, error)
  • func (s *DataCatalogService) GetArtifact(ctx context.Context, request *catalog.GetArtifactRequest) (*catalog.GetArtifactResponse, error)
  • func (s *DataCatalogService) GetDataset(ctx context.Context, request *catalog.GetDatasetRequest) (*catalog.GetDatasetResponse, error)
  • func (s *DataCatalogService) GetOrExtendReservation(ctx context.Context, request *catalog.GetOrExtendReservationRequest) (*catalog.GetOrExtendReservationResponse, error)
  • func (s *DataCatalogService) ListArtifacts(ctx context.Context, request *catalog.ListArtifactsRequest) (*catalog.ListArtifactsResponse, error)
  • func (s *DataCatalogService) ListDatasets(ctx context.Context, request *catalog.ListDatasetsRequest) (*catalog.ListDatasetsResponse, error)
  • func (s *DataCatalogService) ReleaseReservation(ctx context.Context, request *catalog.ReleaseReservationRequest) (*catalog.ReleaseReservationResponse, error)
  • func (s *DataCatalogService) UpdateArtifact(ctx context.Context, request *catalog.UpdateArtifactRequest) (*catalog.UpdateArtifactResponse, error)

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)