service

Documentation

Index

• func New(writeListeners map[storetypes.StoreKey][]storetypes.WriteListener, ...) baseapp.StreamingService
• func NewNodeStatusChecker(address string) domain.NodeStatusChecker
• func NewPoolTracker() domain.BlockPoolUpdateTracker
• type GRPCClient
  • func NewGRPCCLient(grpcAddress string, grpxMaxCallSizeBytes int, appCodec codec.Codec) *GRPCClient
  • func (g *GRPCClient) PushData(ctx context.Context, height uint64, pools []sqsdomain.PoolI, ...) (err error)

Functions

func New

func New(writeListeners map[storetypes.StoreKey][]storetypes.WriteListener, sqsIngester domain.Ingester, poolTracker domain.BlockPoolUpdateTracker, nodeStatusChecker domain.NodeStatusChecker) baseapp.StreamingService

New creates a new sqsStreamingService. writeListeners is a map of store keys to write listeners. sqsIngester is an ingester that ingests the block data into SQS. poolTracker is a tracker that tracks the pools that were changed in the block. nodeStatusChecker is a checker that checks if the node is syncing.

func NewNodeStatusChecker

func NewNodeStatusChecker(address string) domain.NodeStatusChecker

func NewPoolTracker

func NewPoolTracker() domain.BlockPoolUpdateTracker

NewPoolTracker creates a new poolBlockUpdateTracker.

Types

type GRPCClient

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

func NewGRPCCLient

func NewGRPCCLient(grpcAddress string, grpxMaxCallSizeBytes int, appCodec codec.Codec) *GRPCClient

func (*GRPCClient) PushData

func (g *GRPCClient) PushData(ctx context.Context, height uint64, pools []sqsdomain.PoolI, takerFeesMap sqsdomain.TakerFeeMap) (err error)

PushData implements domain.GracefulSQSGRPClient.