Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockMetadata ¶
type BlockMetadata struct {
ID flow.Identifier
Height uint64
Timestamp time.Time
}
BlockMetadata is used to capture information about requested blocks to avoid repeated blockID calculations and passing around full block headers.
type ENEventProvider ¶
type ENEventProvider struct {
// contains filtered or unexported fields
}
func NewENEventProvider ¶
func NewENEventProvider( log zerolog.Logger, nodeProvider *rpc.ExecutionNodeIdentitiesProvider, connFactory connection.ConnectionFactory, nodeCommunicator node_communicator.Communicator, ) *ENEventProvider
func (*ENEventProvider) Events ¶
func (e *ENEventProvider) Events( ctx context.Context, blocks []BlockMetadata, eventType flow.EventType, encoding entities.EventEncodingVersion, ) (Response, error)
type EventProvider ¶
type EventProvider interface {
Events(
ctx context.Context,
blocks []BlockMetadata,
eventType flow.EventType,
requiredEventEncodingVersion entities.EventEncodingVersion,
) (Response, error)
}
type FailoverEventProvider ¶
type FailoverEventProvider struct {
// contains filtered or unexported fields
}
func NewFailoverEventProvider ¶
func NewFailoverEventProvider( log zerolog.Logger, localProvider EventProvider, execNodeProvider EventProvider, ) *FailoverEventProvider
func (*FailoverEventProvider) Events ¶
func (f *FailoverEventProvider) Events( ctx context.Context, blocks []BlockMetadata, eventType flow.EventType, encoding entities.EventEncodingVersion, ) (Response, error)
type LocalEventProvider ¶
type LocalEventProvider struct {
// contains filtered or unexported fields
}
func NewLocalEventProvider ¶
func NewLocalEventProvider(index *index.EventsIndex) *LocalEventProvider
func (*LocalEventProvider) Events ¶
func (l *LocalEventProvider) Events( ctx context.Context, blocks []BlockMetadata, eventType flow.EventType, encoding entities.EventEncodingVersion, ) (Response, error)
type Response ¶
type Response struct {
Events []flow.BlockEvents
MissingBlocks []BlockMetadata
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.