blockchain

Documentation

Index

• type Service
  • func NewService(logger logger.Logger, repository *block.Repository, kafkaAdapter kafka.Kafka, ...) *Service
  • func (b *Service) StartBlockWorker(ctx context.Context, wg *sync.WaitGroup, heightCh chan int) error
  • func (b *Service) StartHeightWorker(ctx context.Context, wg *sync.WaitGroup, heightCh chan int) error

Types

type Service

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

func NewService

func NewService(
	logger logger.Logger,
	repository *block.Repository,
	kafkaAdapter kafka.Kafka,
	bcProvider bitcoin.Provider,
	defaultHeight int, heightPollingInterval int, blockPollingInterval int, rpcURL string, apiKey string, kafkaTopic string,
) *Service

func (*Service) StartBlockWorker

func (b *Service) StartBlockWorker(ctx context.Context, wg *sync.WaitGroup, heightCh chan int) error

func (*Service) StartHeightWorker

func (b *Service) StartHeightWorker(ctx context.Context, wg *sync.WaitGroup, heightCh chan int) error