uploader

Documentation

Index

• func GCPBlockDataObjectName(computationResult *execution.ComputationResult) string
• func WriteComputationResultsTo(computationResult *execution.ComputationResult, writer io.Writer) error
• type AsyncUploader
  • func NewAsyncUploader(uploader Uploader, retryInitialTimeout time.Duration, maxRetryNumber uint64, ...) *AsyncUploader
  • func (a *AsyncUploader) Done() <-chan struct{}
  • func (a *AsyncUploader) Ready() <-chan struct{}
  • func (a *AsyncUploader) Upload(computationResult *execution.ComputationResult) error
• type BlockData
  • func ComputationResultToBlockData(computationResult *execution.ComputationResult) *BlockData
• type FileUploader
  • func NewFileUploader(dir string) *FileUploader
  • func (f *FileUploader) Upload(computationResult *execution.ComputationResult) error
• type GCPBucketUploader
  • func NewGCPBucketUploader(ctx context.Context, bucketName string, log zerolog.Logger) (*GCPBucketUploader, error)
  • func (u *GCPBucketUploader) Upload(computationResult *execution.ComputationResult) error
• type Uploader

Functions

func GCPBlockDataObjectName

func GCPBlockDataObjectName(computationResult *execution.ComputationResult) string

func WriteComputationResultsTo

func WriteComputationResultsTo(computationResult *execution.ComputationResult, writer io.Writer) error

Types

type AsyncUploader

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

func NewAsyncUploader

func NewAsyncUploader(uploader Uploader, retryInitialTimeout time.Duration, maxRetryNumber uint64, log zerolog.Logger, metrics module.ExecutionMetrics) *AsyncUploader

func (*AsyncUploader) Done

func (a *AsyncUploader) Done() <-chan struct{}

func (*AsyncUploader) Ready

func (a *AsyncUploader) Ready() <-chan struct{}

func (*AsyncUploader) Upload

func (a *AsyncUploader) Upload(computationResult *execution.ComputationResult) error

type BlockData

type BlockData struct {
	Block       *flow.Block
	Collections []*entity.CompleteCollection
	TxResults   []*flow.TransactionResult
	Events      []*flow.Event
	TrieUpdates []*ledger.TrieUpdate
}

func ComputationResultToBlockData

func ComputationResultToBlockData(computationResult *execution.ComputationResult) *BlockData

type FileUploader

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

func NewFileUploader

func NewFileUploader(dir string) *FileUploader

func (*FileUploader) Upload

func (f *FileUploader) Upload(computationResult *execution.ComputationResult) error

type GCPBucketUploader

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

func NewGCPBucketUploader

func NewGCPBucketUploader(ctx context.Context, bucketName string, log zerolog.Logger) (*GCPBucketUploader, error)

func (*GCPBucketUploader) Upload

func (u *GCPBucketUploader) Upload(computationResult *execution.ComputationResult) error

type Uploader

type Uploader interface {
	Upload(computationResult *execution.ComputationResult) error
}