localtxmonitor

type CallbackContext struct {
	ConnectionId connection.ConnectionId
	Client       *Client
	Server       *Server
}

type Client struct {
	*protocol.Protocol
	// contains filtered or unexported fields
}

type Config struct {
	GetMempoolFunc GetMempoolFunc
	AcquireTimeout time.Duration
	QueryTimeout   time.Duration
}

type GetMempoolFunc func(CallbackContext) (uint64, uint32, []TxAndEraId, error)

type LocalTxMonitor struct {
	Client *Client
	Server *Server
}

type LocalTxMonitorOptionFunc func(*Config)

type MsgAcquire struct {
	protocol.MessageBase
}

type MsgAcquired struct {
	protocol.MessageBase
	SlotNo uint64
}

type MsgDone struct {
	protocol.MessageBase
}

type MsgGetSizes struct {
	protocol.MessageBase
}

type MsgHasTx struct {
	protocol.MessageBase
	TxId []byte
}

type MsgNextTx struct {
	protocol.MessageBase
}

type MsgRelease struct {
	protocol.MessageBase
}

type MsgReplyGetSizes struct {
	protocol.MessageBase
	Result MsgReplyGetSizesResult
}

type MsgReplyGetSizesResult struct {
	Capacity    uint32
	Size        uint32
	NumberOfTxs uint32
	// contains filtered or unexported fields
}

type MsgReplyHasTx struct {
	protocol.MessageBase
	Result bool
}

type MsgReplyNextTx struct {
	protocol.MessageBase
	Transaction MsgReplyNextTxTransaction
}

type MsgReplyNextTxTransaction struct {
	EraId uint8
	Tx    []byte
	// contains filtered or unexported fields
}

type Server struct {
	*protocol.Protocol
	// contains filtered or unexported fields
}

type TxAndEraId struct {
	EraId uint
	Tx    []byte
	// contains filtered or unexported fields
}