indexer

Documentation

Index

• Variables
• func NewIndexerPublisher(pubsubClient service.PubSubClient) domain.Publisher
• type Config
  • func NewConfigFromOptions(opts servertypes.AppOptions) Config
  • func (c Config) Initialize() domain.Publisher

Variables

var DefaultConfig = Config{
	IsEnabled:                false,
	MaxPublishDelay:          4,
	GCPProjectId:             "",
	BlockTopicId:             "",
	TransactionTopicId:       "",
	PoolTopicId:              "",
	TokenSupplyTopicId:       "",
	TokenSupplyOffsetTopicId: "",
}

DefaultConfig defines the default config for the indexer client.

Functions

func NewIndexerPublisher

func NewIndexerPublisher(pubsubClient service.PubSubClient) domain.Publisher

NewIndexerPublisher creates a new IndexerPublisher with the given PubSubClient

Types

type Config

type Config struct {
	IsEnabled                bool   `mapstructure:"enabled"`
	MaxPublishDelay          int    `mapstructure:"max-publish-delay"`
	GCPProjectId             string `mapstructure:"gcp-project-id"`
	BlockTopicId             string `mapstructure:"block-topic-id"`
	TransactionTopicId       string `mapstructure:"transaction-topic-id"`
	PoolTopicId              string `mapstructure:"pool-topic-id"`
	TokenSupplyTopicId       string `mapstructure:"token-supply-topic-id"`
	TokenSupplyOffsetTopicId string `mapstructure:"token-supply-offset-topic-id"`
	PairTopicId              string `mapstructure:"pair-offset-topic-id"`
}

Config defines the config for the indexer.

func NewConfigFromOptions

func NewConfigFromOptions(opts servertypes.AppOptions) Config

NewConfigFromOptions returns a new indexer config from the given options.

func (Config) Initialize

func (c Config) Initialize() domain.Publisher

Initialize initializes the indexer by creating a new PubSubClient and returning a new IndexerIngester.