updater

Documentation

Index

• Variables
• func New() auacornapi.Acorn
• type Impl
  • func (s *Impl) AcornName() string
  • func (s *Impl) AssembleAcorn(registry auacornapi.AcornRegistry) error
  • 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(ctx context.Context) error
  • func (s *Impl) SetupAcorn(registry auacornapi.AcornRegistry) error
  • func (s *Impl) StartReceivingEvents(ctx context.Context) error
  • func (s *Impl) TeardownAcorn(registry auacornapi.AcornRegistry) 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() auacornapi.Acorn

Types

type Impl

type Impl struct {
	Configuration       librepo.Configuration
	CustomConfiguration repository.CustomConfiguration
	Logging             librepo.Logging
	Kafka               repository.Kafka
	Mapper              service.Mapper
	Cache               service.Cache

	Now func() time.Time
	// contains filtered or unexported fields
}

func (*Impl) AcornName

func (s *Impl) AcornName() string

func (*Impl) AssembleAcorn

func (s *Impl) AssembleAcorn(registry auacornapi.AcornRegistry) error

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(ctx context.Context) error

func (*Impl) SetupAcorn

func (s *Impl) SetupAcorn(registry auacornapi.AcornRegistry) error

func (*Impl) StartReceivingEvents

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

func (*Impl) TeardownAcorn

func (s *Impl) TeardownAcorn(registry auacornapi.AcornRegistry) 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)