service

Documentation

Index

• func New(blockUpdatesProcessUtil commondomain.BlockUpdateProcessUtilsI, ...) *sqsStreamingService
• type GRPCClient
  • func NewGRPCCLient(grpcAddress string, grpxMaxCallSizeBytes int, appCodec codec.Codec) *GRPCClient
  • func (g *GRPCClient) PushData(ctx context.Context, height uint64, pools []ingesttypes.PoolI, ...) (err error)

Functions

func New

func New(blockUpdatesProcessUtil commondomain.BlockUpdateProcessUtilsI, poolsExtractor commondomain.PoolExtractor, poolsTransformer domain.PoolsTransformer, poolTracker domain.BlockPoolUpdateTracker, grpcClient domain.SQSGRPClient, blockProcessStrategyManager commondomain.BlockProcessStrategyManager, nodeStatusChecker domain.NodeStatusChecker) *sqsStreamingService

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.

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 []ingesttypes.PoolI, takerFeesMap ingesttypes.TakerFeeMap) (err error)

PushData implements domain.GracefulSQSGRPClient.