payer

Documentation

Index

• type ClientManager
  • func NewClientManager(log *zap.Logger, nodeRegistry registry.NodeRegistry) *ClientManager
  • func (c *ClientManager) GetClient(nodeID uint32) (*grpc.ClientConn, error)
• type Service
  • func NewPayerApiService(ctx context.Context, log *zap.Logger, registry registry.NodeRegistry, ...) (*Service, error)
  • func (s *Service) PublishClientEnvelopes(ctx context.Context, req *payer_api.PublishClientEnvelopesRequest) (*payer_api.PublishClientEnvelopesResponse, error)

Types

type ClientManager

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

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

func (*ClientManager) GetClient

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

type Service

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

func NewPayerApiService

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

func (*Service) PublishClientEnvelopes

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