api

package
v1.9.1 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2024 License: MIT Imports: 10 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	API_SubscribeNewTxs_FullMethodName              = "/api.API/SubscribeNewTxs"
	API_SubscribeNewTxsV2_FullMethodName            = "/api.API/SubscribeNewTxsV2"
	API_SubscribeNewBlobTxs_FullMethodName          = "/api.API/SubscribeNewBlobTxs"
	API_SendTransaction_FullMethodName              = "/api.API/SendTransaction"
	API_SendRawTransaction_FullMethodName           = "/api.API/SendRawTransaction"
	API_SendTransactionV2_FullMethodName            = "/api.API/SendTransactionV2"
	API_SendTransactionSequence_FullMethodName      = "/api.API/SendTransactionSequence"
	API_SendTransactionSequenceV2_FullMethodName    = "/api.API/SendTransactionSequenceV2"
	API_SendRawTransactionSequence_FullMethodName   = "/api.API/SendRawTransactionSequence"
	API_SubscribeExecutionPayloads_FullMethodName   = "/api.API/SubscribeExecutionPayloads"
	API_SubscribeExecutionPayloadsV2_FullMethodName = "/api.API/SubscribeExecutionPayloadsV2"
	API_SubscribeExecutionHeaders_FullMethodName    = "/api.API/SubscribeExecutionHeaders"
	API_SubscribeBeaconBlocks_FullMethodName        = "/api.API/SubscribeBeaconBlocks"
	API_SubscribeBeaconBlocksV2_FullMethodName      = "/api.API/SubscribeBeaconBlocksV2"
	API_SubmitBlockStream_FullMethodName            = "/api.API/SubmitBlockStream"
)

Variables

View Source 
var API_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.API",
	HandlerType: (*APIServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeNewTxs",
			Handler:       _API_SubscribeNewTxs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeNewTxsV2",
			Handler:       _API_SubscribeNewTxsV2_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeNewBlobTxs",
			Handler:       _API_SubscribeNewBlobTxs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SendTransaction",
			Handler:       _API_SendTransaction_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SendRawTransaction",
			Handler:       _API_SendRawTransaction_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SendTransactionV2",
			Handler:       _API_SendTransactionV2_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SendTransactionSequence",
			Handler:       _API_SendTransactionSequence_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SendTransactionSequenceV2",
			Handler:       _API_SendTransactionSequenceV2_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SendRawTransactionSequence",
			Handler:       _API_SendRawTransactionSequence_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SubscribeExecutionPayloads",
			Handler:       _API_SubscribeExecutionPayloads_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeExecutionPayloadsV2",
			Handler:       _API_SubscribeExecutionPayloadsV2_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeExecutionHeaders",
			Handler:       _API_SubscribeExecutionHeaders_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBeaconBlocks",
			Handler:       _API_SubscribeBeaconBlocks_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBeaconBlocksV2",
			Handler:       _API_SubscribeBeaconBlocksV2_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubmitBlockStream",
			Handler:       _API_SubmitBlockStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api.proto",
}

API_ServiceDesc is the grpc.ServiceDesc for API service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_proto protoreflect.FileDescriptor

Functions

func RegisterAPIServer 

func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)

Types

type APIClient 

type APIClient interface {
	// Opens a new transaction stream with the given filter.
	// TODO: Deprecate
	SubscribeNewTxs(ctx context.Context, in *TxFilter, opts ...grpc.CallOption) (API_SubscribeNewTxsClient, error)
	// Opens a new transaction stream with the given filter.
	SubscribeNewTxsV2(ctx context.Context, in *TxFilter, opts ...grpc.CallOption) (API_SubscribeNewTxsV2Client, error)
	// Opens a new blob transaction stream with the given filter.
	SubscribeNewBlobTxs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (API_SubscribeNewBlobTxsClient, error)
	// Sends a signed transaction to the network.
	// TODO: Deprecate
	SendTransaction(ctx context.Context, opts ...grpc.CallOption) (API_SendTransactionClient, error)
	// Sends a signed, RLP encoded transaction to the network
	// TODO: Deprecate
	SendRawTransaction(ctx context.Context, opts ...grpc.CallOption) (API_SendRawTransactionClient, error)
	SendTransactionV2(ctx context.Context, opts ...grpc.CallOption) (API_SendTransactionV2Client, error)
	// Sends a sequence of signed transactions to the network.
	// TODO: Deprecate
	SendTransactionSequence(ctx context.Context, opts ...grpc.CallOption) (API_SendTransactionSequenceClient, error)
	SendTransactionSequenceV2(ctx context.Context, opts ...grpc.CallOption) (API_SendTransactionSequenceV2Client, error)
	// Sends a sequence of signed, RLP encoded transactions to the network.
	SendRawTransactionSequence(ctx context.Context, opts ...grpc.CallOption) (API_SendRawTransactionSequenceClient, error)
	// Opens a stream of new execution payloads.
	// TODO: Deprecate
	SubscribeExecutionPayloads(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (API_SubscribeExecutionPayloadsClient, error)
	SubscribeExecutionPayloadsV2(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (API_SubscribeExecutionPayloadsV2Client, error)
	// Opens a stream of new execution payload headers.
	// TODO: Deprecate
	SubscribeExecutionHeaders(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (API_SubscribeExecutionHeadersClient, error)
	// Opens a stream of new beacon blocks. The beacon blocks are "compacted", meaning that the
	// execution payload is not included.
	SubscribeBeaconBlocks(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (API_SubscribeBeaconBlocksClient, error)
	// Opens a stream of new beacon blocks.
	SubscribeBeaconBlocksV2(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (API_SubscribeBeaconBlocksV2Client, error)
	// Opens a bi-directional stream for new block submissions. The client stream is used to send
	// SSZ-encoded beacon blocks, and the server stream is used to send back the state_root, slot and
	// a local timestamp as a confirmation that the block was seen and handled.
	SubmitBlockStream(ctx context.Context, opts ...grpc.CallOption) (API_SubmitBlockStreamClient, error)
}

APIClient is the client API for API service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAPIClient 

func NewAPIClient(cc grpc.ClientConnInterface) APIClient

type APIServer 

type APIServer interface {
	// Opens a new transaction stream with the given filter.
	// TODO: Deprecate
	SubscribeNewTxs(*TxFilter, API_SubscribeNewTxsServer) error
	// Opens a new transaction stream with the given filter.
	SubscribeNewTxsV2(*TxFilter, API_SubscribeNewTxsV2Server) error
	// Opens a new blob transaction stream with the given filter.
	SubscribeNewBlobTxs(*emptypb.Empty, API_SubscribeNewBlobTxsServer) error
	// Sends a signed transaction to the network.
	// TODO: Deprecate
	SendTransaction(API_SendTransactionServer) error
	// Sends a signed, RLP encoded transaction to the network
	// TODO: Deprecate
	SendRawTransaction(API_SendRawTransactionServer) error
	SendTransactionV2(API_SendTransactionV2Server) error
	// Sends a sequence of signed transactions to the network.
	// TODO: Deprecate
	SendTransactionSequence(API_SendTransactionSequenceServer) error
	SendTransactionSequenceV2(API_SendTransactionSequenceV2Server) error
	// Sends a sequence of signed, RLP encoded transactions to the network.
	SendRawTransactionSequence(API_SendRawTransactionSequenceServer) error
	// Opens a stream of new execution payloads.
	// TODO: Deprecate
	SubscribeExecutionPayloads(*emptypb.Empty, API_SubscribeExecutionPayloadsServer) error
	SubscribeExecutionPayloadsV2(*emptypb.Empty, API_SubscribeExecutionPayloadsV2Server) error
	// Opens a stream of new execution payload headers.
	// TODO: Deprecate
	SubscribeExecutionHeaders(*emptypb.Empty, API_SubscribeExecutionHeadersServer) error
	// Opens a stream of new beacon blocks. The beacon blocks are "compacted", meaning that the
	// execution payload is not included.
	SubscribeBeaconBlocks(*emptypb.Empty, API_SubscribeBeaconBlocksServer) error
	// Opens a stream of new beacon blocks.
	SubscribeBeaconBlocksV2(*emptypb.Empty, API_SubscribeBeaconBlocksV2Server) error
	// Opens a bi-directional stream for new block submissions. The client stream is used to send
	// SSZ-encoded beacon blocks, and the server stream is used to send back the state_root, slot and
	// a local timestamp as a confirmation that the block was seen and handled.
	SubmitBlockStream(API_SubmitBlockStreamServer) error
	// contains filtered or unexported methods
}

APIServer is the server API for API service. All implementations must embed UnimplementedAPIServer for forward compatibility

type API_SendRawTransactionClient added in v1.5.0 

type API_SendRawTransactionClient interface {
	Send(*RawTxMsg) error
	Recv() (*TransactionResponse, error)
	grpc.ClientStream
}

type API_SendRawTransactionSequenceClient added in v1.5.0 

type API_SendRawTransactionSequenceClient interface {
	Send(*RawTxSequenceMsg) error
	Recv() (*TxSequenceResponse, error)
	grpc.ClientStream
}

type API_SendRawTransactionSequenceServer added in v1.5.0 

type API_SendRawTransactionSequenceServer interface {
	Send(*TxSequenceResponse) error
	Recv() (*RawTxSequenceMsg, error)
	grpc.ServerStream
}

type API_SendRawTransactionServer added in v1.5.0 

type API_SendRawTransactionServer interface {
	Send(*TransactionResponse) error
	Recv() (*RawTxMsg, error)
	grpc.ServerStream
}

type API_SendTransactionClient added in v1.5.0 

type API_SendTransactionClient interface {
	Send(*eth.Transaction) error
	Recv() (*TransactionResponse, error)
	grpc.ClientStream
}

type API_SendTransactionSequenceClient added in v1.5.0 

type API_SendTransactionSequenceClient interface {
	Send(*TxSequenceMsg) error
	Recv() (*TxSequenceResponse, error)
	grpc.ClientStream
}

type API_SendTransactionSequenceServer added in v1.5.0 

type API_SendTransactionSequenceServer interface {
	Send(*TxSequenceResponse) error
	Recv() (*TxSequenceMsg, error)
	grpc.ServerStream
}

type API_SendTransactionSequenceV2Client added in v1.9.0 

type API_SendTransactionSequenceV2Client interface {
	Send(*TxSequenceMsgV2) error
	Recv() (*TxSequenceResponse, error)
	grpc.ClientStream
}

type API_SendTransactionSequenceV2Server added in v1.9.0 

type API_SendTransactionSequenceV2Server interface {
	Send(*TxSequenceResponse) error
	Recv() (*TxSequenceMsgV2, error)
	grpc.ServerStream
}

type API_SendTransactionServer added in v1.5.0 

type API_SendTransactionServer interface {
	Send(*TransactionResponse) error
	Recv() (*eth.Transaction, error)
	grpc.ServerStream
}

type API_SendTransactionV2Client added in v1.9.0 

type API_SendTransactionV2Client interface {
	Send(*TransactionMsg) error
	Recv() (*TransactionResponse, error)
	grpc.ClientStream
}

type API_SendTransactionV2Server added in v1.9.0 

type API_SendTransactionV2Server interface {
	Send(*TransactionResponse) error
	Recv() (*TransactionMsg, error)
	grpc.ServerStream
}

type API_SubmitBlockStreamClient added in v1.8.0 

type API_SubmitBlockStreamClient interface {
	Send(*BlockSubmissionMsg) error
	Recv() (*BlockSubmissionResponse, error)
	grpc.ClientStream
}

type API_SubmitBlockStreamServer added in v1.8.0 

type API_SubmitBlockStreamServer interface {
	Send(*BlockSubmissionResponse) error
	Recv() (*BlockSubmissionMsg, error)
	grpc.ServerStream
}

type API_SubscribeBeaconBlocksClient added in v1.6.0 

type API_SubscribeBeaconBlocksClient interface {
	Recv() (*eth.CompactBeaconBlock, error)
	grpc.ClientStream
}

type API_SubscribeBeaconBlocksServer added in v1.6.0 

type API_SubscribeBeaconBlocksServer interface {
	Send(*eth.CompactBeaconBlock) error
	grpc.ServerStream
}

type API_SubscribeBeaconBlocksV2Client added in v1.9.0 

type API_SubscribeBeaconBlocksV2Client interface {
	Recv() (*BeaconBlockMsg, error)
	grpc.ClientStream
}

type API_SubscribeBeaconBlocksV2Server added in v1.9.0 

type API_SubscribeBeaconBlocksV2Server interface {
	Send(*BeaconBlockMsg) error
	grpc.ServerStream
}

type API_SubscribeExecutionHeadersClient added in v1.6.0 

type API_SubscribeExecutionHeadersClient interface {
	Recv() (*eth.ExecutionPayloadHeader, error)
	grpc.ClientStream
}

type API_SubscribeExecutionHeadersServer added in v1.6.0 

type API_SubscribeExecutionHeadersServer interface {
	Send(*eth.ExecutionPayloadHeader) error
	grpc.ServerStream
}

type API_SubscribeExecutionPayloadsClient added in v1.6.0 

type API_SubscribeExecutionPayloadsClient interface {
	Recv() (*eth.ExecutionPayload, error)
	grpc.ClientStream
}

type API_SubscribeExecutionPayloadsServer added in v1.6.0 

type API_SubscribeExecutionPayloadsServer interface {
	Send(*eth.ExecutionPayload) error
	grpc.ServerStream
}

type API_SubscribeExecutionPayloadsV2Client added in v1.9.0 

type API_SubscribeExecutionPayloadsV2Client interface {
	Recv() (*ExecutionPayloadMsg, error)
	grpc.ClientStream
}

type API_SubscribeExecutionPayloadsV2Server added in v1.9.0 

type API_SubscribeExecutionPayloadsV2Server interface {
	Send(*ExecutionPayloadMsg) error
	grpc.ServerStream
}

type API_SubscribeNewBlobTxsClient added in v1.9.1 

type API_SubscribeNewBlobTxsClient interface {
	Recv() (*TransactionWithSenderMsg, error)
	grpc.ClientStream
}

type API_SubscribeNewBlobTxsServer added in v1.9.1 

type API_SubscribeNewBlobTxsServer interface {
	Send(*TransactionWithSenderMsg) error
	grpc.ServerStream
}

type API_SubscribeNewTxsClient 

type API_SubscribeNewTxsClient interface {
	Recv() (*eth.Transaction, error)
	grpc.ClientStream
}

type API_SubscribeNewTxsServer 

type API_SubscribeNewTxsServer interface {
	Send(*eth.Transaction) error
	grpc.ServerStream
}

type API_SubscribeNewTxsV2Client added in v1.4.0 

type API_SubscribeNewTxsV2Client interface {
	Recv() (*TransactionWithSenderMsg, error)
	grpc.ClientStream
}

type API_SubscribeNewTxsV2Server added in v1.4.0 

type API_SubscribeNewTxsV2Server interface {
	Send(*TransactionWithSenderMsg) error
	grpc.ServerStream
}

type BeaconBlockMsg added in v1.9.0 

type BeaconBlockMsg struct {

	// The beacon block version.
	DataVersion uint32 `protobuf:"varint,1,opt,name=data_version,json=dataVersion,proto3" json:"data_version,omitempty"`
	// The SSZ encoded beacon block.
	SszBlock []byte `protobuf:"bytes,2,opt,name=ssz_block,json=sszBlock,proto3" json:"ssz_block,omitempty"`
	// contains filtered or unexported fields
}

func (*BeaconBlockMsg) Descriptor deprecated added in v1.9.0 

func (*BeaconBlockMsg) Descriptor() ([]byte, []int)

Deprecated: Use BeaconBlockMsg.ProtoReflect.Descriptor instead.

func (*BeaconBlockMsg) GetDataVersion added in v1.9.0 

func (x *BeaconBlockMsg) GetDataVersion() uint32

func (*BeaconBlockMsg) GetSszBlock added in v1.9.0 

func (x *BeaconBlockMsg) GetSszBlock() []byte

func (*BeaconBlockMsg) ProtoMessage added in v1.9.0 

func (*BeaconBlockMsg) ProtoMessage()

func (*BeaconBlockMsg) ProtoReflect added in v1.9.0 

func (x *BeaconBlockMsg) ProtoReflect() protoreflect.Message

func (*BeaconBlockMsg) Reset added in v1.9.0 

func (x *BeaconBlockMsg) Reset()

func (*BeaconBlockMsg) String added in v1.9.0 

func (x *BeaconBlockMsg) String() string

type BlockFilter 

type BlockFilter struct {
	Producer string `protobuf:"bytes,1,opt,name=producer,proto3" json:"producer,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockFilter) Descriptor deprecated 

func (*BlockFilter) Descriptor() ([]byte, []int)

Deprecated: Use BlockFilter.ProtoReflect.Descriptor instead.

func (*BlockFilter) GetProducer 

func (x *BlockFilter) GetProducer() string

func (*BlockFilter) ProtoMessage 

func (*BlockFilter) ProtoMessage()

func (*BlockFilter) ProtoReflect 

func (x *BlockFilter) ProtoReflect() protoreflect.Message

func (*BlockFilter) Reset 

func (x *BlockFilter) Reset()

func (*BlockFilter) String 

func (x *BlockFilter) String() string

type BlockSubmissionMsg added in v1.8.0 

type BlockSubmissionMsg struct {
	SszBlock []byte `protobuf:"bytes,1,opt,name=ssz_block,json=sszBlock,proto3" json:"ssz_block,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockSubmissionMsg) Descriptor deprecated added in v1.8.0 

func (*BlockSubmissionMsg) Descriptor() ([]byte, []int)

Deprecated: Use BlockSubmissionMsg.ProtoReflect.Descriptor instead.

func (*BlockSubmissionMsg) GetSszBlock added in v1.8.0 

func (x *BlockSubmissionMsg) GetSszBlock() []byte

func (*BlockSubmissionMsg) ProtoMessage added in v1.8.0 

func (*BlockSubmissionMsg) ProtoMessage()

func (*BlockSubmissionMsg) ProtoReflect added in v1.8.0 

func (x *BlockSubmissionMsg) ProtoReflect() protoreflect.Message

func (*BlockSubmissionMsg) Reset added in v1.8.0 

func (x *BlockSubmissionMsg) Reset()

func (*BlockSubmissionMsg) String added in v1.8.0 

func (x *BlockSubmissionMsg) String() string

type BlockSubmissionResponse added in v1.8.0 

type BlockSubmissionResponse struct {

	// The slot of the block.
	Slot uint64 `protobuf:"varint,1,opt,name=slot,proto3" json:"slot,omitempty"`
	// The re-calculated state root after reconstructing the block.
	StateRoot []byte `protobuf:"bytes,2,opt,name=state_root,json=stateRoot,proto3" json:"state_root,omitempty"`
	// Timestamp in microseconds.
	Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockSubmissionResponse) Descriptor deprecated added in v1.8.0 

func (*BlockSubmissionResponse) Descriptor() ([]byte, []int)

Deprecated: Use BlockSubmissionResponse.ProtoReflect.Descriptor instead.

func (*BlockSubmissionResponse) GetSlot added in v1.8.0 

func (x *BlockSubmissionResponse) GetSlot() uint64

func (*BlockSubmissionResponse) GetStateRoot added in v1.8.0 

func (x *BlockSubmissionResponse) GetStateRoot() []byte

func (*BlockSubmissionResponse) GetTimestamp added in v1.8.0 

func (x *BlockSubmissionResponse) GetTimestamp() uint64

func (*BlockSubmissionResponse) ProtoMessage added in v1.8.0 

func (*BlockSubmissionResponse) ProtoMessage()

func (*BlockSubmissionResponse) ProtoReflect added in v1.8.0 

func (x *BlockSubmissionResponse) ProtoReflect() protoreflect.Message

func (*BlockSubmissionResponse) Reset added in v1.8.0 

func (x *BlockSubmissionResponse) Reset()

func (*BlockSubmissionResponse) String added in v1.8.0 

func (x *BlockSubmissionResponse) String() string

type ExecutionPayloadMsg added in v1.9.0 

type ExecutionPayloadMsg struct {

	// The fork data version.
	DataVersion uint32 `protobuf:"varint,1,opt,name=data_version,json=dataVersion,proto3" json:"data_version,omitempty"`
	// The SSZ encoded execution payload.
	SszPayload []byte `protobuf:"bytes,2,opt,name=ssz_payload,json=sszPayload,proto3" json:"ssz_payload,omitempty"`
	// contains filtered or unexported fields
}

/ An SSZ encoded execution payload.

func (*ExecutionPayloadMsg) Descriptor deprecated added in v1.9.0 

func (*ExecutionPayloadMsg) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionPayloadMsg.ProtoReflect.Descriptor instead.

func (*ExecutionPayloadMsg) GetDataVersion added in v1.9.0 

func (x *ExecutionPayloadMsg) GetDataVersion() uint32

func (*ExecutionPayloadMsg) GetSszPayload added in v1.9.0 

func (x *ExecutionPayloadMsg) GetSszPayload() []byte

func (*ExecutionPayloadMsg) ProtoMessage added in v1.9.0 

func (*ExecutionPayloadMsg) ProtoMessage()

func (*ExecutionPayloadMsg) ProtoReflect added in v1.9.0 

func (x *ExecutionPayloadMsg) ProtoReflect() protoreflect.Message

func (*ExecutionPayloadMsg) Reset added in v1.9.0 

func (x *ExecutionPayloadMsg) Reset()

func (*ExecutionPayloadMsg) String added in v1.9.0 

func (x *ExecutionPayloadMsg) String() string

type RawTxMsg 

type RawTxMsg struct {
	RawTx []byte `protobuf:"bytes,1,opt,name=rawTx,proto3" json:"rawTx,omitempty"`
	// contains filtered or unexported fields
}

func (*RawTxMsg) Descriptor deprecated 

func (*RawTxMsg) Descriptor() ([]byte, []int)

Deprecated: Use RawTxMsg.ProtoReflect.Descriptor instead.

func (*RawTxMsg) GetRawTx 

func (x *RawTxMsg) GetRawTx() []byte

func (*RawTxMsg) ProtoMessage 

func (*RawTxMsg) ProtoMessage()

func (*RawTxMsg) ProtoReflect 

func (x *RawTxMsg) ProtoReflect() protoreflect.Message

func (*RawTxMsg) Reset 

func (x *RawTxMsg) Reset()

func (*RawTxMsg) String 

func (x *RawTxMsg) String() string

type RawTxSequenceMsg added in v1.5.0 

type RawTxSequenceMsg struct {
	RawTxs [][]byte `protobuf:"bytes,1,rep,name=raw_txs,json=rawTxs,proto3" json:"raw_txs,omitempty"`
	// contains filtered or unexported fields
}

func (*RawTxSequenceMsg) Descriptor deprecated added in v1.5.0 

func (*RawTxSequenceMsg) Descriptor() ([]byte, []int)

Deprecated: Use RawTxSequenceMsg.ProtoReflect.Descriptor instead.

func (*RawTxSequenceMsg) GetRawTxs added in v1.5.0 

func (x *RawTxSequenceMsg) GetRawTxs() [][]byte

func (*RawTxSequenceMsg) ProtoMessage added in v1.5.0 

func (*RawTxSequenceMsg) ProtoMessage()

func (*RawTxSequenceMsg) ProtoReflect added in v1.5.0 

func (x *RawTxSequenceMsg) ProtoReflect() protoreflect.Message

func (*RawTxSequenceMsg) Reset added in v1.5.0 

func (x *RawTxSequenceMsg) Reset()

func (*RawTxSequenceMsg) String added in v1.5.0 

func (x *RawTxSequenceMsg) String() string

type TransactionMsg added in v1.9.0 

type TransactionMsg struct {

	// / The enveloped, RLP-encoded transaction bytes.
	RlpTransaction []byte `protobuf:"bytes,1,opt,name=rlp_transaction,json=rlpTransaction,proto3" json:"rlp_transaction,omitempty"`
	// contains filtered or unexported fields
}

/ An enveloped, RLP-encoded transaction.

func (*TransactionMsg) Descriptor deprecated added in v1.9.0 

func (*TransactionMsg) Descriptor() ([]byte, []int)

Deprecated: Use TransactionMsg.ProtoReflect.Descriptor instead.

func (*TransactionMsg) GetRlpTransaction added in v1.9.0 

func (x *TransactionMsg) GetRlpTransaction() []byte

func (*TransactionMsg) ProtoMessage added in v1.9.0 

func (*TransactionMsg) ProtoMessage()

func (*TransactionMsg) ProtoReflect added in v1.9.0 

func (x *TransactionMsg) ProtoReflect() protoreflect.Message

func (*TransactionMsg) Reset added in v1.9.0 

func (x *TransactionMsg) Reset()

func (*TransactionMsg) String added in v1.9.0 

func (x *TransactionMsg) String() string

type TransactionResponse 

type TransactionResponse struct {
	Hash      string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionResponse) Descriptor deprecated 

func (*TransactionResponse) Descriptor() ([]byte, []int)

Deprecated: Use TransactionResponse.ProtoReflect.Descriptor instead.

func (*TransactionResponse) GetHash 

func (x *TransactionResponse) GetHash() string

func (*TransactionResponse) GetTimestamp 

func (x *TransactionResponse) GetTimestamp() int64

func (*TransactionResponse) ProtoMessage 

func (*TransactionResponse) ProtoMessage()

func (*TransactionResponse) ProtoReflect 

func (x *TransactionResponse) ProtoReflect() protoreflect.Message

func (*TransactionResponse) Reset 

func (x *TransactionResponse) Reset()

func (*TransactionResponse) String 

func (x *TransactionResponse) String() string

type TransactionWithSenderMsg added in v1.9.0 

type TransactionWithSenderMsg struct {

	// / The enveloped, RLP-encoded transaction bytes.
	RlpTransaction []byte `protobuf:"bytes,1,opt,name=rlp_transaction,json=rlpTransaction,proto3" json:"rlp_transaction,omitempty"`
	// / The address of the sender / signer.
	Sender []byte `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// contains filtered or unexported fields
}

func (*TransactionWithSenderMsg) Descriptor deprecated added in v1.9.0 

func (*TransactionWithSenderMsg) Descriptor() ([]byte, []int)

Deprecated: Use TransactionWithSenderMsg.ProtoReflect.Descriptor instead.

func (*TransactionWithSenderMsg) GetRlpTransaction added in v1.9.0 

func (x *TransactionWithSenderMsg) GetRlpTransaction() []byte

func (*TransactionWithSenderMsg) GetSender added in v1.9.0 

func (x *TransactionWithSenderMsg) GetSender() []byte

func (*TransactionWithSenderMsg) ProtoMessage added in v1.9.0 

func (*TransactionWithSenderMsg) ProtoMessage()

func (*TransactionWithSenderMsg) ProtoReflect added in v1.9.0 

func (x *TransactionWithSenderMsg) ProtoReflect() protoreflect.Message

func (*TransactionWithSenderMsg) Reset added in v1.9.0 

func (x *TransactionWithSenderMsg) Reset()

func (*TransactionWithSenderMsg) String added in v1.9.0 

func (x *TransactionWithSenderMsg) String() string

type TxFilter 

type TxFilter struct {
	Encoded []byte `protobuf:"bytes,1,opt,name=encoded,proto3" json:"encoded,omitempty"`
	// contains filtered or unexported fields
}

func (*TxFilter) Descriptor deprecated 

func (*TxFilter) Descriptor() ([]byte, []int)

Deprecated: Use TxFilter.ProtoReflect.Descriptor instead.

func (*TxFilter) GetEncoded added in v1.5.0 

func (x *TxFilter) GetEncoded() []byte

func (*TxFilter) ProtoMessage 

func (*TxFilter) ProtoMessage()

func (*TxFilter) ProtoReflect 

func (x *TxFilter) ProtoReflect() protoreflect.Message

func (*TxFilter) Reset 

func (x *TxFilter) Reset()

func (*TxFilter) String 

func (x *TxFilter) String() string

type TxSequenceMsg added in v1.5.0 

type TxSequenceMsg struct {
	Sequence []*eth.Transaction `protobuf:"bytes,1,rep,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

func (*TxSequenceMsg) Descriptor deprecated added in v1.5.0 

func (*TxSequenceMsg) Descriptor() ([]byte, []int)

Deprecated: Use TxSequenceMsg.ProtoReflect.Descriptor instead.

func (*TxSequenceMsg) GetSequence added in v1.5.0 

func (x *TxSequenceMsg) GetSequence() []*eth.Transaction

func (*TxSequenceMsg) ProtoMessage added in v1.5.0 

func (*TxSequenceMsg) ProtoMessage()

func (*TxSequenceMsg) ProtoReflect added in v1.5.0 

func (x *TxSequenceMsg) ProtoReflect() protoreflect.Message

func (*TxSequenceMsg) Reset added in v1.5.0 

func (x *TxSequenceMsg) Reset()

func (*TxSequenceMsg) String added in v1.5.0 

func (x *TxSequenceMsg) String() string

type TxSequenceMsgV2 added in v1.9.0 

type TxSequenceMsgV2 struct {

	// / list of enveloped, RLP-encoded transaction bytes.
	Sequence [][]byte `protobuf:"bytes,1,rep,name=sequence,proto3" json:"sequence,omitempty"`
	// contains filtered or unexported fields
}

/ A message containing a sequence of enveloped, RLP-encoded transactions.

func (*TxSequenceMsgV2) Descriptor deprecated added in v1.9.0 

func (*TxSequenceMsgV2) Descriptor() ([]byte, []int)

Deprecated: Use TxSequenceMsgV2.ProtoReflect.Descriptor instead.

func (*TxSequenceMsgV2) GetSequence added in v1.9.0 

func (x *TxSequenceMsgV2) GetSequence() [][]byte

func (*TxSequenceMsgV2) ProtoMessage added in v1.9.0 

func (*TxSequenceMsgV2) ProtoMessage()

func (*TxSequenceMsgV2) ProtoReflect added in v1.9.0 

func (x *TxSequenceMsgV2) ProtoReflect() protoreflect.Message

func (*TxSequenceMsgV2) Reset added in v1.9.0 

func (x *TxSequenceMsgV2) Reset()

func (*TxSequenceMsgV2) String added in v1.9.0 

func (x *TxSequenceMsgV2) String() string

type TxSequenceResponse added in v1.5.0 

type TxSequenceResponse struct {
	SequenceResponse []*TransactionResponse `protobuf:"bytes,1,rep,name=sequence_response,json=sequenceResponse,proto3" json:"sequence_response,omitempty"`
	// contains filtered or unexported fields
}

func (*TxSequenceResponse) Descriptor deprecated added in v1.5.0 

func (*TxSequenceResponse) Descriptor() ([]byte, []int)

Deprecated: Use TxSequenceResponse.ProtoReflect.Descriptor instead.

func (*TxSequenceResponse) GetSequenceResponse added in v1.5.0 

func (x *TxSequenceResponse) GetSequenceResponse() []*TransactionResponse

func (*TxSequenceResponse) ProtoMessage added in v1.5.0 

func (*TxSequenceResponse) ProtoMessage()

func (*TxSequenceResponse) ProtoReflect added in v1.5.0 

func (x *TxSequenceResponse) ProtoReflect() protoreflect.Message

func (*TxSequenceResponse) Reset added in v1.5.0 

func (x *TxSequenceResponse) Reset()

func (*TxSequenceResponse) String added in v1.5.0 

func (x *TxSequenceResponse) String() string

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedAPIServer) SendRawTransaction 

func (UnimplementedAPIServer) SendRawTransaction(API_SendRawTransactionServer) error

func (UnimplementedAPIServer) SendRawTransactionSequence added in v1.5.0 

func (UnimplementedAPIServer) SendRawTransactionSequence(API_SendRawTransactionSequenceServer) error

func (UnimplementedAPIServer) SendTransaction 

func (UnimplementedAPIServer) SendTransaction(API_SendTransactionServer) error

func (UnimplementedAPIServer) SendTransactionSequence added in v1.5.0 

func (UnimplementedAPIServer) SendTransactionSequence(API_SendTransactionSequenceServer) error

func (UnimplementedAPIServer) SendTransactionSequenceV2 added in v1.9.0 

func (UnimplementedAPIServer) SendTransactionSequenceV2(API_SendTransactionSequenceV2Server) error

func (UnimplementedAPIServer) SendTransactionV2 added in v1.9.0 

func (UnimplementedAPIServer) SendTransactionV2(API_SendTransactionV2Server) error

func (UnimplementedAPIServer) SubmitBlockStream added in v1.8.0 

func (UnimplementedAPIServer) SubmitBlockStream(API_SubmitBlockStreamServer) error

func (UnimplementedAPIServer) SubscribeBeaconBlocks added in v1.6.0 

func (UnimplementedAPIServer) SubscribeBeaconBlocks(*emptypb.Empty, API_SubscribeBeaconBlocksServer) error

func (UnimplementedAPIServer) SubscribeBeaconBlocksV2 added in v1.9.0 

func (UnimplementedAPIServer) SubscribeBeaconBlocksV2(*emptypb.Empty, API_SubscribeBeaconBlocksV2Server) error

func (UnimplementedAPIServer) SubscribeExecutionHeaders added in v1.6.0 

func (UnimplementedAPIServer) SubscribeExecutionHeaders(*emptypb.Empty, API_SubscribeExecutionHeadersServer) error

func (UnimplementedAPIServer) SubscribeExecutionPayloads added in v1.6.0 

func (UnimplementedAPIServer) SubscribeExecutionPayloads(*emptypb.Empty, API_SubscribeExecutionPayloadsServer) error

func (UnimplementedAPIServer) SubscribeExecutionPayloadsV2 added in v1.9.0 

func (UnimplementedAPIServer) SubscribeExecutionPayloadsV2(*emptypb.Empty, API_SubscribeExecutionPayloadsV2Server) error

func (UnimplementedAPIServer) SubscribeNewBlobTxs added in v1.9.1 

func (UnimplementedAPIServer) SubscribeNewBlobTxs(*emptypb.Empty, API_SubscribeNewBlobTxsServer) error

func (UnimplementedAPIServer) SubscribeNewTxs 

func (UnimplementedAPIServer) SubscribeNewTxs(*TxFilter, API_SubscribeNewTxsServer) error

func (UnimplementedAPIServer) SubscribeNewTxsV2 added in v1.4.0 

func (UnimplementedAPIServer) SubscribeNewTxsV2(*TxFilter, API_SubscribeNewTxsV2Server) error

type UnsafeAPIServer 

type UnsafeAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.