pubsub

Documentation

Index

• type CrawlerPubSub
  • func NewCrawlerPubSub(projectID string, topic string) (*CrawlerPubSub, error)
  • func (c *CrawlerPubSub) BuildMessage(newsroomException bool, contractAddress string) (*cpubsub.GooglePubSubMsg, error)
  • func (c *CrawlerPubSub) BuildMultiSigMessage(multiSigException bool, contractAddress string) (*cpubsub.GooglePubSubMsg, error)
  • func (c *CrawlerPubSub) PublishMultiSigExceptionMessage(contractAddress string) error
  • func (c *CrawlerPubSub) PublishNewsroomExceptionMessage(contractAddress string) error
  • func (c *CrawlerPubSub) PublishProcessorTriggerMessage() error
  • func (c *CrawlerPubSub) StartPublishers() error
  • func (c *CrawlerPubSub) StopPublishers() error
• type CrawlerPubSubMessage

Types

type CrawlerPubSub

type CrawlerPubSub struct {
	GooglePubsub *cpubsub.GooglePubSub
	Topic        string
}

CrawlerPubSub handles logic for crawler pubsub

func NewCrawlerPubSub

func NewCrawlerPubSub(projectID string, topic string) (*CrawlerPubSub, error)

NewCrawlerPubSub creates a new CrawlerPubSub

func (*CrawlerPubSub) BuildMessage

func (c *CrawlerPubSub) BuildMessage(newsroomException bool,
	contractAddress string) (*cpubsub.GooglePubSubMsg, error)

BuildMessage builds a message for the publisher

func (*CrawlerPubSub) BuildMultiSigMessage

func (c *CrawlerPubSub) BuildMultiSigMessage(multiSigException bool,
	contractAddress string) (*cpubsub.GooglePubSubMsg, error)

BuildMultiSigMessage builds a message for the publisher

func (*CrawlerPubSub) PublishMultiSigExceptionMessage

func (c *CrawlerPubSub) PublishMultiSigExceptionMessage(contractAddress string) error

PublishMultiSigExceptionMessage sends a message to pubsub to get all past events for a multiSig

func (*CrawlerPubSub) PublishNewsroomExceptionMessage

func (c *CrawlerPubSub) PublishNewsroomExceptionMessage(contractAddress string) error

PublishNewsroomExceptionMessage sends a message to pubsub to get all past events for a newsroom

func (*CrawlerPubSub) PublishProcessorTriggerMessage

func (c *CrawlerPubSub) PublishProcessorTriggerMessage() error

PublishProcessorTriggerMessage publishes an empty message to process events

func (*CrawlerPubSub) StartPublishers

func (c *CrawlerPubSub) StartPublishers() error

StartPublishers starts the publishers

func (*CrawlerPubSub) StopPublishers

func (c *CrawlerPubSub) StopPublishers() error

StopPublishers stops the publishers

type CrawlerPubSubMessage

type CrawlerPubSubMessage struct {
	NewsroomException bool   `json:"newsroomException"`
	MultiSigException bool   `json:"multiSigException"`
	ContractAddress   string `json:"contractAddress"`
}

CrawlerPubSubMessage is the message sent from the crawler