txsubmission

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

type Config struct {
	RequestTxIdsFunc RequestTxIdsFunc
	ReplyTxIdsFunc   ReplyTxIdsFunc
	RequestTxsFunc   RequestTxsFunc
	ReplyTxsFunc     ReplyTxsFunc
	DoneFunc         DoneFunc
	InitFunc         InitFunc
	IdleTimeout      time.Duration
}

type DoneFunc func() error

type InitFunc func() error

type MsgDone struct {
	protocol.MessageBase
}

type MsgInit struct {
	protocol.MessageBase
}

type MsgReplyTxIds struct {
	protocol.MessageBase
	TxIds []TxIdAndSize
}

type MsgReplyTxs struct {
	protocol.MessageBase
	Txs []TxBody
}

type MsgRequestTxIds struct {
	protocol.MessageBase
	Blocking bool
	Ack      uint16
	Req      uint16
}

type MsgRequestTxs struct {
	protocol.MessageBase
	TxIds []TxId
}

type ReplyTxIdsFunc func(interface{}) error

type ReplyTxsFunc func(interface{}) error

type RequestTxIdsFunc func(bool, uint16, uint16) ([]TxIdAndSize, error)

type RequestTxsFunc func([]TxId) ([]TxBody, error)

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

type TxBody struct {
	cbor.StructAsArray
	EraId  uint16
	TxBody []byte
}

type TxId struct {
	cbor.StructAsArray
	EraId uint16
	TxId  [32]byte
}

type TxIdAndSize struct {
	cbor.StructAsArray
	TxId TxId
	Size uint32
}

type TxSubmission struct {
	Client *Client
	Server *Server
}

type TxSubmissionOptionFunc func(*Config)