payer

type ClientManager ¶ added in v0.1.1

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

* The ClientManager contains a mapping of nodeIDs to gRPC client connections.

These client connections are safe to be shared and re-used and will automatically attempt to reconnect if the underlying socket connection is lost. *

func NewClientManager(log *zap.Logger, nodeRegistry registry.NodeRegistry) *ClientManager

func (c *ClientManager) GetClient(nodeID uint32) (*grpc.ClientConn, error)

type DefaultMetadataApiClientConstructor ¶ added in v0.2.0

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

func (c *DefaultMetadataApiClientConstructor) NewMetadataApiClient(
	nodeId uint32,
) (metadata_api.MetadataApiClient, error)

type MetadataApiClientConstructor ¶ added in v0.2.0

type MetadataApiClientConstructor interface {
	NewMetadataApiClient(nodeId uint32) (metadata_api.MetadataApiClient, error)
}

type NodeCursorTracker ¶ added in v0.2.0

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

func NewNodeCursorTracker(ctx context.Context,
	log *zap.Logger, metadataApiClient MetadataApiClientConstructor) *NodeCursorTracker

func (ct *NodeCursorTracker) BlockUntilDesiredCursorReached(
	ctx context.Context,
	nodeId uint32,
	desiredOriginatorId uint32,
	desiredSequenceId uint64,
) error

type NodeSelectorAlgorithm ¶ added in v0.2.0

type NodeSelectorAlgorithm interface {
	GetNode(topic topic.Topic) (uint32, error)
}

type Service ¶

type Service struct {
	payer_api.UnimplementedPayerApiServer
	// contains filtered or unexported fields
}

func NewPayerApiService(
	ctx context.Context,
	log *zap.Logger,
	registry registry.NodeRegistry,
	payerPrivateKey *ecdsa.PrivateKey,
	blockchainPublisher blockchain.IBlockchainPublisher,
	metadataApiClient MetadataApiClientConstructor,
) (*Service, error)

func (s *Service) PublishClientEnvelopes(
	ctx context.Context,
	req *payer_api.PublishClientEnvelopesRequest,
) (*payer_api.PublishClientEnvelopesResponse, error)

type StableHashingNodeSelectorAlgorithm ¶ added in v0.2.0

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

func NewStableHashingNodeSelectorAlgorithm(
	reg registry.NodeRegistry,
) *StableHashingNodeSelectorAlgorithm

func (s *StableHashingNodeSelectorAlgorithm) GetNode(topic topic.Topic) (uint32, error)