model

Sep 11, 2024

Changes in this version

+ func FinishAndGetNext(m *NonodoModel, accept bool) (cModel.Input, error)

+ type EspressoSequencer struct

+ func NewEspressoSequencer(model *NonodoModel) *EspressoSequencer

+ func (es *EspressoSequencer) FinishAndGetNext(accept bool) (cModel.Input, error)

+ type InputBoxSequencer struct

+ func NewInputBoxSequencer(model *NonodoModel) *InputBoxSequencer

+ func (ibs *InputBoxSequencer) FinishAndGetNext(accept bool) (cModel.Input, error)

type NonodoModel

+ func (m *NonodoModel) GetInputRepository() *cRepos.InputRepository

+ type Sequencer interface

+ FinishAndGetNext func(accept bool) (cModel.Input, error)

May 5, 2024

Changes in this version

+ const INDEX_FIELD

+ const INPUT_INDEX

+ type AdvanceInput struct

+ BlockNumber uint64

+ Exception []byte

+ Index int

+ MsgSender common.Address

+ Notices []Notice

+ Payload []byte

+ Reports []Report

+ Status CompletionStatus

+ Timestamp time.Time

+ Vouchers []Voucher

+ type CompletionStatus int

+ const CompletionStatusAccepted

+ const CompletionStatusException

+ const CompletionStatusRejected

+ const CompletionStatusUnprocessed

+ type Decoder interface

+ HandleOutput func(ctx context.Context, destination common.Address, payload string, ...) error

+ type Input interface

+ type InputFilter struct

+ IndexGreaterThan *int

+ IndexLowerThan *int

+ func (f InputFilter) Filter(i *AdvanceInput) bool

+ type InputRepository struct

+ Db *sqlx.DB

+ func (c *InputRepository) Count(filter []*model.ConvenienceFilter) (uint64, error)

+ func (c *InputRepository) FindAll(first *int, last *int, after *string, before *string, ...) (*commons.PageResult[AdvanceInput], error)

+ func (r *InputRepository) Create(input AdvanceInput) (*AdvanceInput, error)

+ func (r *InputRepository) CreateTables() error

+ func (r *InputRepository) FindByIndex(index int) (*AdvanceInput, error)

+ func (r *InputRepository) FindByStatus(status CompletionStatus) (*AdvanceInput, error)

+ func (r *InputRepository) Update(input AdvanceInput) (*AdvanceInput, error)

+ type InspectInput struct

+ Exception []byte

+ Index int

+ Payload []byte

+ ProcessedInputCount int

+ Reports []Report

+ Status CompletionStatus

+ type MetadataFilter struct

+ And []*MetadataFilter

+ Eq *string

+ Field string

+ Gt *string

+ Gte *string

+ In []*string

+ Lt *string

+ Lte *string

+ Ne *string

+ Nin []*string

+ Or []*MetadataFilter

+ func CreateFilterList(content string) []*MetadataFilter

+ type NonodoModel struct

+ func NewNonodoModel(decoder Decoder, db *sqlx.DB) *NonodoModel

+ func (m *NonodoModel) AddAdvanceInput(sender common.Address, payload []byte, blockNumber uint64, timestamp time.Time)

+ func (m *NonodoModel) AddInspectInput(payload []byte) int

+ func (m *NonodoModel) AddNotice(payload []byte) (int, error)

+ func (m *NonodoModel) AddReport(payload []byte) error

+ func (m *NonodoModel) AddVoucher(destination common.Address, payload []byte) (int, error)

+ func (m *NonodoModel) FinishAndGetNext(accepted bool) Input

+ func (m *NonodoModel) GetInspectInput(index int) InspectInput

+ func (m *NonodoModel) RegisterException(payload []byte) error

+ type Notice struct

+ Index int

+ InputIndex int

+ Payload []byte

+ func (n Notice) GetInputIndex() int

+ type Output interface

+ GetInputIndex func() int

+ type OutputFilter struct

+ InputIndex *int

+ func (f OutputFilter) Filter(o Output) bool

+ type Report struct

+ Index int

+ InputIndex int

+ Payload []byte

+ func (r Report) GetInputIndex() int

+ type ReportRepository struct

+ Db *sqlx.DB

+ func (c *ReportRepository) Count(filter []*model.ConvenienceFilter) (uint64, error)

+ func (c *ReportRepository) FindAll(first *int, last *int, after *string, before *string, ...) (*commons.PageResult[Report], error)

+ func (c *ReportRepository) FindAllByInputIndex(first *int, last *int, after *string, before *string, inputIndex *int) (*commons.PageResult[Report], error)

+ func (r *ReportRepository) Create(report Report) (Report, error)

+ func (r *ReportRepository) CreateTables() error

+ func (r *ReportRepository) FindByInputAndOutputIndex(inputIndex uint64, outputIndex uint64) (*Report, error)

+ type Voucher struct

+ Destination common.Address

+ Index int

+ InputIndex int

+ Payload []byte

+ func (v Voucher) GetInputIndex() int