avail

Documentation

Index

• Constants
• func WithBatchRetryAttempts(attempts uint) da.Option
• func WithBatchRetryDelay(delay time.Duration) da.Option
• func WithClient(client SubstrateApiI) da.Option
• func WithTxInclusionTimeout(timeout time.Duration) da.Option
• type Config
• type DataAvailabilityLayerClient
  • func (c *DataAvailabilityLayerClient) CheckBatchAvailability(daMetaData *da.DASubmitMetaData) da.ResultCheckBatch
  • func (c *DataAvailabilityLayerClient) GetClientType() da.Client
  • func (c *DataAvailabilityLayerClient) Init(config []byte, pubsubServer *pubsub.Server, kvStore store.KVStore, ...) error
  • func (c *DataAvailabilityLayerClient) RetrieveBatches(daMetaData *da.DASubmitMetaData) da.ResultRetrieveBatch
  • func (c *DataAvailabilityLayerClient) Start() error
  • func (c *DataAvailabilityLayerClient) Stop() error
  • func (c *DataAvailabilityLayerClient) SubmitBatch(batch *types.Batch) da.ResultSubmitBatch
• type SubstrateApi
• type SubstrateApiI

Constants

const (
	DataCallSection      = "DataAvailability"
	DataCallMethod       = "submit_data"
	DataCallSectionIndex = 29
	DataCallMethodIndex  = 1
)

Functions

func WithBatchRetryAttempts

func WithBatchRetryAttempts(attempts uint) da.Option

WithBatchRetryAttempts is an option which sets the number of batch retries.

func WithBatchRetryDelay

func WithBatchRetryDelay(delay time.Duration) da.Option

WithBatchRetryDelay is an option which sets the delay between batch retries.

func WithClient

func WithClient(client SubstrateApiI) da.Option

WithClient is an option which sets the client.

func WithTxInclusionTimeout

func WithTxInclusionTimeout(timeout time.Duration) da.Option

WithTxInclusionTimeout is an option which sets the timeout for waiting for transaction inclusion.

Types

type Config

type Config struct {
	Seed   string `json:"seed"`
	ApiURL string `json:"api_url"`
	AppID  int64  `json:"app_id"`
	Tip    uint64 `json:"tip"`
}

type DataAvailabilityLayerClient

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

func (*DataAvailabilityLayerClient) CheckBatchAvailability

func (c *DataAvailabilityLayerClient) CheckBatchAvailability(daMetaData *da.DASubmitMetaData) da.ResultCheckBatch

CheckBatchAvailability checks batch availability in DataAvailabilityLayerClient instance.

func (*DataAvailabilityLayerClient) GetClientType

func (c *DataAvailabilityLayerClient) GetClientType() da.Client

GetClientType returns client type.

func (*DataAvailabilityLayerClient) Init

func (c *DataAvailabilityLayerClient) Init(config []byte, pubsubServer *pubsub.Server, kvStore store.KVStore, logger types.Logger, options ...da.Option) error

Init initializes DataAvailabilityLayerClient instance.

func (*DataAvailabilityLayerClient) RetrieveBatches

func (c *DataAvailabilityLayerClient) RetrieveBatches(daMetaData *da.DASubmitMetaData) da.ResultRetrieveBatch

RetrieveBatches retrieves batch from DataAvailabilityLayerClient instance.

func (*DataAvailabilityLayerClient) Start

func (c *DataAvailabilityLayerClient) Start() error

Start starts DataAvailabilityLayerClient instance.

func (*DataAvailabilityLayerClient) Stop

func (c *DataAvailabilityLayerClient) Stop() error

Stop stops DataAvailabilityLayerClient instance.

func (*DataAvailabilityLayerClient) SubmitBatch

func (c *DataAvailabilityLayerClient) SubmitBatch(batch *types.Batch) da.ResultSubmitBatch

SubmitBatch submits batch to DataAvailabilityLayerClient instance.

type SubstrateApi

type SubstrateApi struct {
	chain.Chain
	state.State
	author.Author
}

type SubstrateApiI

type SubstrateApiI interface {
	chain.Chain
	state.State
	author.Author
}