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 DeleteProposalConsumer
  • func NewDeleteProposalConsumer(s *db.ProposalService, fc *fetcher.Client, nc *nats.Conn) *DeleteProposalConsumer
  • func (c *DeleteProposalConsumer) Start(ctx context.Context) error
• type MessagesWorker
  • func NewMessagesWorker(sdk *snapshot.SDK, messages *db.MessageService, checkInterval time.Duration) *MessagesWorker
  • func (w *MessagesWorker) Start(ctx context.Context) error
• type ProposalWorker
  • func NewProposalsWorker(sdk *snapshot.SDK, proposals *db.ProposalService, checkInterval time.Duration) *ProposalWorker
  • func (w *ProposalWorker) FetchList(ctx context.Context) error
  • func (w *ProposalWorker) MarkToRefetch(ctx context.Context) error
• type SpacesUpdater
  • func NewSpacesUpdater(sdk *snapshot.SDK, spaces *db.SpaceService) *SpacesUpdater
  • func (s *SpacesUpdater) ProcessSpace(ctx context.Context, space string) error
  • func (s *SpacesUpdater) ProcessSpaces(ctx context.Context, spaces []string) error
• type SpacesWorker
  • func NewSpacesWorker(spaceUpdater *SpacesUpdater, spaces *db.SpaceService, ...) *SpacesWorker
  • func (w *SpacesWorker) Start(ctx context.Context) error
• type UpdateSpaceSettingsConsumer
  • func NewUpdateSpaceSettingsConsumer(su *SpacesUpdater, fc *fetcher.Client, nc *nats.Conn) *UpdateSpaceSettingsConsumer
  • func (c *UpdateSpaceSettingsConsumer) 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 DeleteProposalConsumer

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

func NewDeleteProposalConsumer

func NewDeleteProposalConsumer(
	s *db.ProposalService,
	fc *fetcher.Client,
	nc *nats.Conn,
) *DeleteProposalConsumer

func (*DeleteProposalConsumer) Start

func (c *DeleteProposalConsumer) Start(ctx context.Context) error

type MessagesWorker

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

func NewMessagesWorker

func NewMessagesWorker(sdk *snapshot.SDK, messages *db.MessageService, checkInterval time.Duration) *MessagesWorker

func (*MessagesWorker) Start

func (w *MessagesWorker) 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) FetchList

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

func (*ProposalWorker) MarkToRefetch

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

type SpacesUpdater

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

func NewSpacesUpdater

func NewSpacesUpdater(sdk *snapshot.SDK, spaces *db.SpaceService) *SpacesUpdater

func (*SpacesUpdater) ProcessSpace

func (s *SpacesUpdater) ProcessSpace(ctx context.Context, space string) error

func (*SpacesUpdater) ProcessSpaces

func (s *SpacesUpdater) ProcessSpaces(ctx context.Context, spaces []string) error

type SpacesWorker

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

func NewSpacesWorker

func NewSpacesWorker(spaceUpdater *SpacesUpdater, spaces *db.SpaceService, checkInterval time.Duration) *SpacesWorker

func (*SpacesWorker) Start

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

type UpdateSpaceSettingsConsumer

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

func NewUpdateSpaceSettingsConsumer

func NewUpdateSpaceSettingsConsumer(
	su *SpacesUpdater,
	fc *fetcher.Client,
	nc *nats.Conn,
) *UpdateSpaceSettingsConsumer

func (*UpdateSpaceSettingsConsumer) Start

func (c *UpdateSpaceSettingsConsumer) 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, unrpocessedSpaces unprocessedSpacesFinder, 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