Documentation ¶
Overview ¶
Package fetch provides functions for fetching objects from the index service.
Index ¶
- func GetCloudEventFromKey(ctx context.Context, idxSvc *indexrepo.Service, indexKeys string, ...) (cloudevent.CloudEvent[json.RawMessage], error)
- func GetCloudEventsFromKeys(ctx context.Context, idxSvc *indexrepo.Service, indexKeys []string, ...) ([]cloudevent.CloudEvent[json.RawMessage], error)
- func ListCloudEventsFromMetadata(ctx context.Context, idxSvc *indexrepo.Service, ...) ([]cloudevent.CloudEvent[json.RawMessage], error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetCloudEventFromKey ¶ added in v0.0.3
func GetCloudEventFromKey(ctx context.Context, idxSvc *indexrepo.Service, indexKeys string, buckets []string) (cloudevent.CloudEvent[json.RawMessage], error)
GetCloudEventFromKey gets an object from the index service by trying to get it from each bucket in the list returning the first successful result.
func GetCloudEventsFromKeys ¶ added in v0.0.3
func GetCloudEventsFromKeys(ctx context.Context, idxSvc *indexrepo.Service, indexKeys []string, buckets []string) ([]cloudevent.CloudEvent[json.RawMessage], error)
GetCloudEventsFromKeys gets objects from the index service by trying to get them from each bucket in the list returning the first successful result.
func ListCloudEventsFromMetadata ¶ added in v0.0.3
func ListCloudEventsFromMetadata(ctx context.Context, idxSvc *indexrepo.Service, metadataList []indexrepo.CloudEventMetadata, buckets []string) ([]cloudevent.CloudEvent[json.RawMessage], error)
GetObjectsFromIndexs gets objects from the index service by trying to get them from each bucket in the list returning the first successful result.
Types ¶
This section is empty.
Directories ¶
Path | Synopsis |
---|---|
Packagge httphandler provides the HTTP handler for the fetch service.
|
Packagge httphandler provides the HTTP handler for the fetch service. |
Package rpc provides the gRPC server implementation for the index repo service.
|
Package rpc provides the gRPC server implementation for the index repo service. |
Click to show internal directories.
Click to hide internal directories.