Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GCPStreamer ¶
type GCPStreamer struct {
// contains filtered or unexported fields
}
func NewGCPStreamer ¶
func NewGCPStreamer(log zerolog.Logger, bucket *storage.BucketHandle) *GCPStreamer
func (*GCPStreamer) OnBlockFinalized ¶
func (g *GCPStreamer) OnBlockFinalized(blockID flow.Identifier)
OnBlockFinalized is a callback for the Flow consensus follower. It is called each time a block is finalized by the Flow consensus algorithm.
Source Files
Click to show internal directories.
Click to hide internal directories.