grpc

Documentation

Index

• Variables
• type Config
• type DataAvailabilityLayerClient
  • func (d *DataAvailabilityLayerClient) CheckBatchAvailability(daMetaData *da.DASubmitMetaData) da.ResultCheckBatch
  • func (d *DataAvailabilityLayerClient) GetClientType() da.Client
  • func (d *DataAvailabilityLayerClient) Init(config []byte, _ *pubsub.Server, _ store.KVStore, logger types.Logger, ...) error
  • func (d *DataAvailabilityLayerClient) RetrieveBatches(daMetaData *da.DASubmitMetaData) da.ResultRetrieveBatch
  • func (d *DataAvailabilityLayerClient) Start() error
  • func (d *DataAvailabilityLayerClient) Stop() error
  • func (d *DataAvailabilityLayerClient) SubmitBatch(batch *types.Batch) da.ResultSubmitBatch

Variables

var DefaultConfig = Config{
	Host: "127.0.0.1",
	Port: 7980,
}

DefaultConfig defines default values for DataAvailabilityLayerClient configuration.

Types

type Config

type Config struct {
	// TODO(tzdybal): add more options!
	Host string `json:"host"`
	Port int    `json:"port"`
}

Config contains configuration options for DataAvailabilityLayerClient.

type DataAvailabilityLayerClient

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

DataAvailabilityLayerClient is a generic client that proxies all DA requests via gRPC.

func (*DataAvailabilityLayerClient) CheckBatchAvailability

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

CheckBatchAvailability proxies CheckBatchAvailability request to gRPC server.

func (*DataAvailabilityLayerClient) GetClientType

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

GetClientType returns client type.

func (*DataAvailabilityLayerClient) Init

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

Init sets the configuration options.

func (*DataAvailabilityLayerClient) RetrieveBatches

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

RetrieveBatches proxies RetrieveBlocks request to gRPC server.

func (*DataAvailabilityLayerClient) Start

func (d *DataAvailabilityLayerClient) Start() error

Start creates connection to gRPC server and instantiates gRPC client.

func (*DataAvailabilityLayerClient) Stop

func (d *DataAvailabilityLayerClient) Stop() error

Stop closes connection to gRPC server.

func (*DataAvailabilityLayerClient) SubmitBatch

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

SubmitBatch proxies SubmitBatch request to gRPC server.