Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventSource ¶
type EventSource struct { *instr.Instrumentation // contains filtered or unexported fields }
EventSource generates events on a Bus after Put operations by proxying a Batching datastore.
func New ¶
func New(b event.Bus, ds datastore.Batching) (EventSource, error)
New sets up a new EventSource or returns an error.
func (*EventSource) Batching ¶
func (s *EventSource) Batching() datastore.Batching
Batching returns the proxied Batching datastore.
type EvtProviderPut ¶
type EvtProviderPut struct { CID cid.Cid PeerID peer.ID SpanContext trace.SpanContext // SpanContext allows a Resource' processing to be traceable across the program }
EvtProviderPut should be emitted on every datastore Put() for a peer providing a CID.
Click to show internal directories.
Click to hide internal directories.