remotedbserver

Documentation

Index

• Constants
• func StartGrpc(kv ethdb.KV, eth core.Backend, addr string, ...) (*grpc.Server, error)
• type DBServer
  • func NewDBServer(kv ethdb.KV) *DBServer
  • func (s *DBServer) BucketSize(ctx context.Context, in *remote.BucketSizeRequest) (*remote.BucketSizeReply, error)
  • func (s *DBServer) Size(ctx context.Context, in *remote.SizeRequest) (*remote.SizeReply, error)
• type EthBackendServer
  • func NewEthBackendServer(eth core.Backend, events *Events) *EthBackendServer
  • func (s *EthBackendServer) Add(_ context.Context, in *remote.TxRequest) (*remote.AddReply, error)
  • func (s *EthBackendServer) Etherbase(_ context.Context, _ *remote.EtherbaseRequest) (*remote.EtherbaseReply, error)
  • func (s *EthBackendServer) NetVersion(_ context.Context, _ *remote.NetVersionRequest) (*remote.NetVersionReply, error)
  • func (s *EthBackendServer) Subscribe(r *remote.SubscribeRequest, subscribeServer remote.ETHBACKEND_SubscribeServer) error
• type Events
  • func NewEvents() *Events
  • func (e *Events) AddHeaderSubscription(s HeaderSubscription)
  • func (e *Events) OnNewHeader(newHeader *types.Header)
• type HeaderSubscription
• type KvServer
  • func NewKvServer(kv ethdb.KV) *KvServer
  • func (s *KvServer) Tx(stream remote.KV_TxServer) error
• type RpcEventType

Constants

const (
	EventTypeHeader = RpcEventType(iota)
)

const MaxTxTTL = 30 * time.Second

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 (s *DBServer) BucketSize(ctx context.Context, in *remote.BucketSizeRequest) (*remote.BucketSizeReply, error)

func (*DBServer) Size

func (s *DBServer) Size(ctx context.Context, in *remote.SizeRequest) (*remote.SizeReply, error)

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 (s *EthBackendServer) Add(_ context.Context, in *remote.TxRequest) (*remote.AddReply, error)

func (*EthBackendServer) Etherbase

func (s *EthBackendServer) Etherbase(_ context.Context, _ *remote.EtherbaseRequest) (*remote.EtherbaseReply, error)

func (*EthBackendServer) NetVersion

func (s *EthBackendServer) NetVersion(_ context.Context, _ *remote.NetVersionRequest) (*remote.NetVersionReply, error)

func (*EthBackendServer) Subscribe

func (s *EthBackendServer) Subscribe(r *remote.SubscribeRequest, subscribeServer remote.ETHBACKEND_SubscribeServer) error

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