service

Documentation

Index

• type DataService
  • func (ds *DataService) RepositoriesMaintenance(ctx context.Context, timeout int64)
  • func (ds *DataService) RepositoryEventsProcessing(ctx context.Context, envelope notifications.Envelope) (err error)
  • func (ds *DataService) SyncExistedRepositories(ctx context.Context) error

Types

type DataService

type DataService struct {
	Registry registryInterface
	Storage  engine.Interface
	// contains filtered or unexported fields
}

DataService is service which allow manipulation entries of registry such repositories or tags

func (*DataService) RepositoriesMaintenance

func (ds *DataService) RepositoriesMaintenance(ctx context.Context, timeout int64)

RepositoriesMaintenance check repositories for outdated or updated data in repository storage with 'lastSyncDate' value. Timestamp field update at every sync call in repository storage and compare with 'lastSyncDate' variable. If values above is different garbage collector will remove all outdated entries

func (*DataService) RepositoryEventsProcessing

func (ds *DataService) RepositoryEventsProcessing(ctx context.Context, envelope notifications.Envelope) (err error)

RepositoryEventsProcessing used for processing notification events from registry service

func (*DataService) SyncExistedRepositories

func (ds *DataService) SyncExistedRepositories(ctx context.Context) error

SyncExistedRepositories will check existed entries at a registry service and synchronize it