mempoolpb

package
v0.0.0-...-9727c61 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_mempoolpb_mempoolpb_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BatchIDResponse 

type BatchIDResponse struct {
	BatchId []byte                `protobuf:"bytes,1,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	Origin  *RequestBatchIDOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

BatchIDResponse is a response to a RequestBatchID event.

func (*BatchIDResponse) Descriptor deprecated 

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

Deprecated: Use BatchIDResponse.ProtoReflect.Descriptor instead.

func (*BatchIDResponse) GetBatchId 

func (x *BatchIDResponse) GetBatchId() []byte

func (*BatchIDResponse) GetOrigin 

func (x *BatchIDResponse) GetOrigin() *RequestBatchIDOrigin

func (*BatchIDResponse) ProtoMessage 

func (*BatchIDResponse) ProtoMessage()

func (*BatchIDResponse) ProtoReflect 

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

func (*BatchIDResponse) Reset 

func (x *BatchIDResponse) Reset()

func (*BatchIDResponse) String 

func (x *BatchIDResponse) String() string

type BatchTimeout 

type BatchTimeout struct {
	BatchReqID uint64 `protobuf:"varint,1,opt,name=batchReqID,proto3" json:"batchReqID,omitempty"`
	// contains filtered or unexported fields
}

BatchTimeout is sent by the timer to the mempool when a batch request times out.

func (*BatchTimeout) Descriptor deprecated 

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

Deprecated: Use BatchTimeout.ProtoReflect.Descriptor instead.

func (*BatchTimeout) GetBatchReqID 

func (x *BatchTimeout) GetBatchReqID() uint64

func (*BatchTimeout) ProtoMessage 

func (*BatchTimeout) ProtoMessage()

func (*BatchTimeout) ProtoReflect 

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

func (*BatchTimeout) Reset 

func (x *BatchTimeout) Reset()

func (*BatchTimeout) String 

func (x *BatchTimeout) String() string

type Event 

type Event struct {

	// Types that are assignable to Type:
	//	*Event_RequestBatch
	//	*Event_NewBatch
	//	*Event_RequestTransactions
	//	*Event_TransactionsResponse
	//	*Event_RequestTransactionIds
	//	*Event_TransactionIdsResponse
	//	*Event_RequestBatchId
	//	*Event_BatchIdResponse
	//	*Event_NewTransactions
	//	*Event_BatchTimeout
	//	*Event_NewEpoch
	Type isEvent_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetBatchIdResponse 

func (x *Event) GetBatchIdResponse() *BatchIDResponse

func (*Event) GetBatchTimeout 

func (x *Event) GetBatchTimeout() *BatchTimeout

func (*Event) GetNewBatch 

func (x *Event) GetNewBatch() *NewBatch

func (*Event) GetNewEpoch 

func (x *Event) GetNewEpoch() *NewEpoch

func (*Event) GetNewTransactions 

func (x *Event) GetNewTransactions() *NewTransactions

func (*Event) GetRequestBatch 

func (x *Event) GetRequestBatch() *RequestBatch

func (*Event) GetRequestBatchId 

func (x *Event) GetRequestBatchId() *RequestBatchID

func (*Event) GetRequestTransactionIds 

func (x *Event) GetRequestTransactionIds() *RequestTransactionIDs

func (*Event) GetRequestTransactions 

func (x *Event) GetRequestTransactions() *RequestTransactions

func (*Event) GetTransactionIdsResponse 

func (x *Event) GetTransactionIdsResponse() *TransactionIDsResponse

func (*Event) GetTransactionsResponse 

func (x *Event) GetTransactionsResponse() *TransactionsResponse

func (*Event) GetType 

func (m *Event) GetType() isEvent_Type

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) ReflectTypeOptions 

func (*Event) ReflectTypeOptions() []reflect.Type

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_BatchIdResponse 

type Event_BatchIdResponse struct {
	BatchIdResponse *BatchIDResponse `protobuf:"bytes,8,opt,name=batch_id_response,json=batchIdResponse,proto3,oneof"`
}

func (*Event_BatchIdResponse) Unwrap 

func (w *Event_BatchIdResponse) Unwrap() *BatchIDResponse

type Event_BatchTimeout 

type Event_BatchTimeout struct {
	BatchTimeout *BatchTimeout `protobuf:"bytes,10,opt,name=batch_timeout,json=batchTimeout,proto3,oneof"`
}

func (*Event_BatchTimeout) Unwrap 

func (w *Event_BatchTimeout) Unwrap() *BatchTimeout

type Event_NewBatch 

type Event_NewBatch struct {
	NewBatch *NewBatch `protobuf:"bytes,2,opt,name=new_batch,json=newBatch,proto3,oneof"`
}

func (*Event_NewBatch) Unwrap 

func (w *Event_NewBatch) Unwrap() *NewBatch

type Event_NewEpoch 

type Event_NewEpoch struct {
	NewEpoch *NewEpoch `protobuf:"bytes,11,opt,name=new_epoch,json=newEpoch,proto3,oneof"`
}

func (*Event_NewEpoch) Unwrap 

func (w *Event_NewEpoch) Unwrap() *NewEpoch

type Event_NewTransactions 

type Event_NewTransactions struct {
	NewTransactions *NewTransactions `protobuf:"bytes,9,opt,name=new_transactions,json=newTransactions,proto3,oneof"`
}

func (*Event_NewTransactions) Unwrap 

func (w *Event_NewTransactions) Unwrap() *NewTransactions

type Event_RequestBatch 

type Event_RequestBatch struct {
	RequestBatch *RequestBatch `protobuf:"bytes,1,opt,name=request_batch,json=requestBatch,proto3,oneof"`
}

func (*Event_RequestBatch) Unwrap 

func (w *Event_RequestBatch) Unwrap() *RequestBatch

type Event_RequestBatchId 

type Event_RequestBatchId struct {
	RequestBatchId *RequestBatchID `protobuf:"bytes,7,opt,name=request_batch_id,json=requestBatchId,proto3,oneof"`
}

func (*Event_RequestBatchId) Unwrap 

func (w *Event_RequestBatchId) Unwrap() *RequestBatchID

type Event_RequestTransactionIds 

type Event_RequestTransactionIds struct {
	RequestTransactionIds *RequestTransactionIDs `protobuf:"bytes,5,opt,name=request_transaction_ids,json=requestTransactionIds,proto3,oneof"`
}

func (*Event_RequestTransactionIds) Unwrap 

func (w *Event_RequestTransactionIds) Unwrap() *RequestTransactionIDs

type Event_RequestTransactions 

type Event_RequestTransactions struct {
	RequestTransactions *RequestTransactions `protobuf:"bytes,3,opt,name=request_transactions,json=requestTransactions,proto3,oneof"`
}

func (*Event_RequestTransactions) Unwrap 

func (w *Event_RequestTransactions) Unwrap() *RequestTransactions

type Event_TransactionIdsResponse 

type Event_TransactionIdsResponse struct {
	TransactionIdsResponse *TransactionIDsResponse `protobuf:"bytes,6,opt,name=transaction_ids_response,json=transactionIdsResponse,proto3,oneof"`
}

func (*Event_TransactionIdsResponse) Unwrap 

func (w *Event_TransactionIdsResponse) Unwrap() *TransactionIDsResponse

type Event_TransactionsResponse 

type Event_TransactionsResponse struct {
	TransactionsResponse *TransactionsResponse `protobuf:"bytes,4,opt,name=transactions_response,json=transactionsResponse,proto3,oneof"`
}

func (*Event_TransactionsResponse) Unwrap 

func (w *Event_TransactionsResponse) Unwrap() *TransactionsResponse

type Event_Type 

type Event_Type = isEvent_Type

type Event_TypeWrapper 

type Event_TypeWrapper[T any] interface {
	Event_Type
	Unwrap() *T
}

type NewBatch 

type NewBatch struct {
	TxIds  [][]byte                 `protobuf:"bytes,1,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"`
	Txs    []*trantorpb.Transaction `protobuf:"bytes,2,rep,name=txs,proto3" json:"txs,omitempty"`
	Origin *RequestBatchOrigin      `protobuf:"bytes,3,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

NewBatch is a response to a RequestBatch event.

func (*NewBatch) Descriptor deprecated 

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

Deprecated: Use NewBatch.ProtoReflect.Descriptor instead.

func (*NewBatch) GetOrigin 

func (x *NewBatch) GetOrigin() *RequestBatchOrigin

func (*NewBatch) GetTxIds 

func (x *NewBatch) GetTxIds() [][]byte

func (*NewBatch) GetTxs 

func (x *NewBatch) GetTxs() []*trantorpb.Transaction

func (*NewBatch) ProtoMessage 

func (*NewBatch) ProtoMessage()

func (*NewBatch) ProtoReflect 

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

func (*NewBatch) Reset 

func (x *NewBatch) Reset()

func (*NewBatch) String 

func (x *NewBatch) String() string

type NewEpoch 

type NewEpoch struct {
	EpochNr        uint64                    `protobuf:"varint,1,opt,name=epoch_nr,json=epochNr,proto3" json:"epoch_nr,omitempty"`
	ClientProgress *trantorpb.ClientProgress `protobuf:"bytes,2,opt,name=client_progress,json=clientProgress,proto3" json:"client_progress,omitempty"`
	// contains filtered or unexported fields
}

func (*NewEpoch) Descriptor deprecated 

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

Deprecated: Use NewEpoch.ProtoReflect.Descriptor instead.

func (*NewEpoch) GetClientProgress 

func (x *NewEpoch) GetClientProgress() *trantorpb.ClientProgress

func (*NewEpoch) GetEpochNr 

func (x *NewEpoch) GetEpochNr() uint64

func (*NewEpoch) ProtoMessage 

func (*NewEpoch) ProtoMessage()

func (*NewEpoch) ProtoReflect 

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

func (*NewEpoch) Reset 

func (x *NewEpoch) Reset()

func (*NewEpoch) String 

func (x *NewEpoch) String() string

type NewTransactions 

type NewTransactions struct {
	Transactions []*trantorpb.Transaction `protobuf:"bytes,1,rep,name=transactions,proto3" json:"transactions,omitempty"`
	// contains filtered or unexported fields
}

func (*NewTransactions) Descriptor deprecated 

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

Deprecated: Use NewTransactions.ProtoReflect.Descriptor instead.

func (*NewTransactions) GetTransactions 

func (x *NewTransactions) GetTransactions() []*trantorpb.Transaction

func (*NewTransactions) ProtoMessage 

func (*NewTransactions) ProtoMessage()

func (*NewTransactions) ProtoReflect 

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

func (*NewTransactions) Reset 

func (x *NewTransactions) Reset()

func (*NewTransactions) String 

func (x *NewTransactions) String() string

type RequestBatch 

type RequestBatch struct {
	Epoch  uint64              `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Origin *RequestBatchOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

RequestBatch is used by the availability layer to request a new batch of transactions from the mempool.

func (*RequestBatch) Descriptor deprecated 

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

Deprecated: Use RequestBatch.ProtoReflect.Descriptor instead.

func (*RequestBatch) GetEpoch 

func (x *RequestBatch) GetEpoch() uint64

func (*RequestBatch) GetOrigin 

func (x *RequestBatch) GetOrigin() *RequestBatchOrigin

func (*RequestBatch) ProtoMessage 

func (*RequestBatch) ProtoMessage()

func (*RequestBatch) ProtoReflect 

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

func (*RequestBatch) Reset 

func (x *RequestBatch) Reset()

func (*RequestBatch) String 

func (x *RequestBatch) String() string

type RequestBatchID 

type RequestBatchID struct {
	TxIds  [][]byte              `protobuf:"bytes,1,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"`
	Origin *RequestBatchIDOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

RequestBatchID allows other modules to request the mempool module to compute the ID of a batch. It is possible that some transactions in the batch are not present in the mempool.

func (*RequestBatchID) Descriptor deprecated 

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

Deprecated: Use RequestBatchID.ProtoReflect.Descriptor instead.

func (*RequestBatchID) GetOrigin 

func (x *RequestBatchID) GetOrigin() *RequestBatchIDOrigin

func (*RequestBatchID) GetTxIds 

func (x *RequestBatchID) GetTxIds() [][]byte

func (*RequestBatchID) ProtoMessage 

func (*RequestBatchID) ProtoMessage()

func (*RequestBatchID) ProtoReflect 

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

func (*RequestBatchID) Reset 

func (x *RequestBatchID) Reset()

func (*RequestBatchID) String 

func (x *RequestBatchID) String() string

type RequestBatchIDOrigin 

type RequestBatchIDOrigin struct {
	Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// Types that are assignable to Type:
	//	*RequestBatchIDOrigin_ContextStore
	//	*RequestBatchIDOrigin_Dsl
	Type isRequestBatchIDOrigin_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

func (*RequestBatchIDOrigin) Descriptor deprecated 

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

Deprecated: Use RequestBatchIDOrigin.ProtoReflect.Descriptor instead.

func (*RequestBatchIDOrigin) GetContextStore 

func (x *RequestBatchIDOrigin) GetContextStore() *contextstorepb.Origin

func (*RequestBatchIDOrigin) GetDsl 

func (x *RequestBatchIDOrigin) GetDsl() *dslpb.Origin

func (*RequestBatchIDOrigin) GetModule 

func (x *RequestBatchIDOrigin) GetModule() string

func (*RequestBatchIDOrigin) GetType 

func (m *RequestBatchIDOrigin) GetType() isRequestBatchIDOrigin_Type

func (*RequestBatchIDOrigin) ProtoMessage 

func (*RequestBatchIDOrigin) ProtoMessage()

func (*RequestBatchIDOrigin) ProtoReflect 

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

func (*RequestBatchIDOrigin) ReflectTypeOptions 

func (*RequestBatchIDOrigin) ReflectTypeOptions() []reflect.Type

func (*RequestBatchIDOrigin) Reset 

func (x *RequestBatchIDOrigin) Reset()

func (*RequestBatchIDOrigin) String 

func (x *RequestBatchIDOrigin) String() string

type RequestBatchIDOrigin_ContextStore 

type RequestBatchIDOrigin_ContextStore struct {
	ContextStore *contextstorepb.Origin `protobuf:"bytes,2,opt,name=context_store,json=contextStore,proto3,oneof"`
}

func (*RequestBatchIDOrigin_ContextStore) Unwrap 

func (w *RequestBatchIDOrigin_ContextStore) Unwrap() *contextstorepb.Origin

type RequestBatchIDOrigin_Dsl 

type RequestBatchIDOrigin_Dsl struct {
	Dsl *dslpb.Origin `protobuf:"bytes,3,opt,name=dsl,proto3,oneof"`
}

func (*RequestBatchIDOrigin_Dsl) Unwrap 

func (w *RequestBatchIDOrigin_Dsl) Unwrap() *dslpb.Origin

type RequestBatchIDOrigin_Type 

type RequestBatchIDOrigin_Type = isRequestBatchIDOrigin_Type

type RequestBatchIDOrigin_TypeWrapper 

type RequestBatchIDOrigin_TypeWrapper[T any] interface {
	RequestBatchIDOrigin_Type
	Unwrap() *T
}

type RequestBatchOrigin 

type RequestBatchOrigin struct {
	Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// Types that are assignable to Type:
	//	*RequestBatchOrigin_ContextStore
	//	*RequestBatchOrigin_Dsl
	Type isRequestBatchOrigin_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

func (*RequestBatchOrigin) Descriptor deprecated 

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

Deprecated: Use RequestBatchOrigin.ProtoReflect.Descriptor instead.

func (*RequestBatchOrigin) GetContextStore 

func (x *RequestBatchOrigin) GetContextStore() *contextstorepb.Origin

func (*RequestBatchOrigin) GetDsl 

func (x *RequestBatchOrigin) GetDsl() *dslpb.Origin

func (*RequestBatchOrigin) GetModule 

func (x *RequestBatchOrigin) GetModule() string

func (*RequestBatchOrigin) GetType 

func (m *RequestBatchOrigin) GetType() isRequestBatchOrigin_Type

func (*RequestBatchOrigin) ProtoMessage 

func (*RequestBatchOrigin) ProtoMessage()

func (*RequestBatchOrigin) ProtoReflect 

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

func (*RequestBatchOrigin) ReflectTypeOptions 

func (*RequestBatchOrigin) ReflectTypeOptions() []reflect.Type

func (*RequestBatchOrigin) Reset 

func (x *RequestBatchOrigin) Reset()

func (*RequestBatchOrigin) String 

func (x *RequestBatchOrigin) String() string

type RequestBatchOrigin_ContextStore 

type RequestBatchOrigin_ContextStore struct {
	ContextStore *contextstorepb.Origin `protobuf:"bytes,2,opt,name=context_store,json=contextStore,proto3,oneof"`
}

func (*RequestBatchOrigin_ContextStore) Unwrap 

func (w *RequestBatchOrigin_ContextStore) Unwrap() *contextstorepb.Origin

type RequestBatchOrigin_Dsl 

type RequestBatchOrigin_Dsl struct {
	Dsl *dslpb.Origin `protobuf:"bytes,3,opt,name=dsl,proto3,oneof"`
}

func (*RequestBatchOrigin_Dsl) Unwrap 

func (w *RequestBatchOrigin_Dsl) Unwrap() *dslpb.Origin

type RequestBatchOrigin_Type 

type RequestBatchOrigin_Type = isRequestBatchOrigin_Type

type RequestBatchOrigin_TypeWrapper 

type RequestBatchOrigin_TypeWrapper[T any] interface {
	RequestBatchOrigin_Type
	Unwrap() *T
}

type RequestTransactionIDs 

type RequestTransactionIDs struct {
	Txs    []*trantorpb.Transaction     `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
	Origin *RequestTransactionIDsOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

RequestTransactionIDs allows other modules to request the mempool module to compute IDs for the given transactions. It is possible that some of these transactions are not present in the mempool.

func (*RequestTransactionIDs) Descriptor deprecated 

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

Deprecated: Use RequestTransactionIDs.ProtoReflect.Descriptor instead.

func (*RequestTransactionIDs) GetOrigin 

func (x *RequestTransactionIDs) GetOrigin() *RequestTransactionIDsOrigin

func (*RequestTransactionIDs) GetTxs 

func (x *RequestTransactionIDs) GetTxs() []*trantorpb.Transaction

func (*RequestTransactionIDs) ProtoMessage 

func (*RequestTransactionIDs) ProtoMessage()

func (*RequestTransactionIDs) ProtoReflect 

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

func (*RequestTransactionIDs) Reset 

func (x *RequestTransactionIDs) Reset()

func (*RequestTransactionIDs) String 

func (x *RequestTransactionIDs) String() string

type RequestTransactionIDsOrigin 

type RequestTransactionIDsOrigin struct {
	Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// Types that are assignable to Type:
	//	*RequestTransactionIDsOrigin_ContextStore
	//	*RequestTransactionIDsOrigin_Dsl
	Type isRequestTransactionIDsOrigin_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

func (*RequestTransactionIDsOrigin) Descriptor deprecated 

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

Deprecated: Use RequestTransactionIDsOrigin.ProtoReflect.Descriptor instead.

func (*RequestTransactionIDsOrigin) GetContextStore 

func (x *RequestTransactionIDsOrigin) GetContextStore() *contextstorepb.Origin

func (*RequestTransactionIDsOrigin) GetDsl 

func (x *RequestTransactionIDsOrigin) GetDsl() *dslpb.Origin

func (*RequestTransactionIDsOrigin) GetModule 

func (x *RequestTransactionIDsOrigin) GetModule() string

func (*RequestTransactionIDsOrigin) GetType 

func (m *RequestTransactionIDsOrigin) GetType() isRequestTransactionIDsOrigin_Type

func (*RequestTransactionIDsOrigin) ProtoMessage 

func (*RequestTransactionIDsOrigin) ProtoMessage()

func (*RequestTransactionIDsOrigin) ProtoReflect 

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

func (*RequestTransactionIDsOrigin) ReflectTypeOptions 

func (*RequestTransactionIDsOrigin) ReflectTypeOptions() []reflect.Type

func (*RequestTransactionIDsOrigin) Reset 

func (x *RequestTransactionIDsOrigin) Reset()

func (*RequestTransactionIDsOrigin) String 

func (x *RequestTransactionIDsOrigin) String() string

type RequestTransactionIDsOrigin_ContextStore 

type RequestTransactionIDsOrigin_ContextStore struct {
	ContextStore *contextstorepb.Origin `protobuf:"bytes,2,opt,name=context_store,json=contextStore,proto3,oneof"`
}

func (*RequestTransactionIDsOrigin_ContextStore) Unwrap 

func (w *RequestTransactionIDsOrigin_ContextStore) Unwrap() *contextstorepb.Origin

type RequestTransactionIDsOrigin_Dsl 

type RequestTransactionIDsOrigin_Dsl struct {
	Dsl *dslpb.Origin `protobuf:"bytes,3,opt,name=dsl,proto3,oneof"`
}

func (*RequestTransactionIDsOrigin_Dsl) Unwrap 

func (w *RequestTransactionIDsOrigin_Dsl) Unwrap() *dslpb.Origin

type RequestTransactionIDsOrigin_Type 

type RequestTransactionIDsOrigin_Type = isRequestTransactionIDsOrigin_Type

type RequestTransactionIDsOrigin_TypeWrapper 

type RequestTransactionIDsOrigin_TypeWrapper[T any] interface {
	RequestTransactionIDsOrigin_Type
	Unwrap() *T
}

type RequestTransactions 

type RequestTransactions struct {
	TxIds  [][]byte                   `protobuf:"bytes,1,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"`
	Origin *RequestTransactionsOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

RequestTransactions allows the availability layer to request transactions from the mempool by their IDs. It is possible that some of these transactions are not present in the mempool.

func (*RequestTransactions) Descriptor deprecated 

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

Deprecated: Use RequestTransactions.ProtoReflect.Descriptor instead.

func (*RequestTransactions) GetOrigin 

func (x *RequestTransactions) GetOrigin() *RequestTransactionsOrigin

func (*RequestTransactions) GetTxIds 

func (x *RequestTransactions) GetTxIds() [][]byte

func (*RequestTransactions) ProtoMessage 

func (*RequestTransactions) ProtoMessage()

func (*RequestTransactions) ProtoReflect 

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

func (*RequestTransactions) Reset 

func (x *RequestTransactions) Reset()

func (*RequestTransactions) String 

func (x *RequestTransactions) String() string

type RequestTransactionsOrigin 

type RequestTransactionsOrigin struct {
	Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	// Types that are assignable to Type:
	//	*RequestTransactionsOrigin_ContextStore
	//	*RequestTransactionsOrigin_Dsl
	Type isRequestTransactionsOrigin_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

func (*RequestTransactionsOrigin) Descriptor deprecated 

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

Deprecated: Use RequestTransactionsOrigin.ProtoReflect.Descriptor instead.

func (*RequestTransactionsOrigin) GetContextStore 

func (x *RequestTransactionsOrigin) GetContextStore() *contextstorepb.Origin

func (*RequestTransactionsOrigin) GetDsl 

func (x *RequestTransactionsOrigin) GetDsl() *dslpb.Origin

func (*RequestTransactionsOrigin) GetModule 

func (x *RequestTransactionsOrigin) GetModule() string

func (*RequestTransactionsOrigin) GetType 

func (m *RequestTransactionsOrigin) GetType() isRequestTransactionsOrigin_Type

func (*RequestTransactionsOrigin) ProtoMessage 

func (*RequestTransactionsOrigin) ProtoMessage()

func (*RequestTransactionsOrigin) ProtoReflect 

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

func (*RequestTransactionsOrigin) ReflectTypeOptions 

func (*RequestTransactionsOrigin) ReflectTypeOptions() []reflect.Type

func (*RequestTransactionsOrigin) Reset 

func (x *RequestTransactionsOrigin) Reset()

func (*RequestTransactionsOrigin) String 

func (x *RequestTransactionsOrigin) String() string

type RequestTransactionsOrigin_ContextStore 

type RequestTransactionsOrigin_ContextStore struct {
	ContextStore *contextstorepb.Origin `protobuf:"bytes,2,opt,name=context_store,json=contextStore,proto3,oneof"`
}

func (*RequestTransactionsOrigin_ContextStore) Unwrap 

func (w *RequestTransactionsOrigin_ContextStore) Unwrap() *contextstorepb.Origin

type RequestTransactionsOrigin_Dsl 

type RequestTransactionsOrigin_Dsl struct {
	Dsl *dslpb.Origin `protobuf:"bytes,3,opt,name=dsl,proto3,oneof"`
}

func (*RequestTransactionsOrigin_Dsl) Unwrap 

func (w *RequestTransactionsOrigin_Dsl) Unwrap() *dslpb.Origin

type RequestTransactionsOrigin_Type 

type RequestTransactionsOrigin_Type = isRequestTransactionsOrigin_Type

type RequestTransactionsOrigin_TypeWrapper 

type RequestTransactionsOrigin_TypeWrapper[T any] interface {
	RequestTransactionsOrigin_Type
	Unwrap() *T
}

type TransactionIDsResponse 

type TransactionIDsResponse struct {
	TxIds  [][]byte                     `protobuf:"bytes,1,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"`
	Origin *RequestTransactionIDsOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

TransactionIDsResponse is a response to a RequestTransactionIDs event.

func (*TransactionIDsResponse) Descriptor deprecated 

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

Deprecated: Use TransactionIDsResponse.ProtoReflect.Descriptor instead.

func (*TransactionIDsResponse) GetOrigin 

func (x *TransactionIDsResponse) GetOrigin() *RequestTransactionIDsOrigin

func (*TransactionIDsResponse) GetTxIds 

func (x *TransactionIDsResponse) GetTxIds() [][]byte

func (*TransactionIDsResponse) ProtoMessage 

func (*TransactionIDsResponse) ProtoMessage()

func (*TransactionIDsResponse) ProtoReflect 

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

func (*TransactionIDsResponse) Reset 

func (x *TransactionIDsResponse) Reset()

func (*TransactionIDsResponse) String 

func (x *TransactionIDsResponse) String() string

type TransactionsResponse 

type TransactionsResponse struct {
	FoundIds   [][]byte                   `protobuf:"bytes,1,rep,name=found_ids,json=foundIds,proto3" json:"found_ids,omitempty"`
	FoundTxs   []*trantorpb.Transaction   `protobuf:"bytes,2,rep,name=found_txs,json=foundTxs,proto3" json:"found_txs,omitempty"`
	MissingIds [][]byte                   `protobuf:"bytes,3,rep,name=missing_ids,json=missingIds,proto3" json:"missing_ids,omitempty"`
	Origin     *RequestTransactionsOrigin `protobuf:"bytes,4,opt,name=origin,proto3" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

TransactionsResponse is a response to a RequestTransactions event.

func (*TransactionsResponse) Descriptor deprecated 

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

Deprecated: Use TransactionsResponse.ProtoReflect.Descriptor instead.

func (*TransactionsResponse) GetFoundIds 

func (x *TransactionsResponse) GetFoundIds() [][]byte

func (*TransactionsResponse) GetFoundTxs 

func (x *TransactionsResponse) GetFoundTxs() []*trantorpb.Transaction

func (*TransactionsResponse) GetMissingIds 

func (x *TransactionsResponse) GetMissingIds() [][]byte

func (*TransactionsResponse) GetOrigin 

func (x *TransactionsResponse) GetOrigin() *RequestTransactionsOrigin

func (*TransactionsResponse) ProtoMessage 

func (*TransactionsResponse) ProtoMessage()

func (*TransactionsResponse) ProtoReflect 

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

func (*TransactionsResponse) Reset 

func (x *TransactionsResponse) Reset()

func (*TransactionsResponse) String 

func (x *TransactionsResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.