sync

Documentation

Index

• type SyncRepository
• type SyncService
  • func NewService(repositoryService *db.RepositoryService, ...) *SyncService
  • func (r *SyncService) AddHandler(version, identifier string, syncer Syncer)
  • func (r *SyncService) StartService(shutdownCtx context.Context, waitGroup *sync.WaitGroup)
  • func (r *SyncService) SynchronizeCredential(credential db.Credential, fullSync, withTariffs bool, lastUpdated *time.Time, ...)
• type Syncer
• type SyncerHandler

Types

type SyncRepository

type SyncRepository interface{}

type SyncService

type SyncService struct {
	Repository           SyncRepository
	AtCpiService         *atcpi.AtCpiService
	DeIseService         *deise.DeIseService
	ItBecService         *itbec.ItBecService
	NlConService         *nlcon.NlConService
	CredentialRepository credential.CredentialRepository
	PartyRepository      party.PartyRepository
	VersionResolver      *version.VersionResolver
	// contains filtered or unexported fields
}

func NewService

func NewService(repositoryService *db.RepositoryService, ocpiService *transportation.OcpiService) *SyncService

func (*SyncService) AddHandler

func (r *SyncService) AddHandler(version, identifier string, syncer Syncer)

func (*SyncService) StartService

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

func (*SyncService) SynchronizeCredential

func (r *SyncService) SynchronizeCredential(credential db.Credential, fullSync, withTariffs bool, lastUpdated *time.Time, countryCode *string, partyID *string)

type Syncer

type Syncer interface {
	SyncByIdentifier(ctx context.Context, credential db.Credential, fullSync bool, lastUpdated *time.Time, countryCode *string, partyID *string)
}

type SyncerHandler

type SyncerHandler struct {
	Version    string
	Identifier string
	Syncer     Syncer
}