remotedbserver

Documentation

Index

• Constants
• Variables
• type KvServer
  • func NewKvServer(ctx context.Context, kv kv.RoDB, snapshots Snapsthots, ...) *KvServer
  • func (s *KvServer) SendStateChanges(ctx context.Context, sc *remote.StateChangeBatch)
  • func (s *KvServer) Snapshots(ctx context.Context, _ *remote.SnapshotsRequest) (*remote.SnapshotsReply, error)
  • func (s *KvServer) StateChanges(req *remote.StateChangeRequest, server remote.KV_StateChangesServer) error
  • func (s *KvServer) Tx(stream remote.KV_TxServer) error
  • func (s *KvServer) Version(context.Context, *emptypb.Empty) (*types.VersionReply, error)
• type Snapsthots
• type StateChangePubSub
  • func (s *StateChangePubSub) Len() int
  • func (s *StateChangePubSub) Pub(reply *remote.StateChangeBatch)
  • func (s *StateChangePubSub) Sub() (ch chan *remote.StateChangeBatch, remove func())

Constants

const MaxTxTTL = 60 * time.Second

Variables

var KvServiceAPIVersion = &types.VersionReply{Major: 6, Minor: 0, Patch: 0}

KvServiceAPIVersion - use it to track changes in API 1.1.0 - added pending transactions, add methods eth_getRawTransactionByHash, eth_retRawTransactionByBlockHashAndIndex, eth_retRawTransactionByBlockNumberAndIndex| Yes | | 1.2.0 - Added separated services for mining and txpool methods 2.0.0 - Rename all buckets 3.0.0 - ?? 4.0.0 - Server send tx.ViewID() after open tx 5.0 - BlockTransaction table now has canonical ids (txs of non-canonical blocks moving to NonCanonicalTransaction table) 5.1.0 - Added blockGasLimit to the StateChangeBatch 6.0.0 - Blocks now have system-txs - in the begin/end of block

Types

type KvServer

type KvServer struct {
	remote.UnimplementedKVServer // must be embedded to have forward compatible implementations.
	// contains filtered or unexported fields
}

func NewKvServer

func NewKvServer(ctx context.Context, kv kv.RoDB, snapshots Snapsthots, historySnapshots Snapsthots) *KvServer

func (*KvServer) SendStateChanges

func (s *KvServer) SendStateChanges(ctx context.Context, sc *remote.StateChangeBatch)

func (*KvServer) Snapshots

func (s *KvServer) Snapshots(ctx context.Context, _ *remote.SnapshotsRequest) (*remote.SnapshotsReply, error)

func (*KvServer) StateChanges

func (s *KvServer) StateChanges(req *remote.StateChangeRequest, server remote.KV_StateChangesServer) error

func (*KvServer) Tx

func (s *KvServer) Tx(stream remote.KV_TxServer) error

func (*KvServer) Version

func (s *KvServer) Version(context.Context, *emptypb.Empty) (*types.VersionReply, error)

Version returns the service-side interface version number

type Snapsthots

type Snapsthots interface {
	Files() []string
}

type StateChangePubSub

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

func (*StateChangePubSub) Len

func (s *StateChangePubSub) Len() int

func (*StateChangePubSub) Pub

func (s *StateChangePubSub) Pub(reply *remote.StateChangeBatch)

func (*StateChangePubSub) Sub

func (s *StateChangePubSub) Sub() (ch chan *remote.StateChangeBatch, remove func())