pm

Sep 10, 2024

Changes in this version

type MockSender

+ func (m *MockSender) CleanupSession(sessionID string)

type Sender

+ CleanupSession func(sessionID string)

Jun 10, 2022

Changes in this version

type MockRecipient

+ func (m *MockRecipient) SetMaxFaceValue(maxfacevalue *big.Int)

type Recipient

+ SetMaxFaceValue func(maxfacevalue *big.Int)

May 11, 2022

Changes in this version

type TimeManager

+ PreLastInitializedL1BlockHash func() [32]byte

Feb 11, 2022

Changes in this version

type TicketStore

+ IsOrchActive func(addr ethcommon.Address, round *big.Int) (bool, error)

type TimeManager

+ LastInitializedL1BlockHash func() [32]byte

+ LastSeenL1Block func() *big.Int

+ SubscribeL1Blocks func(sink chan<- *big.Int) event.Subscription

Aug 6, 2020

Changes in this version

+ type LocalSenderMonitorConfig struct

+ Claimant ethcommon.Address

+ CleanupInterval time.Duration

+ RPCTimeout time.Duration

+ RedeemGas int

+ SuggestGasPrice func(context.Context) (*big.Int, error)

+ TTL int

Jul 6, 2020

Changes in this version

+ type LocalSenderMonitor struct

+ func (sm *LocalSenderMonitor) MaxFloat(addr ethcommon.Address) (*big.Int, error)

+ func (sm *LocalSenderMonitor) QueueTicket(ticket *SignedTicket) error

+ func (sm *LocalSenderMonitor) Start()

+ func (sm *LocalSenderMonitor) Stop()

+ func (sm *LocalSenderMonitor) SubscribeMaxFloatChange(sender ethcommon.Address, sink chan<- struct{}) event.Subscription

+ func (sm *LocalSenderMonitor) ValidateSender(addr ethcommon.Address) error

type SenderManager

+ SubscribeReserveChange func(sink chan<- ethcommon.Address) event.Subscription

type TicketStore

+ MarkWinningTicketRedeemed func(ticket *SignedTicket, txHash ethcommon.Hash) error

+ RemoveWinningTicket func(ticket *SignedTicket) error

+ SelectEarliestWinningTicket func(sender ethcommon.Address) (*SignedTicket, error)

+ WinningTicketCount func(sender ethcommon.Address) (int, error)

Apr 21, 2020

Changes in this version

type TicketExpirationParams

+ func (e *TicketExpirationParams) AuxData() []byte

type TicketParams

+ ExpirationParams *TicketExpirationParams

Mar 12, 2020

Changes in this version

+ var ErrTicketParamsExpired = errors.New("TicketParams expired")

+ type FatalReceiveErr struct

+ func NewFatalReceiveErr(err error) *FatalReceiveErr

type Ticket

+ ParamsExpirationBlock *big.Int

+ PricePerPixel *big.Rat

type TicketParams

+ ExpirationBlock *big.Int

+ PricePerPixel *big.Rat

+ type TimeManager interface

+ GetTranscoderPoolSize func() *big.Int

+ LastInitializedBlockHash func() [32]byte

+ LastInitializedRound func() *big.Int

+ LastSeenBlock func() *big.Int

+ SubscribeBlocks func(sink chan<- *big.Int) event.Subscription

+ SubscribeRounds func(sink chan<- types.Log) event.Subscription

Feb 5, 2020

Changes in this version

+ type ErrSenderValidation struct

type TicketParams

+ func (p *TicketParams) WinProbRat() *big.Rat

Dec 3, 2019

Changes in this version

type SenderMonitor

+ ValidateSender func(addr ethcommon.Address) error

Oct 29, 2019

Changes in this version

+ func RandAddress() ethcommon.Address

+ func RandBytes(size uint) []byte

+ func RandHash() ethcommon.Hash

+ func VerifySig(addr ethcommon.Address, msg, sig []byte) bool

+ type Broker interface

+ CancelUnlock func() (*types.Transaction, error)

+ CheckTx func(tx *types.Transaction) error

+ FundDeposit func(amount *big.Int) (*types.Transaction, error)

+ FundDepositAndReserve func(depositAmount, reserveAmount *big.Int) (*types.Transaction, error)

+ FundReserve func(amount *big.Int) (*types.Transaction, error)

+ IsUsedTicket func(ticket *Ticket) (bool, error)

+ RedeemWinningTicket func(ticket *Ticket, sig []byte, recipientRand *big.Int) (*types.Transaction, error)

+ Unlock func() (*types.Transaction, error)

+ Withdraw func() (*types.Transaction, error)

+ type DefaultSigVerifier struct

+ func (sv *DefaultSigVerifier) Verify(addr ethcommon.Address, msg, sig []byte) bool

+ type ErrorMonitor interface

+ AcceptErr func(sender ethcommon.Address) bool

+ ClearErrCount func(sender ethcommon.Address)

+ type GasPriceMonitor interface

+ GasPrice func() *big.Int

+ type MockReceiveError struct

+ func NewMockReceiveError(err error, acceptable bool) *MockReceiveError

+ func (re *MockReceiveError) Acceptable() bool

+ func (re *MockReceiveError) Error() string

+ type MockRecipient struct

+ func (m *MockRecipient) EV() *big.Rat

+ func (m *MockRecipient) ReceiveTicket(ticket *Ticket, sig []byte, seed *big.Int) (sessionID string, won bool, err error)

+ func (m *MockRecipient) RedeemWinningTicket(ticket *Ticket, sig []byte, seed *big.Int) error

+ func (m *MockRecipient) RedeemWinningTickets(sessionIDs []string) error

+ func (m *MockRecipient) Start()

+ func (m *MockRecipient) Stop()

+ func (m *MockRecipient) TicketParams(sender ethcommon.Address) (*TicketParams, error)

+ func (m *MockRecipient) TxCostMultiplier(sender ethcommon.Address) (*big.Rat, error)

+ type MockSender struct

+ func (m *MockSender) CreateTicketBatch(sessionID string, size int) (*TicketBatch, error)

+ func (m *MockSender) EV(sessionID string) (*big.Rat, error)

+ func (m *MockSender) StartSession(ticketParams TicketParams) string

+ func (m *MockSender) ValidateTicketParams(ticketParams *TicketParams) error

+ type Recipient interface

+ EV func() *big.Rat

+ ReceiveTicket func(ticket *Ticket, sig []byte, seed *big.Int) (sessionID string, won bool, err error)

+ RedeemWinningTicket func(ticket *Ticket, sig []byte, seed *big.Int) error

+ RedeemWinningTickets func(sessionIDs []string) error

+ Start func()

+ Stop func()

+ TicketParams func(sender ethcommon.Address) (*TicketParams, error)

+ TxCostMultiplier func(sender ethcommon.Address) (*big.Rat, error)

+ func NewRecipient(addr ethcommon.Address, broker Broker, val Validator, store TicketStore, ...) (Recipient, error)

+ func NewRecipientWithSecret(addr ethcommon.Address, broker Broker, val Validator, store TicketStore, ...) Recipient

+ type RedeemableEmitter interface

+ Redeemable func() chan *SignedTicket

+ type ReserveInfo struct

+ ClaimedInCurrentRound *big.Int

+ FundsRemaining *big.Int

+ type RoundsManager interface

+ GetTranscoderPoolSize func() *big.Int

+ LastInitializedBlockHash func() [32]byte

+ LastInitializedRound func() *big.Int

+ type Sender interface

+ CreateTicketBatch func(sessionID string, size int) (*TicketBatch, error)

+ EV func(sessionID string) (*big.Rat, error)

+ StartSession func(ticketParams TicketParams) string

+ ValidateTicketParams func(ticketParams *TicketParams) error

+ func NewSender(signer Signer, roundsManager RoundsManager, senderManager SenderManager, ...) Sender

+ type SenderInfo struct

+ Deposit *big.Int

+ Reserve *ReserveInfo

+ WithdrawRound *big.Int

+ type SenderManager interface

+ ClaimedReserve func(reserveHolder ethcommon.Address, claimant ethcommon.Address) (*big.Int, error)

+ Clear func(addr ethcommon.Address)

+ GetSenderInfo func(addr ethcommon.Address) (*SenderInfo, error)

+ type SenderMonitor interface

+ AddFloat func(addr ethcommon.Address, amount *big.Int) error

+ MaxFloat func(addr ethcommon.Address) (*big.Int, error)

+ QueueTicket func(addr ethcommon.Address, ticket *SignedTicket)

+ Start func()

+ Stop func()

+ SubFloat func(addr ethcommon.Address, amount *big.Int)

+ func NewSenderMonitor(claimant ethcommon.Address, broker Broker, smgr SenderManager, ...) SenderMonitor

+ type SigVerifier interface

+ Verify func(addr ethcommon.Address, msg, sig []byte) bool

+ type SignedTicket struct

+ RecipientRand *big.Int

+ Sig []byte

+ type Signer interface

+ Account func() accounts.Account

+ Sign func(msg []byte) ([]byte, error)

+ type Ticket struct

+ CreationRound int64

+ CreationRoundBlockHash ethcommon.Hash

+ FaceValue *big.Int

+ Recipient ethcommon.Address

+ RecipientRandHash ethcommon.Hash

+ Sender ethcommon.Address

+ SenderNonce uint32

+ WinProb *big.Int

+ func NewTicket(params *TicketParams, expirationParams *TicketExpirationParams, ...) *Ticket

+ func (t *Ticket) AuxData() []byte

+ func (t *Ticket) EV() *big.Rat

+ func (t *Ticket) Hash() ethcommon.Hash

+ func (t *Ticket) WinProbRat() *big.Rat

+ type TicketBatch struct

+ Sender ethcommon.Address

+ SenderParams []*TicketSenderParams

+ func (b *TicketBatch) Tickets() []*Ticket

+ type TicketExpirationParams struct

+ CreationRound int64

+ CreationRoundBlockHash ethcommon.Hash

+ type TicketParams struct

+ FaceValue *big.Int

+ Recipient ethcommon.Address

+ RecipientRandHash ethcommon.Hash

+ Seed *big.Int

+ WinProb *big.Int

+ type TicketParamsConfig struct

+ EV *big.Int

+ RedeemGas int

+ TxCostMultiplier int

+ type TicketSenderParams struct

+ SenderNonce uint32

+ Sig []byte

+ type TicketStore interface

+ LoadWinningTickets func(sessionIDs []string) (tickets []*Ticket, sigs [][]byte, recipientRands []*big.Int, err error)

+ StoreWinningTicket func(sessionID string, ticket *Ticket, sig []byte, recipientRand *big.Int) error

+ type Validator interface

+ IsWinningTicket func(ticket *Ticket, sig []byte, recipientRand *big.Int) bool

+ ValidateTicket func(recipient ethcommon.Address, ticket *Ticket, sig []byte, ...) error

+ func NewValidator(sigVerifier SigVerifier, roundsManager RoundsManager) Validator