cloud

package

v1.3.1 Latest Latest Go to latest Published: Sep 10, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

View Source

var DefaultConfig = Config{
	BufferSize: 32,
}

This section is empty.

type Config struct {
	BufferSize uint
}

type GCPStreamer struct {
	// contains filtered or unexported fields
}

func NewGCPStreamer(log zerolog.Logger, bucket *storage.BucketHandle, options ...Option) *GCPStreamer

func (g *GCPStreamer) Next() (*uploader.BlockData, error)

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.

type Option func(*Config)

func WithBufferSize(size uint) Option