sources

Documentation

Index

• Variables
• type Payload
• type Service
  • func NewService(ctx context.Context, sources *viper.Viper, sourcesURL string, ...) (*Service, error)
  • func NewTestService() *Service
  • func (s *Service) Close() (multiErr error)
  • func (s *Service) GetCollections(sourceID string) ([]string, error)
  • func (s *Service) GetSource(sourceID string) (*Unit, error)
  • func (s *Service) IsConfigured() bool
• type Status
• type Unit
  • func (u *Unit) Close() (multiErr error)

Variables

var StatusInstance = &Status{Reloading: false}

Types

type Payload

type Payload struct {
	Sources map[string]driversbase.SourceConfig `json:"sources,omitempty"`
}

type Service

type Service struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Service keep up-to-date sources

func NewService

func NewService(ctx context.Context, sources *viper.Viper, sourcesURL string, destinationsService *destinations.Service, metaStorage meta.Storage,
	cronScheduler *scheduling.CronScheduler) (*Service, error)

NewService returns initialized Service instance or error if occurred

func NewTestService

func NewTestService() *Service

NewTestService is used only for tests

func (*Service) Close

func (s *Service) Close() (multiErr error)

func (*Service) GetCollections

func (s *Service) GetCollections(sourceID string) ([]string, error)

func (*Service) GetSource

func (s *Service) GetSource(sourceID string) (*Unit, error)

func (*Service) IsConfigured

func (s *Service) IsConfigured() bool

type Status

type Status struct {
	Reloading bool
}

Status is a singleton struct for storing sources reloading state. Scheduler checks this flag and doesn't run Sync tasks

type Unit

type Unit struct {
	SourceID                 string
	SourceType               string
	DriverPerCollection      map[string]driversbase.Driver
	DestinationIDs           []string
	PostHandleDestinationIDs []string
	Notifications            map[string]interface{}
	ProjectName              string
	// contains filtered or unexported fields
}

func (*Unit) Close

func (u *Unit) Close() (multiErr error)

Close all drivers