api

package
v0.1.8-alpha Latest Latest
Warning

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

 Go to latest Published: Sep 6, 2020 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_AuthAPI_proto protoreflect.FileDescriptor
View Source 
var File_proto_DatasetAPI_proto protoreflect.FileDescriptor
View Source 
var File_proto_LoadAPI_proto protoreflect.FileDescriptor
View Source 
var File_proto_MetadataAPI_proto protoreflect.FileDescriptor
View Source 
var File_proto_ProjectAPI_proto protoreflect.FileDescriptor

Functions

func RegisterAPITokenServiceHandler 

func RegisterAPITokenServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterAPITokenServiceHandler registers the http handlers for service APITokenService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterAPITokenServiceHandlerClient 

func RegisterAPITokenServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client APITokenServiceClient) error

RegisterAPITokenServiceHandlerClient registers the http handlers for service APITokenService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "APITokenServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "APITokenServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "APITokenServiceClient" to call the correct interceptors.

func RegisterAPITokenServiceHandlerFromEndpoint 

func RegisterAPITokenServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterAPITokenServiceHandlerFromEndpoint is same as RegisterAPITokenServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterAPITokenServiceHandlerServer 

func RegisterAPITokenServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server APITokenServiceServer) error

RegisterAPITokenServiceHandlerServer registers the http handlers for service APITokenService to "mux". UnaryRPC :call APITokenServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterAPITokenServiceHandlerFromEndpoint instead.

func RegisterAPITokenServiceServer 

func RegisterAPITokenServiceServer(s *grpc.Server, srv APITokenServiceServer)

func RegisterDatasetServiceHandler 

func RegisterDatasetServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDatasetServiceHandler registers the http handlers for service DatasetService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDatasetServiceHandlerClient 

func RegisterDatasetServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DatasetServiceClient) error

RegisterDatasetServiceHandlerClient registers the http handlers for service DatasetService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DatasetServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DatasetServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DatasetServiceClient" to call the correct interceptors.

func RegisterDatasetServiceHandlerFromEndpoint 

func RegisterDatasetServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDatasetServiceHandlerFromEndpoint is same as RegisterDatasetServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDatasetServiceHandlerServer 

func RegisterDatasetServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DatasetServiceServer) error

RegisterDatasetServiceHandlerServer registers the http handlers for service DatasetService to "mux". UnaryRPC :call DatasetServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterDatasetServiceHandlerFromEndpoint instead.

func RegisterDatasetServiceServer 

func RegisterDatasetServiceServer(s *grpc.Server, srv DatasetServiceServer)

func RegisterLoadServiceHandler 

func RegisterLoadServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterLoadServiceHandler registers the http handlers for service LoadService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterLoadServiceHandlerClient 

func RegisterLoadServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LoadServiceClient) error

RegisterLoadServiceHandlerClient registers the http handlers for service LoadService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "LoadServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "LoadServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "LoadServiceClient" to call the correct interceptors.

func RegisterLoadServiceHandlerFromEndpoint 

func RegisterLoadServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterLoadServiceHandlerFromEndpoint is same as RegisterLoadServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterLoadServiceHandlerServer 

func RegisterLoadServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LoadServiceServer) error

RegisterLoadServiceHandlerServer registers the http handlers for service LoadService to "mux". UnaryRPC :call LoadServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterLoadServiceHandlerFromEndpoint instead.

func RegisterLoadServiceServer 

func RegisterLoadServiceServer(s *grpc.Server, srv LoadServiceServer)

func RegisterMetadataCompositeStoreHandler 

func RegisterMetadataCompositeStoreHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterMetadataCompositeStoreHandler registers the http handlers for service MetadataCompositeStore to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterMetadataCompositeStoreHandlerClient 

func RegisterMetadataCompositeStoreHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MetadataCompositeStoreClient) error

RegisterMetadataCompositeStoreHandlerClient registers the http handlers for service MetadataCompositeStore to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "MetadataCompositeStoreClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "MetadataCompositeStoreClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "MetadataCompositeStoreClient" to call the correct interceptors.

func RegisterMetadataCompositeStoreHandlerFromEndpoint 

func RegisterMetadataCompositeStoreHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterMetadataCompositeStoreHandlerFromEndpoint is same as RegisterMetadataCompositeStoreHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterMetadataCompositeStoreHandlerServer 

func RegisterMetadataCompositeStoreHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MetadataCompositeStoreServer) error

RegisterMetadataCompositeStoreHandlerServer registers the http handlers for service MetadataCompositeStore to "mux". UnaryRPC :call MetadataCompositeStoreServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterMetadataCompositeStoreHandlerFromEndpoint instead.

func RegisterMetadataCompositeStoreServer 

func RegisterMetadataCompositeStoreServer(s *grpc.Server, srv MetadataCompositeStoreServer)

func RegisterObjectsServiceHandler 

func RegisterObjectsServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterObjectsServiceHandler registers the http handlers for service ObjectsService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterObjectsServiceHandlerClient 

func RegisterObjectsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ObjectsServiceClient) error

RegisterObjectsServiceHandlerClient registers the http handlers for service ObjectsService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ObjectsServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ObjectsServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ObjectsServiceClient" to call the correct interceptors.

func RegisterObjectsServiceHandlerFromEndpoint 

func RegisterObjectsServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterObjectsServiceHandlerFromEndpoint is same as RegisterObjectsServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterObjectsServiceHandlerServer 

func RegisterObjectsServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ObjectsServiceServer) error

RegisterObjectsServiceHandlerServer registers the http handlers for service ObjectsService to "mux". UnaryRPC :call ObjectsServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterObjectsServiceHandlerFromEndpoint instead.

func RegisterObjectsServiceServer 

func RegisterObjectsServiceServer(s *grpc.Server, srv ObjectsServiceServer)

func RegisterProjectAPIHandler 

func RegisterProjectAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterProjectAPIHandler registers the http handlers for service ProjectAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterProjectAPIHandlerClient 

func RegisterProjectAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProjectAPIClient) error

RegisterProjectAPIHandlerClient registers the http handlers for service ProjectAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ProjectAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ProjectAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ProjectAPIClient" to call the correct interceptors.

func RegisterProjectAPIHandlerFromEndpoint 

func RegisterProjectAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterProjectAPIHandlerFromEndpoint is same as RegisterProjectAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterProjectAPIHandlerServer 

func RegisterProjectAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProjectAPIServer) error

RegisterProjectAPIHandlerServer registers the http handlers for service ProjectAPI to "mux". UnaryRPC :call ProjectAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterProjectAPIHandlerFromEndpoint instead.

func RegisterProjectAPIServer 

func RegisterProjectAPIServer(s *grpc.Server, srv ProjectAPIServer)

Types

type APITokenServiceClient 

type APITokenServiceClient interface {
	// CreateAPIToken Creates a new API token and returns it
	CreateAPIToken(ctx context.Context, in *authmodels.CreateTokenRequest, opts ...grpc.CallOption) (*authmodels.TokenEntry, error)
	// GetTokenList Lists all available access tokens
	GetTokenList(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*authmodels.TokenList, error)
	// RevokeToken Revokes an access token
	RevokeToken(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*commonmodels.Empty, error)
}

APITokenServiceClient is the client API for APITokenService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAPITokenServiceClient 

func NewAPITokenServiceClient(cc grpc.ClientConnInterface) APITokenServiceClient

type APITokenServiceServer 

type APITokenServiceServer interface {
	// CreateAPIToken Creates a new API token and returns it
	CreateAPIToken(context.Context, *authmodels.CreateTokenRequest) (*authmodels.TokenEntry, error)
	// GetTokenList Lists all available access tokens
	GetTokenList(context.Context, *commonmodels.ID) (*authmodels.TokenList, error)
	// RevokeToken Revokes an access token
	RevokeToken(context.Context, *commonmodels.ID) (*commonmodels.Empty, error)
}

APITokenServiceServer is the server API for APITokenService service.

type DatasetServiceClient 

type DatasetServiceClient interface {
	// CreateNewDataset Creates a new dataset and associates it with a dataset
	CreateNewDataset(ctx context.Context, in *datasetmodels.CreateDatasetRequest, opts ...grpc.CallOption) (*datasetentrymodels.DatasetEntry, error)
	// Datasets Lists all datasets of a user
	Datasets(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*datasetmodels.DatasetList, error)
	// Lists Versions of a dataset
	DatasetVersions(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*datasetmodels.DatasetVersionList, error)
	// Updates a field of a dataset
	UpdateDatasetField(ctx context.Context, in *datasetmodels.UpdateFieldsRequest, opts ...grpc.CallOption) (*datasetentrymodels.DatasetEntry, error)
	// Updates the current dataset version of a dataset
	UpdateCurrentDatasetVersion(ctx context.Context, in *datasetmodels.UpdateCurrentDatasetVersionRequest, opts ...grpc.CallOption) (*datasetentrymodels.DatasetEntry, error)
	// DeleteDataset Delete a dataset
	// Datasets can only be deleted if
	DeleteDataset(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*commonmodels.Empty, error)
	// Creates a new dataset version which is linked to an exisiting dataset
	CreateNewDatasetVersion(ctx context.Context, in *datasetmodels.CreateDatasetVersionRequest, opts ...grpc.CallOption) (*datasetentrymodels.DatasetVersionEntry, error)
	GetDatasetVersion(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*datasetentrymodels.DatasetVersionEntry, error)
	UpdateDatasetVersionField(ctx context.Context, in *datasetmodels.UpdateFieldsRequest, opts ...grpc.CallOption) (*datasetentrymodels.DatasetEntry, error)
	// Deletes a dataset version
	// This should not delete the underlaying dataset objects
	DeleteDatasetVersion(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*commonmodels.Empty, error)
	//DatasetVersionObjectGroups Lists all objects groups that are part of the given dataset version
	DatasetVersionObjectGroups(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*datasetmodels.DatasetObjectGroupList, error)
}

DatasetServiceClient is the client API for DatasetService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDatasetServiceClient 

func NewDatasetServiceClient(cc grpc.ClientConnInterface) DatasetServiceClient

type DatasetServiceServer 

type DatasetServiceServer interface {
	// CreateNewDataset Creates a new dataset and associates it with a dataset
	CreateNewDataset(context.Context, *datasetmodels.CreateDatasetRequest) (*datasetentrymodels.DatasetEntry, error)
	// Datasets Lists all datasets of a user
	Datasets(context.Context, *commonmodels.ID) (*datasetmodels.DatasetList, error)
	// Lists Versions of a dataset
	DatasetVersions(context.Context, *commonmodels.ID) (*datasetmodels.DatasetVersionList, error)
	// Updates a field of a dataset
	UpdateDatasetField(context.Context, *datasetmodels.UpdateFieldsRequest) (*datasetentrymodels.DatasetEntry, error)
	// Updates the current dataset version of a dataset
	UpdateCurrentDatasetVersion(context.Context, *datasetmodels.UpdateCurrentDatasetVersionRequest) (*datasetentrymodels.DatasetEntry, error)
	// DeleteDataset Delete a dataset
	// Datasets can only be deleted if
	DeleteDataset(context.Context, *commonmodels.ID) (*commonmodels.Empty, error)
	// Creates a new dataset version which is linked to an exisiting dataset
	CreateNewDatasetVersion(context.Context, *datasetmodels.CreateDatasetVersionRequest) (*datasetentrymodels.DatasetVersionEntry, error)
	GetDatasetVersion(context.Context, *commonmodels.ID) (*datasetentrymodels.DatasetVersionEntry, error)
	UpdateDatasetVersionField(context.Context, *datasetmodels.UpdateFieldsRequest) (*datasetentrymodels.DatasetEntry, error)
	// Deletes a dataset version
	// This should not delete the underlaying dataset objects
	DeleteDatasetVersion(context.Context, *commonmodels.ID) (*commonmodels.Empty, error)
	//DatasetVersionObjectGroups Lists all objects groups that are part of the given dataset version
	DatasetVersionObjectGroups(context.Context, *commonmodels.ID) (*datasetmodels.DatasetObjectGroupList, error)
}

DatasetServiceServer is the server API for DatasetService service.

type LoadServiceClient 

type LoadServiceClient interface {
	// Creates a list of upload links to place dataset entities in object storage
	// and adds corresponding metadata objects
	GetUploadLink(ctx context.Context, in *loadmodels.CreateUploadLinkRequest, opts ...grpc.CallOption) (*loadmodels.CreateUploadLinkResponse, error)
	InitMultipartUpload(ctx context.Context, in *loadmodels.InitMultipartUploadRequest, opts ...grpc.CallOption) (*commonmodels.Empty, error)
	GetMultipartUploadLinkPart(ctx context.Context, in *loadmodels.GetMultipartUploadLinkPartRequest, opts ...grpc.CallOption) (*loadmodels.GetMultipartUploadLinkPartResponse, error)
	FinishMultipartUpload(ctx context.Context, in *loadmodels.FinishMultipartUploadRequest, opts ...grpc.CallOption) (*commonmodels.Empty, error)
	GetDownloadLinks(ctx context.Context, in *loadmodels.GetDownloadRequest, opts ...grpc.CallOption) (*loadmodels.GetDownloadResponse, error)
}

LoadServiceClient is the client API for LoadService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLoadServiceClient 

func NewLoadServiceClient(cc grpc.ClientConnInterface) LoadServiceClient

type LoadServiceServer 

type LoadServiceServer interface {
	// Creates a list of upload links to place dataset entities in object storage
	// and adds corresponding metadata objects
	GetUploadLink(context.Context, *loadmodels.CreateUploadLinkRequest) (*loadmodels.CreateUploadLinkResponse, error)
	InitMultipartUpload(context.Context, *loadmodels.InitMultipartUploadRequest) (*commonmodels.Empty, error)
	GetMultipartUploadLinkPart(context.Context, *loadmodels.GetMultipartUploadLinkPartRequest) (*loadmodels.GetMultipartUploadLinkPartResponse, error)
	FinishMultipartUpload(context.Context, *loadmodels.FinishMultipartUploadRequest) (*commonmodels.Empty, error)
	GetDownloadLinks(context.Context, *loadmodels.GetDownloadRequest) (*loadmodels.GetDownloadResponse, error)
}

LoadServiceServer is the server API for LoadService service.

type MetadataCompositeStoreClient 

type MetadataCompositeStoreClient interface {
	CreateMetadataDB(ctx context.Context, in *metadatamodels.InitMetadataDBRequest, opts ...grpc.CallOption) (*metadatamodels.MetadataDBEntry, error)
	ListMetadataDBs(ctx context.Context, in *commonmodels.Empty, opts ...grpc.CallOption) (*metadatamodels.MetadataDBList, error)
	CreateMetadataDBCollection(ctx context.Context, in *metadatamodels.InitMetadataCollectionRequest, opts ...grpc.CallOption) (*metadatamodels.MetadataDBEntry, error)
	ListMetadataDBCollections(ctx context.Context, in *commonmodels.Empty, opts ...grpc.CallOption) (*metadatamodels.MetadataDBCollectionList, error)
	InsertMetadata(ctx context.Context, in *metadatamodels.InsertMetadataRequest, opts ...grpc.CallOption) (*commonmodels.Empty, error)
	AddMetadataIndex(ctx context.Context, in *metadatamodels.AddMetadataIndexRequest, opts ...grpc.CallOption) (*commonmodels.Empty, error)
	Query(ctx context.Context, in *metadatamodels.QueryRequest, opts ...grpc.CallOption) (*metadatamodels.Field, error)
}

MetadataCompositeStoreClient is the client API for MetadataCompositeStore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetadataCompositeStoreClient 

func NewMetadataCompositeStoreClient(cc grpc.ClientConnInterface) MetadataCompositeStoreClient

type MetadataCompositeStoreServer 

type MetadataCompositeStoreServer interface {
	CreateMetadataDB(context.Context, *metadatamodels.InitMetadataDBRequest) (*metadatamodels.MetadataDBEntry, error)
	ListMetadataDBs(context.Context, *commonmodels.Empty) (*metadatamodels.MetadataDBList, error)
	CreateMetadataDBCollection(context.Context, *metadatamodels.InitMetadataCollectionRequest) (*metadatamodels.MetadataDBEntry, error)
	ListMetadataDBCollections(context.Context, *commonmodels.Empty) (*metadatamodels.MetadataDBCollectionList, error)
	InsertMetadata(context.Context, *metadatamodels.InsertMetadataRequest) (*commonmodels.Empty, error)
	AddMetadataIndex(context.Context, *metadatamodels.AddMetadataIndexRequest) (*commonmodels.Empty, error)
	Query(context.Context, *metadatamodels.QueryRequest) (*metadatamodels.Field, error)
}

MetadataCompositeStoreServer is the server API for MetadataCompositeStore service.

type ObjectsServiceClient 

type ObjectsServiceClient interface {
	//CreateDatsetObjectGroup Creates a new dataset object group in the database
	//Will also create all related dataset objects
	CreateDatsetObjectGroup(ctx context.Context, in *datasetmodels.CreateDatasetObjectGroupRequest, opts ...grpc.CallOption) (*datasetentrymodels.DatasetObjectGroup, error)
	//DatasetVersionObjectGroups Lists all objects groups that are part of the given dataset version
	DatasetVersionObjectGroups(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*datasetmodels.DatasetObjectGroupList, error)
	//GetDatasetObjectGroup The dataset object group with the given ID
	//Will only return a dataset object group without its affiliated objects
	GetDatasetObjectGroup(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*datasetentrymodels.DatasetObjectGroup, error)
	//DeleteDatasetObjectGroup Deletes the given dataset group and all associated dataset objects
	//Can only be used when all linked dataset versions have been deleted
	DeleteDatasetObjectGroup(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*commonmodels.Empty, error)
}

ObjectsServiceClient is the client API for ObjectsService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewObjectsServiceClient 

func NewObjectsServiceClient(cc grpc.ClientConnInterface) ObjectsServiceClient

type ObjectsServiceServer 

type ObjectsServiceServer interface {
	//CreateDatsetObjectGroup Creates a new dataset object group in the database
	//Will also create all related dataset objects
	CreateDatsetObjectGroup(context.Context, *datasetmodels.CreateDatasetObjectGroupRequest) (*datasetentrymodels.DatasetObjectGroup, error)
	//DatasetVersionObjectGroups Lists all objects groups that are part of the given dataset version
	DatasetVersionObjectGroups(context.Context, *commonmodels.ID) (*datasetmodels.DatasetObjectGroupList, error)
	//GetDatasetObjectGroup The dataset object group with the given ID
	//Will only return a dataset object group without its affiliated objects
	GetDatasetObjectGroup(context.Context, *commonmodels.ID) (*datasetentrymodels.DatasetObjectGroup, error)
	//DeleteDatasetObjectGroup Deletes the given dataset group and all associated dataset objects
	//Can only be used when all linked dataset versions have been deleted
	DeleteDatasetObjectGroup(context.Context, *commonmodels.ID) (*commonmodels.Empty, error)
}

ObjectsServiceServer is the server API for ObjectsService service.

type ProjectAPIClient 

type ProjectAPIClient interface {
	CreateProject(ctx context.Context, in *projectmodels.CreateProjectRequest, opts ...grpc.CallOption) (*projectmodels.ProjectEntry, error)
	AddUserToProject(ctx context.Context, in *projectmodels.AddUserToProjectRequest, opts ...grpc.CallOption) (*projectmodels.ProjectEntry, error)
	GetProjectDatasets(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*datasetmodels.DatasetList, error)
	GetUserProjects(ctx context.Context, in *commonmodels.Empty, opts ...grpc.CallOption) (*projectmodels.ProjectEntryList, error)
	DeleteProject(ctx context.Context, in *commonmodels.ID, opts ...grpc.CallOption) (*commonmodels.Empty, error)
}

ProjectAPIClient is the client API for ProjectAPI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProjectAPIClient 

func NewProjectAPIClient(cc grpc.ClientConnInterface) ProjectAPIClient

type ProjectAPIServer 

type ProjectAPIServer interface {
	CreateProject(context.Context, *projectmodels.CreateProjectRequest) (*projectmodels.ProjectEntry, error)
	AddUserToProject(context.Context, *projectmodels.AddUserToProjectRequest) (*projectmodels.ProjectEntry, error)
	GetProjectDatasets(context.Context, *commonmodels.ID) (*datasetmodels.DatasetList, error)
	GetUserProjects(context.Context, *commonmodels.Empty) (*projectmodels.ProjectEntryList, error)
	DeleteProject(context.Context, *commonmodels.ID) (*commonmodels.Empty, error)
}

ProjectAPIServer is the server API for ProjectAPI service.

type UnimplementedAPITokenServiceServer 

type UnimplementedAPITokenServiceServer struct {
}

UnimplementedAPITokenServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPITokenServiceServer) CreateAPIToken 

func (*UnimplementedAPITokenServiceServer) CreateAPIToken(context.Context, *authmodels.CreateTokenRequest) (*authmodels.TokenEntry, error)

func (*UnimplementedAPITokenServiceServer) GetTokenList 

func (*UnimplementedAPITokenServiceServer) GetTokenList(context.Context, *commonmodels.ID) (*authmodels.TokenList, error)

func (*UnimplementedAPITokenServiceServer) RevokeToken 

func (*UnimplementedAPITokenServiceServer) RevokeToken(context.Context, *commonmodels.ID) (*commonmodels.Empty, error)

type UnimplementedDatasetServiceServer 

type UnimplementedDatasetServiceServer struct {
}

UnimplementedDatasetServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDatasetServiceServer) CreateNewDataset 

func (*UnimplementedDatasetServiceServer) CreateNewDataset(context.Context, *datasetmodels.CreateDatasetRequest) (*datasetentrymodels.DatasetEntry, error)

func (*UnimplementedDatasetServiceServer) CreateNewDatasetVersion 

func (*UnimplementedDatasetServiceServer) CreateNewDatasetVersion(context.Context, *datasetmodels.CreateDatasetVersionRequest) (*datasetentrymodels.DatasetVersionEntry, error)

func (*UnimplementedDatasetServiceServer) DatasetVersionObjectGroups 

func (*UnimplementedDatasetServiceServer) DatasetVersionObjectGroups(context.Context, *commonmodels.ID) (*datasetmodels.DatasetObjectGroupList, error)

func (*UnimplementedDatasetServiceServer) DatasetVersions 

func (*UnimplementedDatasetServiceServer) DatasetVersions(context.Context, *commonmodels.ID) (*datasetmodels.DatasetVersionList, error)

func (*UnimplementedDatasetServiceServer) Datasets 

func (*UnimplementedDatasetServiceServer) Datasets(context.Context, *commonmodels.ID) (*datasetmodels.DatasetList, error)

func (*UnimplementedDatasetServiceServer) DeleteDataset 

func (*UnimplementedDatasetServiceServer) DeleteDataset(context.Context, *commonmodels.ID) (*commonmodels.Empty, error)

func (*UnimplementedDatasetServiceServer) DeleteDatasetVersion 

func (*UnimplementedDatasetServiceServer) DeleteDatasetVersion(context.Context, *commonmodels.ID) (*commonmodels.Empty, error)

func (*UnimplementedDatasetServiceServer) GetDatasetVersion 

func (*UnimplementedDatasetServiceServer) GetDatasetVersion(context.Context, *commonmodels.ID) (*datasetentrymodels.DatasetVersionEntry, error)

func (*UnimplementedDatasetServiceServer) UpdateCurrentDatasetVersion 

func (*UnimplementedDatasetServiceServer) UpdateCurrentDatasetVersion(context.Context, *datasetmodels.UpdateCurrentDatasetVersionRequest) (*datasetentrymodels.DatasetEntry, error)

func (*UnimplementedDatasetServiceServer) UpdateDatasetField 

func (*UnimplementedDatasetServiceServer) UpdateDatasetField(context.Context, *datasetmodels.UpdateFieldsRequest) (*datasetentrymodels.DatasetEntry, error)

func (*UnimplementedDatasetServiceServer) UpdateDatasetVersionField 

func (*UnimplementedDatasetServiceServer) UpdateDatasetVersionField(context.Context, *datasetmodels.UpdateFieldsRequest) (*datasetentrymodels.DatasetEntry, error)

type UnimplementedLoadServiceServer 

type UnimplementedLoadServiceServer struct {
}

UnimplementedLoadServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedLoadServiceServer) FinishMultipartUpload 

func (*UnimplementedLoadServiceServer) FinishMultipartUpload(context.Context, *loadmodels.FinishMultipartUploadRequest) (*commonmodels.Empty, error)
func (*UnimplementedLoadServiceServer) GetDownloadLinks(context.Context, *loadmodels.GetDownloadRequest) (*loadmodels.GetDownloadResponse, error)

func (*UnimplementedLoadServiceServer) GetMultipartUploadLinkPart 

func (*UnimplementedLoadServiceServer) GetMultipartUploadLinkPart(context.Context, *loadmodels.GetMultipartUploadLinkPartRequest) (*loadmodels.GetMultipartUploadLinkPartResponse, error)
func (*UnimplementedLoadServiceServer) GetUploadLink(context.Context, *loadmodels.CreateUploadLinkRequest) (*loadmodels.CreateUploadLinkResponse, error)

func (*UnimplementedLoadServiceServer) InitMultipartUpload 

func (*UnimplementedLoadServiceServer) InitMultipartUpload(context.Context, *loadmodels.InitMultipartUploadRequest) (*commonmodels.Empty, error)

type UnimplementedMetadataCompositeStoreServer 

type UnimplementedMetadataCompositeStoreServer struct {
}

UnimplementedMetadataCompositeStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetadataCompositeStoreServer) AddMetadataIndex 

func (*UnimplementedMetadataCompositeStoreServer) AddMetadataIndex(context.Context, *metadatamodels.AddMetadataIndexRequest) (*commonmodels.Empty, error)

func (*UnimplementedMetadataCompositeStoreServer) CreateMetadataDB 

func (*UnimplementedMetadataCompositeStoreServer) CreateMetadataDB(context.Context, *metadatamodels.InitMetadataDBRequest) (*metadatamodels.MetadataDBEntry, error)

func (*UnimplementedMetadataCompositeStoreServer) CreateMetadataDBCollection 

func (*UnimplementedMetadataCompositeStoreServer) CreateMetadataDBCollection(context.Context, *metadatamodels.InitMetadataCollectionRequest) (*metadatamodels.MetadataDBEntry, error)

func (*UnimplementedMetadataCompositeStoreServer) InsertMetadata 

func (*UnimplementedMetadataCompositeStoreServer) InsertMetadata(context.Context, *metadatamodels.InsertMetadataRequest) (*commonmodels.Empty, error)

func (*UnimplementedMetadataCompositeStoreServer) ListMetadataDBCollections 

func (*UnimplementedMetadataCompositeStoreServer) ListMetadataDBCollections(context.Context, *commonmodels.Empty) (*metadatamodels.MetadataDBCollectionList, error)

func (*UnimplementedMetadataCompositeStoreServer) ListMetadataDBs 

func (*UnimplementedMetadataCompositeStoreServer) ListMetadataDBs(context.Context, *commonmodels.Empty) (*metadatamodels.MetadataDBList, error)

func (*UnimplementedMetadataCompositeStoreServer) Query 

func (*UnimplementedMetadataCompositeStoreServer) Query(context.Context, *metadatamodels.QueryRequest) (*metadatamodels.Field, error)

type UnimplementedObjectsServiceServer 

type UnimplementedObjectsServiceServer struct {
}

UnimplementedObjectsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedObjectsServiceServer) CreateDatsetObjectGroup 

func (*UnimplementedObjectsServiceServer) CreateDatsetObjectGroup(context.Context, *datasetmodels.CreateDatasetObjectGroupRequest) (*datasetentrymodels.DatasetObjectGroup, error)

func (*UnimplementedObjectsServiceServer) DatasetVersionObjectGroups 

func (*UnimplementedObjectsServiceServer) DatasetVersionObjectGroups(context.Context, *commonmodels.ID) (*datasetmodels.DatasetObjectGroupList, error)

func (*UnimplementedObjectsServiceServer) DeleteDatasetObjectGroup 

func (*UnimplementedObjectsServiceServer) DeleteDatasetObjectGroup(context.Context, *commonmodels.ID) (*commonmodels.Empty, error)

func (*UnimplementedObjectsServiceServer) GetDatasetObjectGroup 

func (*UnimplementedObjectsServiceServer) GetDatasetObjectGroup(context.Context, *commonmodels.ID) (*datasetentrymodels.DatasetObjectGroup, error)

type UnimplementedProjectAPIServer 

type UnimplementedProjectAPIServer struct {
}

UnimplementedProjectAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedProjectAPIServer) AddUserToProject 

func (*UnimplementedProjectAPIServer) AddUserToProject(context.Context, *projectmodels.AddUserToProjectRequest) (*projectmodels.ProjectEntry, error)

func (*UnimplementedProjectAPIServer) CreateProject 

func (*UnimplementedProjectAPIServer) CreateProject(context.Context, *projectmodels.CreateProjectRequest) (*projectmodels.ProjectEntry, error)

func (*UnimplementedProjectAPIServer) DeleteProject 

func (*UnimplementedProjectAPIServer) DeleteProject(context.Context, *commonmodels.ID) (*commonmodels.Empty, error)

func (*UnimplementedProjectAPIServer) GetProjectDatasets 

func (*UnimplementedProjectAPIServer) GetProjectDatasets(context.Context, *commonmodels.ID) (*datasetmodels.DatasetList, error)

func (*UnimplementedProjectAPIServer) GetUserProjects 

func (*UnimplementedProjectAPIServer) GetUserProjects(context.Context, *commonmodels.Empty) (*projectmodels.ProjectEntryList, 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.