consumers

Documentation

Index

• type CryptoServiceClient
• type Storage
• type WalletBalanceConsumer
  • func NewWalletBalanceConsumer(storage Storage, cryptoServiceClient CryptoServiceClient) *WalletBalanceConsumer
  • func (c *WalletBalanceConsumer) Consume(ctx context.Context, msg []byte) error

Types

type CryptoServiceClient

type CryptoServiceClient interface {
	Transfer(ctx context.Context, in *crypto_service.TransferRequest, opts ...grpc.CallOption) (*crypto_service.TransferResponse, error)
}

type Storage

type Storage interface {
	ListInvoices(ctx context.Context, filter storage.ListInvoicesFilter, pagination postgres.Pagination) ([]*models.Invoice, error)
	UpdateInvoice(ctx context.Context, invoice *models.Invoice) (*models.Invoice, error)
}

type WalletBalanceConsumer

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

func NewWalletBalanceConsumer

func NewWalletBalanceConsumer(
	storage Storage,
	cryptoServiceClient CryptoServiceClient,
) *WalletBalanceConsumer

func (*WalletBalanceConsumer) Consume

func (c *WalletBalanceConsumer) Consume(ctx context.Context, msg []byte) error