datasetsv1connect

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: May 23, 2025 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// CollectionServiceCreateCollectionProcedure is the fully-qualified name of the CollectionService's
	// CreateCollection RPC.
	CollectionServiceCreateCollectionProcedure = "/datasets.v1.CollectionService/CreateCollection"
	// CollectionServiceGetCollectionByNameProcedure is the fully-qualified name of the
	// CollectionService's GetCollectionByName RPC.
	CollectionServiceGetCollectionByNameProcedure = "/datasets.v1.CollectionService/GetCollectionByName"
	// CollectionServiceListCollectionsProcedure is the fully-qualified name of the CollectionService's
	// ListCollections RPC.
	CollectionServiceListCollectionsProcedure = "/datasets.v1.CollectionService/ListCollections"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// DataAccessServiceGetDatasetForIntervalProcedure is the fully-qualified name of the
	// DataAccessService's GetDatasetForInterval RPC.
	DataAccessServiceGetDatasetForIntervalProcedure = "/datasets.v1.DataAccessService/GetDatasetForInterval"
	// DataAccessServiceGetDatapointByIDProcedure is the fully-qualified name of the DataAccessService's
	// GetDatapointByID RPC.
	DataAccessServiceGetDatapointByIDProcedure = "/datasets.v1.DataAccessService/GetDatapointByID"
	// DataAccessServiceQueryByIDProcedure is the fully-qualified name of the DataAccessService's
	// QueryByID RPC.
	DataAccessServiceQueryByIDProcedure = "/datasets.v1.DataAccessService/QueryByID"
	// DataAccessServiceQueryProcedure is the fully-qualified name of the DataAccessService's Query RPC.
	DataAccessServiceQueryProcedure = "/datasets.v1.DataAccessService/Query"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// DataIngestionServiceIngestDatapointsProcedure is the fully-qualified name of the
	// DataIngestionService's IngestDatapoints RPC.
	DataIngestionServiceIngestDatapointsProcedure = "/datasets.v1.DataIngestionService/IngestDatapoints"
	// DataIngestionServiceIngestProcedure is the fully-qualified name of the DataIngestionService's
	// Ingest RPC.
	DataIngestionServiceIngestProcedure = "/datasets.v1.DataIngestionService/Ingest"
	// DataIngestionServiceDeleteProcedure is the fully-qualified name of the DataIngestionService's
	// Delete RPC.
	DataIngestionServiceDeleteProcedure = "/datasets.v1.DataIngestionService/Delete"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// DatasetServiceCreateDatasetProcedure is the fully-qualified name of the DatasetService's
	// CreateDataset RPC.
	DatasetServiceCreateDatasetProcedure = "/datasets.v1.DatasetService/CreateDataset"
	// DatasetServiceGetDatasetProcedure is the fully-qualified name of the DatasetService's GetDataset
	// RPC.
	DatasetServiceGetDatasetProcedure = "/datasets.v1.DatasetService/GetDataset"
	// DatasetServiceUpdateDatasetProcedure is the fully-qualified name of the DatasetService's
	// UpdateDataset RPC.
	DatasetServiceUpdateDatasetProcedure = "/datasets.v1.DatasetService/UpdateDataset"
	// DatasetServiceUpdateDatasetDescriptionProcedure is the fully-qualified name of the
	// DatasetService's UpdateDatasetDescription RPC.
	DatasetServiceUpdateDatasetDescriptionProcedure = "/datasets.v1.DatasetService/UpdateDatasetDescription"
	// DatasetServiceListDatasetsProcedure is the fully-qualified name of the DatasetService's
	// ListDatasets RPC.
	DatasetServiceListDatasetsProcedure = "/datasets.v1.DatasetService/ListDatasets"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// CollectionServiceName is the fully-qualified name of the CollectionService service.
	CollectionServiceName = "datasets.v1.CollectionService"
)
View Source 
const (
	// DataAccessServiceName is the fully-qualified name of the DataAccessService service.
	DataAccessServiceName = "datasets.v1.DataAccessService"
)
View Source 
const (
	// DataIngestionServiceName is the fully-qualified name of the DataIngestionService service.
	DataIngestionServiceName = "datasets.v1.DataIngestionService"
)
View Source 
const (
	// DatasetServiceName is the fully-qualified name of the DatasetService service.
	DatasetServiceName = "datasets.v1.DatasetService"
)

Variables

This section is empty.

Functions

func NewCollectionServiceHandler 

func NewCollectionServiceHandler(svc CollectionServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewCollectionServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewDataAccessServiceHandler 

func NewDataAccessServiceHandler(svc DataAccessServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewDataAccessServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewDataIngestionServiceHandler 

func NewDataIngestionServiceHandler(svc DataIngestionServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewDataIngestionServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewDatasetServiceHandler 

func NewDatasetServiceHandler(svc DatasetServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewDatasetServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type CollectionServiceClient 

type CollectionServiceClient interface {
	CreateCollection(context.Context, *connect.Request[v1.CreateCollectionRequest]) (*connect.Response[v1.CollectionInfo], error)
	GetCollectionByName(context.Context, *connect.Request[v1.GetCollectionByNameRequest]) (*connect.Response[v1.CollectionInfo], error)
	ListCollections(context.Context, *connect.Request[v1.ListCollectionsRequest]) (*connect.Response[v1.CollectionInfos], error)
}

CollectionServiceClient is a client for the datasets.v1.CollectionService service.

func NewCollectionServiceClient 

func NewCollectionServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) CollectionServiceClient

NewCollectionServiceClient constructs a client for the datasets.v1.CollectionService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type CollectionServiceHandler 

type CollectionServiceHandler interface {
	CreateCollection(context.Context, *connect.Request[v1.CreateCollectionRequest]) (*connect.Response[v1.CollectionInfo], error)
	GetCollectionByName(context.Context, *connect.Request[v1.GetCollectionByNameRequest]) (*connect.Response[v1.CollectionInfo], error)
	ListCollections(context.Context, *connect.Request[v1.ListCollectionsRequest]) (*connect.Response[v1.CollectionInfos], error)
}

CollectionServiceHandler is an implementation of the datasets.v1.CollectionService service.

type DataAccessServiceClient 

type DataAccessServiceClient interface {
	// GetDatasetForInterval returns a list of data points for a given time interval and collection.
	GetDatasetForInterval(context.Context, *connect.Request[v1.GetDatasetForIntervalRequest]) (*connect.Response[v1.DatapointPage], error)
	// GetDatapointByID returns a single datapoint by its ID.
	GetDatapointByID(context.Context, *connect.Request[v1.GetDatapointByIdRequest]) (*connect.Response[v1.Datapoint], error)
	// QueryByID returns a single data point by its ID.
	QueryByID(context.Context, *connect.Request[v1.QueryByIDRequest]) (*connect.Response[v1.Any], error)
	// Query returns a list of data points matching the given query filters.
	Query(context.Context, *connect.Request[v1.QueryRequest]) (*connect.Response[v1.QueryResultPage], error)
}

DataAccessServiceClient is a client for the datasets.v1.DataAccessService service.

func NewDataAccessServiceClient 

func NewDataAccessServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) DataAccessServiceClient

NewDataAccessServiceClient constructs a client for the datasets.v1.DataAccessService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type DataAccessServiceHandler 

type DataAccessServiceHandler interface {
	// GetDatasetForInterval returns a list of data points for a given time interval and collection.
	GetDatasetForInterval(context.Context, *connect.Request[v1.GetDatasetForIntervalRequest]) (*connect.Response[v1.DatapointPage], error)
	// GetDatapointByID returns a single datapoint by its ID.
	GetDatapointByID(context.Context, *connect.Request[v1.GetDatapointByIdRequest]) (*connect.Response[v1.Datapoint], error)
	// QueryByID returns a single data point by its ID.
	QueryByID(context.Context, *connect.Request[v1.QueryByIDRequest]) (*connect.Response[v1.Any], error)
	// Query returns a list of data points matching the given query filters.
	Query(context.Context, *connect.Request[v1.QueryRequest]) (*connect.Response[v1.QueryResultPage], error)
}

DataAccessServiceHandler is an implementation of the datasets.v1.DataAccessService service.

type DataIngestionServiceClient 

type DataIngestionServiceClient interface {
	// legacy ingest endpoint, that separates datapoints into meta and data. Will be removed in the future.
	IngestDatapoints(context.Context, *connect.Request[v1.IngestDatapointsRequest]) (*connect.Response[v1.IngestResponse], error)
	Ingest(context.Context, *connect.Request[v1.IngestRequest]) (*connect.Response[v1.IngestResponse], error)
	Delete(context.Context, *connect.Request[v1.DeleteRequest]) (*connect.Response[v1.DeleteResponse], error)
}

DataIngestionServiceClient is a client for the datasets.v1.DataIngestionService service.

func NewDataIngestionServiceClient 

func NewDataIngestionServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) DataIngestionServiceClient

NewDataIngestionServiceClient constructs a client for the datasets.v1.DataIngestionService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type DataIngestionServiceHandler 

type DataIngestionServiceHandler interface {
	// legacy ingest endpoint, that separates datapoints into meta and data. Will be removed in the future.
	IngestDatapoints(context.Context, *connect.Request[v1.IngestDatapointsRequest]) (*connect.Response[v1.IngestResponse], error)
	Ingest(context.Context, *connect.Request[v1.IngestRequest]) (*connect.Response[v1.IngestResponse], error)
	Delete(context.Context, *connect.Request[v1.DeleteRequest]) (*connect.Response[v1.DeleteResponse], error)
}

DataIngestionServiceHandler is an implementation of the datasets.v1.DataIngestionService service.

type DatasetServiceClient 

type DatasetServiceClient interface {
	CreateDataset(context.Context, *connect.Request[v1.CreateDatasetRequest]) (*connect.Response[v1.Dataset], error)
	GetDataset(context.Context, *connect.Request[v1.GetDatasetRequest]) (*connect.Response[v1.Dataset], error)
	UpdateDataset(context.Context, *connect.Request[v1.UpdateDatasetRequest]) (*connect.Response[v1.Dataset], error)
	UpdateDatasetDescription(context.Context, *connect.Request[v1.UpdateDatasetDescriptionRequest]) (*connect.Response[v1.Dataset], error)
	ListDatasets(context.Context, *connect.Request[v1.ListDatasetsRequest]) (*connect.Response[v1.ListDatasetsResponse], error)
}

DatasetServiceClient is a client for the datasets.v1.DatasetService service.

func NewDatasetServiceClient 

func NewDatasetServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) DatasetServiceClient

NewDatasetServiceClient constructs a client for the datasets.v1.DatasetService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type DatasetServiceHandler 

type DatasetServiceHandler interface {
	CreateDataset(context.Context, *connect.Request[v1.CreateDatasetRequest]) (*connect.Response[v1.Dataset], error)
	GetDataset(context.Context, *connect.Request[v1.GetDatasetRequest]) (*connect.Response[v1.Dataset], error)
	UpdateDataset(context.Context, *connect.Request[v1.UpdateDatasetRequest]) (*connect.Response[v1.Dataset], error)
	UpdateDatasetDescription(context.Context, *connect.Request[v1.UpdateDatasetDescriptionRequest]) (*connect.Response[v1.Dataset], error)
	ListDatasets(context.Context, *connect.Request[v1.ListDatasetsRequest]) (*connect.Response[v1.ListDatasetsResponse], error)
}

DatasetServiceHandler is an implementation of the datasets.v1.DatasetService service.

type UnimplementedCollectionServiceHandler 

type UnimplementedCollectionServiceHandler struct{}

UnimplementedCollectionServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedCollectionServiceHandler) CreateCollection 

func (UnimplementedCollectionServiceHandler) CreateCollection(context.Context, *connect.Request[v1.CreateCollectionRequest]) (*connect.Response[v1.CollectionInfo], error)

func (UnimplementedCollectionServiceHandler) GetCollectionByName 

func (UnimplementedCollectionServiceHandler) GetCollectionByName(context.Context, *connect.Request[v1.GetCollectionByNameRequest]) (*connect.Response[v1.CollectionInfo], error)

func (UnimplementedCollectionServiceHandler) ListCollections 

func (UnimplementedCollectionServiceHandler) ListCollections(context.Context, *connect.Request[v1.ListCollectionsRequest]) (*connect.Response[v1.CollectionInfos], error)

type UnimplementedDataAccessServiceHandler 

type UnimplementedDataAccessServiceHandler struct{}

UnimplementedDataAccessServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedDataAccessServiceHandler) GetDatapointByID 

func (UnimplementedDataAccessServiceHandler) GetDatapointByID(context.Context, *connect.Request[v1.GetDatapointByIdRequest]) (*connect.Response[v1.Datapoint], error)

func (UnimplementedDataAccessServiceHandler) GetDatasetForInterval 

func (UnimplementedDataAccessServiceHandler) GetDatasetForInterval(context.Context, *connect.Request[v1.GetDatasetForIntervalRequest]) (*connect.Response[v1.DatapointPage], error)

func (UnimplementedDataAccessServiceHandler) Query 

func (UnimplementedDataAccessServiceHandler) Query(context.Context, *connect.Request[v1.QueryRequest]) (*connect.Response[v1.QueryResultPage], error)

func (UnimplementedDataAccessServiceHandler) QueryByID 

func (UnimplementedDataAccessServiceHandler) QueryByID(context.Context, *connect.Request[v1.QueryByIDRequest]) (*connect.Response[v1.Any], error)

type UnimplementedDataIngestionServiceHandler 

type UnimplementedDataIngestionServiceHandler struct{}

UnimplementedDataIngestionServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedDataIngestionServiceHandler) Delete 

func (UnimplementedDataIngestionServiceHandler) Delete(context.Context, *connect.Request[v1.DeleteRequest]) (*connect.Response[v1.DeleteResponse], error)

func (UnimplementedDataIngestionServiceHandler) Ingest 

func (UnimplementedDataIngestionServiceHandler) Ingest(context.Context, *connect.Request[v1.IngestRequest]) (*connect.Response[v1.IngestResponse], error)

func (UnimplementedDataIngestionServiceHandler) IngestDatapoints 

func (UnimplementedDataIngestionServiceHandler) IngestDatapoints(context.Context, *connect.Request[v1.IngestDatapointsRequest]) (*connect.Response[v1.IngestResponse], error)

type UnimplementedDatasetServiceHandler 

type UnimplementedDatasetServiceHandler struct{}

UnimplementedDatasetServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedDatasetServiceHandler) CreateDataset 

func (UnimplementedDatasetServiceHandler) CreateDataset(context.Context, *connect.Request[v1.CreateDatasetRequest]) (*connect.Response[v1.Dataset], error)

func (UnimplementedDatasetServiceHandler) GetDataset 

func (UnimplementedDatasetServiceHandler) GetDataset(context.Context, *connect.Request[v1.GetDatasetRequest]) (*connect.Response[v1.Dataset], error)

func (UnimplementedDatasetServiceHandler) ListDatasets 

func (UnimplementedDatasetServiceHandler) ListDatasets(context.Context, *connect.Request[v1.ListDatasetsRequest]) (*connect.Response[v1.ListDatasetsResponse], error)

func (UnimplementedDatasetServiceHandler) UpdateDataset 

func (UnimplementedDatasetServiceHandler) UpdateDataset(context.Context, *connect.Request[v1.UpdateDatasetRequest]) (*connect.Response[v1.Dataset], error)

func (UnimplementedDatasetServiceHandler) UpdateDatasetDescription 

func (UnimplementedDatasetServiceHandler) UpdateDatasetDescription(context.Context, *connect.Request[v1.UpdateDatasetDescriptionRequest]) (*connect.Response[v1.Dataset], 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.