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.
Source Files
Click to show internal directories.
Click to hide internal directories.