servicemanager

package

v0.0.0-...-15f1d61 Latest Latest Go to latest Published: Apr 9, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/aoscloud/aos_servicemanager

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type ImageParts
type ServiceInfo
type ServiceManager
- func New(config *config.Config, serviceInfoProvider ServiceStorage) (sm *ServiceManager, err error)
type ServiceStorage

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrNotExist not exist service error.
	ErrNotExist = errors.New("service not exist")
	// ErrVersionMismatch new service version <= existing one.
	ErrVersionMismatch = errors.New("version mismatch")
)

View Source

var NewSpaceAllocator = spaceallocator.New

NewSpaceAllocator space allocator constructor.

View Source

var RemoveCachedServicesPeriod = 24 * time.Hour

RemoveCachedServicesPeriod global variable is used to be able to mocking the services TTL functionality in test.

Functions ¶

This section is empty.

Types ¶

type ImageParts ¶

type ImageParts struct {
	ImageConfigPath   string
	ServiceConfigPath string
	ServiceFSPath     string
	LayersDigest      []string
}

ImageParts struct with paths for image parts.

type ServiceInfo ¶

type ServiceInfo struct {
	aostypes.VersionInfo
	ServiceID       string
	ServiceProvider string
	ImagePath       string
	ManifestDigest  []byte
	Timestamp       time.Time
	Cached          bool
	Size            uint64
	GID             uint32
}

ServiceInfo service information.

type ServiceManager ¶

type ServiceManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

ServiceManager instance.

func New ¶

func New(
	config *config.Config, serviceInfoProvider ServiceStorage,
) (sm *ServiceManager, err error)

New creates new service manager object.

func (*ServiceManager) Close ¶

func (sm *ServiceManager) Close()

Close closes service manager instance.

func (*ServiceManager) GetImageParts ¶

func (sm *ServiceManager) GetImageParts(service ServiceInfo) (parts ImageParts, err error)

GetImageParts gets image parts for the service.

func (*ServiceManager) GetServiceInfo ¶

func (sm *ServiceManager) GetServiceInfo(serviceID string) (serviceInfo ServiceInfo, err error)

GetServiceInfo gets service information by id.

func (*ServiceManager) ProcessDesiredServices ¶

func (sm *ServiceManager) ProcessDesiredServices(desiredServices []aostypes.ServiceInfo) error

ProcessDesiredServices installs, removes, restores desired services on the system.

func (*ServiceManager) ValidateService ¶

func (sm *ServiceManager) ValidateService(service ServiceInfo) error

ValidateService validate service.

type ServiceStorage ¶

type ServiceStorage interface {
	GetAllServiceVersions(serviceID string) ([]ServiceInfo, error)
	GetServices() ([]ServiceInfo, error)
	AddService(info ServiceInfo) error
	RemoveService(serviceID string, aosVersion uint64) error
	SetServiceCached(serviceID string, aosVersion uint64, cached bool) error
}

ServiceStorage provides API to create, remove or access services DB.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL