Documentation ¶
Index ¶
- func AddEventSentToCache(cacheClient *lru.Cache, event *cloudevents.Event) error
- func EventKey(event *cloudevents.Event) (string, error)
- func Get(ctx context.Context) *lru.Cache
- func IsCloudEventSent(cacheClient *lru.Cache, event *cloudevents.Event) (bool, error)
- func ToContext(ctx context.Context, c *lru.Cache) context.Context
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddEventSentToCache ¶
func AddEventSentToCache(cacheClient *lru.Cache, event *cloudevents.Event) error
AddEventSentToCache adds the particular object to cache marking it as sent
func EventKey ¶
func EventKey(event *cloudevents.Event) (string, error)
EventKey defines whether an event is considered different from another in future we might want to let specific event types override this
func IsCloudEventSent ¶
IsCloudEventSent checks if the event exists in the cache
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.