txfee

Documentation

Index

• type FeeFetchFunc
• type FeeFetcher
  • func NewFeeFetcher(sources []*SourceConfig, log dex.Logger) *FeeFetcher
  • func (f *FeeFetcher) Connect(ctx context.Context) (*sync.WaitGroup, error)
  • func (f *FeeFetcher) Next() <-chan uint64
• type SourceConfig

Types

type FeeFetchFunc

type FeeFetchFunc func(ctx context.Context) (rate uint64, errDelay time.Duration, err error)

FeeFetchFunc is a function that fetches a fee rate. If an error is encountered the FeeFetchFunc will indicate how long to wait until trying again.

type FeeFetcher

type FeeFetcher struct {
	// contains filtered or unexported fields
}

func NewFeeFetcher

func NewFeeFetcher(sources []*SourceConfig, log dex.Logger) *FeeFetcher

NewFeeFetcher creates and returns a new FeeFetcher.

func (*FeeFetcher) Connect

func (f *FeeFetcher) Connect(ctx context.Context) (*sync.WaitGroup, error)

func (*FeeFetcher) Next

func (f *FeeFetcher) Next() <-chan uint64

type SourceConfig

type SourceConfig struct {
	F      FeeFetchFunc
	Name   string
	Period time.Duration
	// Rank controls which priority group the source is in. Lower Rank is higher
	// priority. Fee rates from similarly-ranked sources are grouped together
	// for a composite rate. Lower-ranked groups are not considered at all
	// until all sources from higher ranked groups are error or expired.
	Rank uint
}

SourceConfig defines a fee rate source.