signaller

Documentation

Index

• Constants
• type BothanClient
• type FeedQuerier
• type Signaller
  • func New(feedQuerier FeedQuerier, bothanClient BothanClient, interval time.Duration, ...) *Signaller
  • func (s *Signaller) Start()

Constants

const (
	FixedIntervalOffset int64 = 10
	TimeBuffer          int64 = 3
)

Types

type BothanClient

type BothanClient interface {
	bothanclient.Client
}

type FeedQuerier

type FeedQuerier interface {
	QueryValidValidator(valAddress sdk.ValAddress) (*feeds.QueryValidValidatorResponse, error)
	QueryValidatorPrices(valAddress sdk.ValAddress) (*feeds.QueryValidatorPricesResponse, error)
	QueryParams() (*feeds.QueryParamsResponse, error)
	QueryCurrentFeeds() (*feeds.QueryCurrentFeedsResponse, error)
}

type Signaller

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

func New

func New(
	feedQuerier FeedQuerier,
	bothanClient BothanClient,
	interval time.Duration,
	submitCh chan<- submitter.SignalPriceSubmission,
	logger *logger.Logger,
	valAddress sdk.ValAddress,
	pendingSignalIDs *sync.Map,
	distributionStartPercentage uint64,
	distributionOffsetPercentage uint64,
) *Signaller

func (*Signaller) Start

func (s *Signaller) Start()