candidates

Documentation

Index

• type AuthorizerCandidatesScanner
  • func NewAuthorizerCandidatesScanner(logger zerolog.Logger) AuthorizerCandidatesScanner
  • func (s AuthorizerCandidatesScanner) GetCollection(client client.Client, ctx context.Context, id flow.Identifier) (coll *flow.Collection, err error)
  • func (s AuthorizerCandidatesScanner) Scan(ctx context.Context, client client.Client, blocks BlockRange) CandidatesResult
• type BlockRange
• type CandidateScanner
• type CandidatesResult
  • func NewCandidatesResult(addresses map[flow.Address]struct{}) CandidatesResult
  • func NewCandidatesResultError(err error) CandidatesResult
  • func WaitForCandidateResults(candidatesChan <-chan CandidatesResult, expectedResults int) CandidatesResult
  • func (r *CandidatesResult) Err() error
  • func (r *CandidatesResult) MergeWith(r2 CandidatesResult)
• type EventCandidatesScanner
  • func NewEventCandidatesScanner(eventType string, ...) *EventCandidatesScanner
  • func (s *EventCandidatesScanner) Scan(ctx context.Context, client client.Client, blocks BlockRange) CandidatesResult

Types

type AuthorizerCandidatesScanner

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

func NewAuthorizerCandidatesScanner

func NewAuthorizerCandidatesScanner(logger zerolog.Logger) AuthorizerCandidatesScanner

func (AuthorizerCandidatesScanner) GetCollection

func (s AuthorizerCandidatesScanner) GetCollection(
	client client.Client,
	ctx context.Context,
	id flow.Identifier,
) (coll *flow.Collection, err error)

func (AuthorizerCandidatesScanner) Scan

func (s AuthorizerCandidatesScanner) Scan(
	ctx context.Context,
	client client.Client,
	blocks BlockRange,
) CandidatesResult

type BlockRange

type BlockRange struct {
	Start uint64
	End   uint64 // inclusive
}

type CandidateScanner

type CandidateScanner interface {
	Scan(ctx context.Context, client client.Client, blocks BlockRange) CandidatesResult
}

type CandidatesResult

type CandidatesResult struct {
	Addresses map[flow.Address]struct{}
	// contains filtered or unexported fields
}

func NewCandidatesResult

func NewCandidatesResult(addresses map[flow.Address]struct{}) CandidatesResult

func NewCandidatesResultError

func NewCandidatesResultError(err error) CandidatesResult

func WaitForCandidateResults

func WaitForCandidateResults(
	candidatesChan <-chan CandidatesResult,
	expectedResults int,
) CandidatesResult

func (*CandidatesResult) Err

func (r *CandidatesResult) Err() error

func (*CandidatesResult) MergeWith

func (r *CandidatesResult) MergeWith(r2 CandidatesResult)

type EventCandidatesScanner

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

func NewEventCandidatesScanner

func NewEventCandidatesScanner(
	eventType string,
	candidateAddressFromEvent func(event cadence.Event) (flow.Address, error),
	logger zerolog.Logger,
) *EventCandidatesScanner

func (*EventCandidatesScanner) Scan

func (s *EventCandidatesScanner) Scan(
	ctx context.Context,
	client client.Client,
	blocks BlockRange,
) CandidatesResult