dca

package
v0.0.0-...-bc78c8b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 31, 2021 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AssetsRepository

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

AssetsRepository fetches and stores dca assets bought

func NewAssetsRepository

func NewAssetsRepository(repo domain.Repository) *AssetsRepository

NewAssetsRepository returns an instance of dca AssetsRepository

func (*AssetsRepository) FindAll

func (r *AssetsRepository) FindAll() (*[]domain.DCAAsset, error)

FindAll fetches existing dca jobs

func (*AssetsRepository) Save

func (r *AssetsRepository) Save(dcaAsset *domain.DCAAsset) error

Save persists dca job in database

type JobsRepository

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

JobsRepository fetches and stores dca jobs

func NewJobsRepository

func NewJobsRepository(repo domain.Repository) *JobsRepository

NewJobsRepository returns an instance of dca Jobsrepository

func (*JobsRepository) FindAll

func (r *JobsRepository) FindAll() (*[]domain.DCAJob, error)

FindAll fetches existing dca jobs

func (*JobsRepository) Save

func (r *JobsRepository) Save(dcaJob *domain.DCAJob) error

Save persists dca job in database

type Service

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

Service executes DCA operations

func NewService

func NewService(broker domain.Broker, collector domain.Collector, dcaJobsRepo domain.DCAJobsRepository, dcaAssetsRepo domain.DCAAssetsRepository) *Service

NewService returns an instance of the DCAService

func (*Service) CreateDCA

func (s *Service) CreateDCA(dcaJob *domain.DCAJob) error

CreateDCA creates a dca job in repository

func (*Service) DrainDCA

func (s *Service) DrainDCA() error

DrainDCA fetches dca jobs and execute dca operations

func (*Service) SetNotificationsService

func (s *Service) SetNotificationsService(service domain.NotificationsService)

SetNotificationsService initializes service that will send notifications

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL