remotedbserver

package
v0.0.0-...-140c642 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 24, 2021 License: GPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

View Source
const (
	EventTypeHeader = RpcEventType(iota)
)
View Source
const MaxTxTTL = 30 * time.Second

Variables

This section is empty.

Functions

func StartGrpc

func StartGrpc(kv ethdb.KV, eth core.Backend, addr string, creds *credentials.TransportCredentials, events *Events) (*grpc.Server, error)

Types

type DBServer

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

func NewDBServer

func NewDBServer(kv ethdb.KV) *DBServer

func (*DBServer) BucketSize

func (*DBServer) Size

type EthBackendServer

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

func NewEthBackendServer

func NewEthBackendServer(eth core.Backend, events *Events) *EthBackendServer

func (*EthBackendServer) Add

func (*EthBackendServer) Etherbase

func (*EthBackendServer) NetVersion

func (*EthBackendServer) Subscribe

type Events

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

func NewEvents

func NewEvents() *Events

func (*Events) AddHeaderSubscription

func (e *Events) AddHeaderSubscription(s HeaderSubscription)

func (*Events) OnNewHeader

func (e *Events) OnNewHeader(newHeader *types.Header)

type HeaderSubscription

type HeaderSubscription func(*types.Header) error

type KvServer

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

func NewKvServer

func NewKvServer(kv ethdb.KV) *KvServer

func (*KvServer) Tx

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

type RpcEventType

type RpcEventType uint64

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL