dca

Documentation

Index

• type AssetsRepository
  • func NewAssetsRepository(repo domain.Repository) *AssetsRepository
  • func (r *AssetsRepository) FindAll() (*[]domain.DCAAsset, error)
  • func (r *AssetsRepository) Save(dcaAsset *domain.DCAAsset) error
• type JobsRepository
  • func NewJobsRepository(repo domain.Repository) *JobsRepository
  • func (r *JobsRepository) FindAll() (*[]domain.DCAJob, error)
  • func (r *JobsRepository) Save(dcaJob *domain.DCAJob) error
• type Service
  • func NewService(broker domain.Broker, collector domain.Collector, ...) *Service
  • func (s *Service) CreateDCA(dcaJob *domain.DCAJob) error
  • func (s *Service) DrainDCA() error
  • func (s *Service) SetNotificationsService(service domain.NotificationsService)

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