service

Documentation

Index

• type PubSubClient
  • func NewPubSubCLient(...) *PubSubClient
  • func (p *PubSubClient) PublishBlock(ctx context.Context, block indexerdomain.Block) error
  • func (p *PubSubClient) PublishPair(ctx context.Context, pair indexerdomain.Pair) error
  • func (p *PubSubClient) PublishPool(ctx context.Context, pool indexerdomain.Pool) error
  • func (p *PubSubClient) PublishTokenSupply(ctx context.Context, tokenSupply indexerdomain.TokenSupply) error
  • func (p *PubSubClient) PublishTokenSupplyOffset(ctx context.Context, tokenSupplyOffset indexerdomain.TokenSupplyOffset) error
  • func (p *PubSubClient) PublishTransaction(ctx context.Context, txn indexerdomain.Transaction) error

Types

type PubSubClient

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

PubSubClient is a client for publishing messages to a PubSub topic.

func NewPubSubCLient

func NewPubSubCLient(projectId, blockTopicId, transactionTopicId, poolTopicId, tokenSupplyTopicId, tokenSupplyOffsetTopicId, pairTopicID string) *PubSubClient

NewPubSubCLient creates a new PubSubClient.

func (*PubSubClient) PublishBlock

func (p *PubSubClient) PublishBlock(ctx context.Context, block indexerdomain.Block) error

Publish implements PubSubClient.PublishBlock

func (*PubSubClient) PublishPair

func (p *PubSubClient) PublishPair(ctx context.Context, pair indexerdomain.Pair) error

PublishPair implements PubSubClient.PublishPair

func (*PubSubClient) PublishPool

func (p *PubSubClient) PublishPool(ctx context.Context, pool indexerdomain.Pool) error

PublishPool implements PubSubClient.PublishPool

func (*PubSubClient) PublishTokenSupply

func (p *PubSubClient) PublishTokenSupply(ctx context.Context, tokenSupply indexerdomain.TokenSupply) error

PublishTokenSupply implements domain.PubSubClient.

func (*PubSubClient) PublishTokenSupplyOffset

func (p *PubSubClient) PublishTokenSupplyOffset(ctx context.Context, tokenSupplyOffset indexerdomain.TokenSupplyOffset) error

PublishTokenSupplyOffset implements domain.PubSubClient.

func (*PubSubClient) PublishTransaction

func (p *PubSubClient) PublishTransaction(ctx context.Context, txn indexerdomain.Transaction) error

PublishTransaction implements PubSubClient.PublishTransaction