updater

Documentation

Index

• Variables
• func New(configuration librepo.Configuration, customConfig config.CustomConfiguration, ...) service.Updater
• type Impl
  • func (s *Impl) CanDeleteOwner(ctx context.Context, ownerAlias string) bool
  • func (s *Impl) CanMoveOrDeleteRepository(ctx context.Context, key string) bool
  • func (s *Impl) DeleteOwner(ctx context.Context, ownerAlias string, deletionInfo openapi.DeletionDto) error
  • func (s *Impl) DeleteRepository(ctx context.Context, key string, deletionInfo openapi.DeletionDto) error
  • func (s *Impl) DeleteService(ctx context.Context, serviceName string, deletionInfo openapi.DeletionDto) error
  • func (s *Impl) IsUpdater() bool
  • func (s *Impl) PerformFullUpdate(ctx context.Context) error
  • func (s *Impl) PerformFullUpdateWithNotifications(ctx context.Context) error
  • func (s *Impl) RefreshRepository(ctx context.Context, key string) error
  • func (s *Impl) RefreshService(ctx context.Context, serviceName string) error
  • func (s *Impl) Setup() error
  • func (s *Impl) SetupUpdater(ctx context.Context) error
  • func (s *Impl) StartReceivingEvents(ctx context.Context) error
  • func (s *Impl) WithMetadataLock(ctx context.Context, closure func(context.Context) error) error
  • func (s *Impl) WriteOwner(ctx context.Context, ownerAlias string, owner openapi.OwnerDto) (openapi.OwnerDto, error)
  • func (s *Impl) WriteRepository(ctx context.Context, key string, repository openapi.RepositoryDto) (openapi.RepositoryDto, error)
  • func (s *Impl) WriteService(ctx context.Context, serviceName string, service openapi.ServiceDto) (openapi.ServiceDto, error)

Variables

var (
	TotalErrorCounterName    = "updater_error_count"
	MetadataErrorCounterName = "updater_error_metadata_count"
	OwnerErrorCounterName    = "updater_error_owner_count"
	ServiceErrorCounterName  = "updater_error_service_count"
	RepoErrorCounterName     = "updater_error_repo_count"
)

var TimeStampFormat = "2006-01-02T15:04:05Z"

Functions

func New

func New(
	configuration librepo.Configuration,
	customConfig config.CustomConfiguration,
	logging librepo.Logging,
	timestamp librepo.Timestamp,
	kafka repository.Kafka,
	notifier repository.Notifier,
	mapper service.Mapper,
	cache service.Cache,
) service.Updater

Types

type Impl

type Impl struct {
	Configuration       librepo.Configuration
	CustomConfiguration config.CustomConfiguration
	Logging             librepo.Logging
	Timestamp           librepo.Timestamp
	Kafka               repository.Kafka
	Notifier            repository.Notifier
	Mapper              service.Mapper
	Cache               service.Cache
	// contains filtered or unexported fields
}

func (*Impl) CanDeleteOwner

func (s *Impl) CanDeleteOwner(ctx context.Context, ownerAlias string) bool

func (*Impl) CanMoveOrDeleteRepository

func (s *Impl) CanMoveOrDeleteRepository(ctx context.Context, key string) bool

func (*Impl) DeleteOwner

func (s *Impl) DeleteOwner(ctx context.Context, ownerAlias string, deletionInfo openapi.DeletionDto) error

func (*Impl) DeleteRepository

func (s *Impl) DeleteRepository(ctx context.Context, key string, deletionInfo openapi.DeletionDto) error

func (*Impl) DeleteService

func (s *Impl) DeleteService(ctx context.Context, serviceName string, deletionInfo openapi.DeletionDto) error

func (*Impl) IsUpdater

func (s *Impl) IsUpdater() bool

func (*Impl) PerformFullUpdate

func (s *Impl) PerformFullUpdate(ctx context.Context) error

func (*Impl) PerformFullUpdateWithNotifications

func (s *Impl) PerformFullUpdateWithNotifications(ctx context.Context) error

func (*Impl) RefreshRepository

func (s *Impl) RefreshRepository(ctx context.Context, key string) error

func (*Impl) RefreshService

func (s *Impl) RefreshService(ctx context.Context, serviceName string) error

func (*Impl) Setup

func (s *Impl) Setup() error

func (*Impl) SetupUpdater

func (s *Impl) SetupUpdater(ctx context.Context) error

func (*Impl) StartReceivingEvents

func (s *Impl) StartReceivingEvents(ctx context.Context) error

func (*Impl) WithMetadataLock

func (s *Impl) WithMetadataLock(ctx context.Context, closure func(context.Context) error) error

func (*Impl) WriteOwner

func (s *Impl) WriteOwner(ctx context.Context, ownerAlias string, owner openapi.OwnerDto) (openapi.OwnerDto, error)

func (*Impl) WriteRepository

func (s *Impl) WriteRepository(ctx context.Context, key string, repository openapi.RepositoryDto) (openapi.RepositoryDto, error)

func (*Impl) WriteService

func (s *Impl) WriteService(ctx context.Context, serviceName string, service openapi.ServiceDto) (openapi.ServiceDto, error)