mempoolpb

package
v0.4.4 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2023 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 added in v0.4.1 

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 added in v0.4.1 

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

Deprecated: Use BatchTimeout.ProtoReflect.Descriptor instead.

func (*BatchTimeout) GetBatchReqID added in v0.4.1 

func (x *BatchTimeout) GetBatchReqID() uint64

func (*BatchTimeout) ProtoMessage added in v0.4.1 

func (*BatchTimeout) ProtoMessage()

func (*BatchTimeout) ProtoReflect added in v0.4.1 

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

func (*BatchTimeout) Reset added in v0.4.1 

func (x *BatchTimeout) Reset()

func (*BatchTimeout) String added in v0.4.1 

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 added in v0.4.1 

func (x *Event) GetBatchTimeout() *BatchTimeout

func (*Event) GetNewBatch 

func (x *Event) GetNewBatch() *NewBatch

func (*Event) GetNewEpoch added in v0.4.2 

func (x *Event) GetNewEpoch() *NewEpoch

func (*Event) GetNewTransactions added in v0.4.0 

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 added in v0.2.0 

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 added in v0.4.1 

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

func (*Event_BatchTimeout) Unwrap added in v0.4.1 

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 added in v0.4.2 

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

func (*Event_NewEpoch) Unwrap added in v0.4.2 

func (w *Event_NewEpoch) Unwrap() *NewEpoch

type Event_NewTransactions added in v0.4.0 

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

func (*Event_NewTransactions) Unwrap added in v0.4.0 

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 added in v0.4.2 

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 added in v0.4.2 

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

Deprecated: Use NewEpoch.ProtoReflect.Descriptor instead.

func (*NewEpoch) GetClientProgress added in v0.4.2 

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

func (*NewEpoch) GetEpochNr added in v0.4.2 

func (x *NewEpoch) GetEpochNr() uint64

func (*NewEpoch) ProtoMessage added in v0.4.2 

func (*NewEpoch) ProtoMessage()

func (*NewEpoch) ProtoReflect added in v0.4.2 

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

func (*NewEpoch) Reset added in v0.4.2 

func (x *NewEpoch) Reset()

func (*NewEpoch) String added in v0.4.2 

func (x *NewEpoch) String() string

type NewTransactions added in v0.4.0 

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 added in v0.4.0 

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

Deprecated: Use NewTransactions.ProtoReflect.Descriptor instead.

func (*NewTransactions) GetTransactions added in v0.4.0 

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

func (*NewTransactions) ProtoMessage added in v0.4.0 

func (*NewTransactions) ProtoMessage()

func (*NewTransactions) ProtoReflect added in v0.4.0 

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

func (*NewTransactions) Reset added in v0.4.0 

func (x *NewTransactions) Reset()

func (*NewTransactions) String added in v0.4.0 

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 added in v0.4.2 

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 added in v0.2.0 

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 added in v0.2.0 

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 added in v0.2.0 

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

type RequestBatchIDOrigin_Type added in v0.2.0 

type RequestBatchIDOrigin_Type = isRequestBatchIDOrigin_Type

type RequestBatchIDOrigin_TypeWrapper added in v0.2.0 

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 added in v0.2.0 

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 added in v0.2.0 

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 added in v0.2.0 

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

type RequestBatchOrigin_Type added in v0.2.0 

type RequestBatchOrigin_Type = isRequestBatchOrigin_Type

type RequestBatchOrigin_TypeWrapper added in v0.2.0 

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 added in v0.2.0 

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 added in v0.2.0 

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 added in v0.2.0 

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

type RequestTransactionIDsOrigin_Type added in v0.2.0 

type RequestTransactionIDsOrigin_Type = isRequestTransactionIDsOrigin_Type

type RequestTransactionIDsOrigin_TypeWrapper added in v0.2.0 

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 added in v0.2.0 

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 added in v0.2.0 

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 added in v0.2.0 

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

type RequestTransactionsOrigin_Type added in v0.2.0 

type RequestTransactionsOrigin_Type = isRequestTransactionsOrigin_Type

type RequestTransactionsOrigin_TypeWrapper added in v0.2.0 

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 added in v0.4.2 

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

func (*TransactionsResponse) GetFoundTxs added in v0.4.2 

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

func (*TransactionsResponse) GetMissingIds added in v0.4.2 

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.