updates

Documentation

Index

• type ActiveProposalsWorker
  • func NewActiveProposalsWorker(sdk *snapshot.SDK, proposals *db.ProposalService, checkInterval time.Duration) *ActiveProposalsWorker
  • func (w *ActiveProposalsWorker) Start(ctx context.Context) error
• type ProposalWorker
  • func NewProposalsWorker(sdk *snapshot.SDK, proposals *db.ProposalService, checkInterval time.Duration) *ProposalWorker
  • func (w *ProposalWorker) Start(ctx context.Context) error
• type SpacesWorker
  • func NewSpacesWorker(sdk *snapshot.SDK, spaces *db.SpaceService, checkInterval time.Duration) *SpacesWorker
  • func (w *SpacesWorker) Start(ctx context.Context) error
• type VoteWorker
  • func NewVotesWorker(sdk *snapshot.SDK, votes *db.VoteService, proposals *db.ProposalService, ...) *VoteWorker
  • func (w *VoteWorker) LoadActive(ctx context.Context) error
  • func (w *VoteWorker) LoadHistorical(ctx context.Context) error

Types

type ActiveProposalsWorker

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

func NewActiveProposalsWorker

func NewActiveProposalsWorker(sdk *snapshot.SDK, proposals *db.ProposalService, checkInterval time.Duration) *ActiveProposalsWorker

func (*ActiveProposalsWorker) Start

func (w *ActiveProposalsWorker) Start(ctx context.Context) error

type ProposalWorker

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

func NewProposalsWorker

func NewProposalsWorker(sdk *snapshot.SDK, proposals *db.ProposalService, checkInterval time.Duration) *ProposalWorker

func (*ProposalWorker) Start

func (w *ProposalWorker) Start(ctx context.Context) error

type SpacesWorker

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

func NewSpacesWorker

func NewSpacesWorker(sdk *snapshot.SDK, spaces *db.SpaceService, checkInterval time.Duration) *SpacesWorker

func (*SpacesWorker) Start

func (w *SpacesWorker) Start(ctx context.Context) error

type VoteWorker

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

func NewVotesWorker

func NewVotesWorker(
	sdk *snapshot.SDK,
	votes *db.VoteService,
	proposals *db.ProposalService,
	checkInterval time.Duration,
) *VoteWorker

func (*VoteWorker) LoadActive

func (w *VoteWorker) LoadActive(ctx context.Context) error

func (*VoteWorker) LoadHistorical

func (w *VoteWorker) LoadHistorical(ctx context.Context) error