Documentation
¶
Index ¶
- Constants
- func StartGrpc(kv ethdb.KV, eth core.Backend, addr string, ...) (*grpc.Server, error)
- type DBServer
- type 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
- type HeaderSubscription
- type KvServer
- type RpcEventType
Constants ¶
View Source
const (
EventTypeHeader = RpcEventType(iota)
)
View Source
const MaxTxTTL = 30 * time.Second
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DBServer ¶
type DBServer struct { remote.UnimplementedDBServer // must be embedded to have forward compatible implementations. // contains filtered or unexported fields }
func NewDBServer ¶
func (*DBServer) BucketSize ¶
func (s *DBServer) BucketSize(ctx context.Context, in *remote.BucketSizeRequest) (*remote.BucketSizeReply, 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) 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 (*Events) AddHeaderSubscription ¶
func (e *Events) AddHeaderSubscription(s HeaderSubscription)
func (*Events) OnNewHeader ¶
type HeaderSubscription ¶
type KvServer ¶
type KvServer struct { remote.UnimplementedKVServer // must be embedded to have forward compatible implementations. // contains filtered or unexported fields }
func NewKvServer ¶
type RpcEventType ¶
type RpcEventType uint64
Click to show internal directories.
Click to hide internal directories.