Documentation
¶
Overview ¶
Package fetch provides functions for fetching objects from the index service.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetCloudEventFromIndex ¶ added in v0.0.4
func GetCloudEventFromIndex(ctx context.Context, evtSvc *eventrepo.Service, indexKeys cloudevent.CloudEvent[eventrepo.ObjectInfo], 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 ListCloudEventsFromIndexes ¶ added in v0.0.4
func ListCloudEventsFromIndexes(ctx context.Context, evtSvc *eventrepo.Service, indexKeys []cloudevent.CloudEvent[eventrepo.ObjectInfo], buckets []string) ([]cloudevent.CloudEvent[json.RawMessage], error)
ListCloudEventsFromIndexes fetches a list of cloud events 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.
Source Files
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.