providing

Documentation

Overview

Package providing implements an exchange wrapper which does content providing for new blocks.

Index

• type Exchange
  • func New(base exchange.Interface, provider provider.Provider) *Exchange
  • func (ex *Exchange) NotifyNewBlocks(ctx context.Context, blocks ...blocks.Block) error

Types

type Exchange

type Exchange struct {
	exchange.Interface
	// contains filtered or unexported fields
}

Exchange is an exchange wrapper that calls Provide for blocks received over NotifyNewBlocks.

func New

func New(base exchange.Interface, provider provider.Provider) *Exchange

New creates a new providing Exchange with the given exchange and provider. This is a light wrapper. We recommend that the provider supports the handling of many concurrent provides etc. as it is called directly for every new block.

func (*Exchange) NotifyNewBlocks

func (ex *Exchange) NotifyNewBlocks(ctx context.Context, blocks ...blocks.Block) error

NotifyNewBlocks calls NotifyNewBlocks on the underlying provider and provider.Provide for every block after that.