deise

Documentation

Index

• Constants
• type DeIseRepository
• type DeIseService
  • func NewService(repositoryService *db.RepositoryService) *DeIseService
  • func (r *DeIseService) Run(ctx context.Context, credential db.Credential, lastUpdated time.Time)
  • func (r *DeIseService) StartService(shutdownCtx context.Context, waitGroup *sync.WaitGroup)
• type DeIseTariffDto
  • func UnmarshalDto(body io.ReadCloser) ([]*DeIseTariffDto, error)

Constants

const (
	TARIFF_UID_TEMPLATE = "compleo-%v"
)

Types

type DeIseRepository

type DeIseRepository interface{}

type DeIseService

type DeIseService struct {
	Repository           DeIseRepository
	HTTPRequester        transportation.HTTPRequester
	ConnectorRepository  connector.ConnectorRepository
	DataImportRepository dataimport.DataImportRepository
	ElementResolver      *element.ElementResolver
	TariffRepository     tariff.TariffRepository
	// contains filtered or unexported fields
}

func NewService

func NewService(repositoryService *db.RepositoryService) *DeIseService

func (*DeIseService) Run

func (r *DeIseService) Run(ctx context.Context, credential db.Credential, lastUpdated time.Time)

func (*DeIseService) StartService

func (r *DeIseService) StartService(shutdownCtx context.Context, waitGroup *sync.WaitGroup)

type DeIseTariffDto

type DeIseTariffDto struct {
	EvseID             string  `csv:"EVSE_ID"`
	ActivePriceSet     string  `csv:"ACTIVE_PRICE_SET"`
	ActiveKwhPrice     float64 `csv:"ACTIVE_KWH_PRICE"`
	ActiveMinutePrice  float64 `csv:"ACTIVE_MINUTE_PRICE"`
	ActiveMinuteDelay  int32   `csv:"ACTIVE_MINUTE_DELAY"`
	ActiveSessionPrice float64 `csv:"ACTIVE_SESSION_PRICE"`
	NextPriceSet       string  `csv:"-"`
	NextPriceTimestamp string  `csv:"-"`
	NextKwhPrice       string  `csv:"-"`
	NextMinutePrice    string  `csv:"-"`
	NextMinuteDelay    string  `csv:"-"`
	NextSessionPrice   string  `csv:"-"`
}

func UnmarshalDto

func UnmarshalDto(body io.ReadCloser) ([]*DeIseTariffDto, error)