matcher

Dec 17, 2018

Changes in this version

+ var ErrSessionExpired = errors.New("session expired")

type Config

+ Log slog.Logger

+ SessionLog slog.Logger

+ SuccessfulSesssionNtfn func(ticketHash chainhash.Hash)

type Session

+ CurrentStage SessionStage

type SessionParticipant

+ CurrentStage SessionStage

+ SessionToken []byte

+ type SessionStage int

+ const StageDone

+ const StageUnknown

+ const StageWaitingOutputs

+ const StageWaitingSplitFunds

+ const StageWaitingTicketFunds

+ func (ss SessionStage) String() string

Aug 9, 2018

Changes in this version

+ func MustRandInt64() int64

+ func NewRandInt64() (int64, error)

+ func OriginalSrcFromCtx(ctx context.Context) string

+ func WithOriginalSrc(parent context.Context, src string) context.Context

Jul 17, 2018

Changes in this version

type Session

+ func (sess *Session) FindVoterCoinIndex() (dcrutil.Amount, int)

+ func (sess *Session) VoteAddresses() []dcrutil.Address

May 28, 2018

Changes in this version

type Config

+ PoolAddrValidator PoolAddressValidationProvider

+ VoteAddrValidator VoteAddressValidationProvider

+ type InsecurePoolAddressesValidator struct

+ func (v InsecurePoolAddressesValidator) ValidatePoolSubsidyAddress(poolAddr dcrutil.Address) error

+ func (v InsecurePoolAddressesValidator) ValidateVoteAddress(voteAddr dcrutil.Address) error

+ type PoolAddressValidationProvider interface

+ ValidatePoolSubsidyAddress func(poolAddr dcrutil.Address) error

+ type VoteAddressValidationProvider interface

+ ValidateVoteAddress func(voteAddr dcrutil.Address) error

May 16, 2018

Changes in this version

type Config

+ SessionDataDir string

type Session

+ TicketFee dcrutil.Amount

+ func (sess *Session) SaveSession(sessionDir string) error

+ func (sess *Session) SelectedCoin() dcrutil.Amount

May 9, 2018

Changes in this version

+ const CommitmentLimits

+ const MaximumExpiry

+ const RevocationFeeRate

+ const VoterLotteryCommitmentScriptSize

+ var EmptySStxChangeAddr = []byte

+ func CreateUnsignedRevocation(ticketHash *chainhash.Hash, ticketPurchase *wire.MsgTx, ...) (*wire.MsgTx, error)

+ func TargetTicketExpirationBlock(curBlockHeight, maxExpiry uint32, params *chaincfg.Params) uint32

type Config

+ NetworkProvider NetworkProvider

+ PublishTransactions bool

+ type NetworkProvider interface

+ ConnectedToDecredNetwork func() bool

+ CurrentBlockHash func() chainhash.Hash

+ CurrentBlockHeight func() uint32

+ CurrentTicketPrice func() uint64

+ GetUtxos func(outpoints []*wire.OutPoint) (splitticket.UtxoMap, error)

+ PublishTransactions func([]*wire.MsgTx) error

+ type ParticipantTicketOutput struct

+ Amount dcrutil.Amount

+ PoolPkScript []byte

+ SecretHash *splitticket.SecretNumberHash

+ VotePkScript []byte

type Session

+ MainchainHash chainhash.Hash

+ MainchainHeight uint32

+ TicketExpiry uint32

+ func (sess *Session) CreateVoterTransactions() (*wire.MsgTx, *wire.MsgTx, *wire.MsgTx, error)

+ func (sess *Session) FindVoterIndex() int

+ func (sess *Session) ParticipantAmounts() []dcrutil.Amount

+ func (sess *Session) ParticipantTicketOutputs() []*ParticipantTicketOutput

+ func (sess *Session) SecretNumberHashes() []splitticket.SecretNumberHash

+ func (sess *Session) SecretNumbers() splitticket.SecretNumbers

+ func (sess *Session) SplitUtxoMap() (splitticket.UtxoMap, error)

type SessionParticipant

+ CommitmentAddress dcrutil.Address

+ SecretHash splitticket.SecretNumberHash

+ SecretNb splitticket.SecretNumber

+ SplitTxAddress dcrutil.Address

+ type WaitingQueue struct

+ Amounts []dcrutil.Amount

+ Name string

Mar 30, 2018

Changes in this version

+ var ErrNotConnectedToDecredNet = merry.New("Not connected to the decred network")

type TicketPriceProvider

+ ConnectedToDecredNetwork func() bool

Mar 27, 2018

Changes in this version

+ const InputVmValidationFlags

+ const ParticipantFeeOverheadEstimate

+ const TicketFeeEstimate

+ const TicketParticipantSize

+ const TicketTxInitialSize

+ var ErrCommitmentValueDifferent = merry.New("Commitment value is different than expected")

+ var ErrFeeTooLow = merry.New("Provided tx fee is too low")

+ var ErrIndexNotFound = merry.New("Index not found")

+ var ErrLowAmount = merry.New("Amount too low to participate in ticket purchase")

+ var ErrNilChangeOutput = merry.New("Nil change output provided")

+ var ErrNilCommitmentOutput = merry.New("Nil commitment output provided")

+ var ErrNoPoolAddress = merry.New("Pool address was not specified")

+ var ErrNoRevocationScriptSig = merry.New("Revocation Script not specified")

+ var ErrNoSplitTxInputOutPoints = merry.New("No split tx input outpoints sent")

+ var ErrNoVoteAddress = merry.New("Vote Address not specified for session")

+ var ErrParticipantDisconnected = merry.New("Participant disconnected from session")

+ var ErrSessionMaxTimeExpired = merry.New("Maximum time for finishing session has expired")

+ var ErrSessionNotFound = merry.New("Session with the provided ID not found")

+ var ErrSplitInputSignLenMismatch = merry.New("Split input count and script sig count mismatch")

+ var ErrSplitValueInputValueMismatch = merry.New("Amount of split tx output and ValueIn of ticket input are different")

+ var ErrStakeDiffTooCloseToChange = merry.New("Stake difficulty window too close to change")

+ var ErrTicketScriptSigNotProvided = merry.New("Ticket scriptSig not provided")

+ var ErrTooManyParticipants = merry.New("Too many online participants at the moment")

+ var ErrVoteAddressNotSpecified = merry.New("Voter Address not specified")

+ func ChooseVoter(contributions []dcrutil.Amount) int

+ func MustRandInt16() int16

+ func MustRandInt32() int32

+ func MustRandUInt16() uint16

+ func MustRandUint64() uint64

+ func NewRandInt16() (int16, error)

+ func NewRandInt32() (int32, error)

+ func NewRandUInt16() (uint16, error)

+ func NewRandUint64() (uint64, error)

+ func SelectContributionAmounts(maxAmounts []dcrutil.Amount, ticketPrice, partFee, poolPartFee dcrutil.Amount) ([]dcrutil.Amount, error)

+ func SessionFeeEstimate(numParticipants int) dcrutil.Amount

+ func SessionParticipantFee(numParticipants int) dcrutil.Amount

+ type Config struct

+ ChainParams *chaincfg.Params

+ LogBackend logging.LeveledBackend

+ LogLevel logging.Level

+ MaxOnlineParticipants int

+ MaxSessionDuration time.Duration

+ MinAmount uint64

+ PoolFee float64

+ PriceProvider TicketPriceProvider

+ SignPoolSplitOutProvider SignPoolSplitOutputProvider

+ StakeDiffChangeStopWindow int32

+ type Matcher struct

+ func NewMatcher(cfg *Config) *Matcher

+ func (matcher *Matcher) AddParticipant(ctx context.Context, maxAmount uint64) (*SessionParticipant, error)

+ func (matcher *Matcher) FundSplit(ctx context.Context, sessionID ParticipantID, inputScriptSigs [][]byte) (*wire.MsgTx, error)

+ func (matcher *Matcher) FundTicket(ctx context.Context, sessionID ParticipantID, inputScriptSig []byte, ...) (*wire.MsgTx, *wire.MsgTx, error)

+ func (matcher *Matcher) Run() error

+ func (matcher *Matcher) SetParticipantsOutputs(ctx context.Context, sessionID ParticipantID, ...) (*wire.MsgTx, *wire.MsgTx, *wire.MsgTx, error)

+ func (matcher *Matcher) WatchWaitingList(ctx context.Context, watcher chan []dcrutil.Amount)

+ type ParticipantID uint32

+ func (id ParticipantID) String() string

+ type Session struct

+ Canceled bool

+ ChainParams *chaincfg.Params

+ Done bool

+ ID SessionID

+ Participants []*SessionParticipant

+ PoolFee dcrutil.Amount

+ SplitTxPoolOut *wire.TxOut

+ StartTime time.Time

+ TicketPoolIn *wire.TxIn

+ TicketPrice dcrutil.Amount

+ VoterIndex int

+ func (sess *Session) AllOutputsFilled() bool

+ func (sess *Session) CreateTransactions() (*wire.MsgTx, *wire.MsgTx, *wire.MsgTx, error)

+ func (sess *Session) SplitTxIsFunded() bool

+ func (sess *Session) TicketIsFunded() bool

+ type SessionID uint16

+ func (id SessionID) String() string

+ type SessionParticipant struct

+ ChangeTxOut *wire.TxOut

+ CommitAmount dcrutil.Amount

+ CommitmentTxOut *wire.TxOut

+ Fee dcrutil.Amount

+ ID ParticipantID

+ Index int

+ PoolAddress *dcrutil.Address

+ PoolFee dcrutil.Amount

+ RevocationScriptSig []byte

+ Session *Session

+ SplitTxChange *wire.TxOut

+ SplitTxInputs []*wire.TxIn

+ SplitTxOut *wire.TxOut

+ SplitTxOutputIndex int

+ TicketScriptSig []byte

+ VoteAddress *dcrutil.Address

+ type SignPoolSplitOutputProvider interface

+ PoolFeeAddress func() dcrutil.Address

+ SignPoolSplitOutput func(split, ticket *wire.MsgTx) ([]byte, error)

+ type TicketPriceProvider interface

+ CurrentBlockHeight func() int32

+ CurrentTicketPrice func() uint64

+ type VoteAddressProvider interface

+ SignRevocation func(ticket, revocation *wire.MsgTx) (*wire.MsgTx, error)

+ VotingAddress func() dcrutil.Address