repository

package
v0.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 24, 2023 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrContainerNotFound = errors.New("container not found")
)
View Source 
var (
	ErrInstanceNotFound = errors.New("logs for this uuid are not found")
)
View Source 
var (
	ErrPkgNotFound = errors2.New("package not found")
)

Functions

This section is empty.

Types

type EventInMemoryRepository added in v0.1.1 

type EventInMemoryRepository struct {
	// contains filtered or unexported fields
}

func NewEventInMemoryRepository added in v0.1.1 

func NewEventInMemoryRepository() EventInMemoryRepository

func (*EventInMemoryRepository) AddListener added in v0.1.1 

func (r *EventInMemoryRepository) AddListener(l types.Listener)

func (*EventInMemoryRepository) RemoveListener added in v0.1.1 

func (r *EventInMemoryRepository) RemoveListener(l types.Listener)

func (*EventInMemoryRepository) Send added in v0.1.1 

func (r *EventInMemoryRepository) Send(e interface{})

type InstanceFSRepository added in v0.1.1 

type InstanceFSRepository struct {
	// contains filtered or unexported fields
}

func NewInstanceFSRepository added in v0.1.1 

func NewInstanceFSRepository() InstanceFSRepository

func (*InstanceFSRepository) Delete added in v0.1.1 

func (r *InstanceFSRepository) Delete(uuid uuid.UUID) error

func (*InstanceFSRepository) Exists added in v0.1.1 

func (r *InstanceFSRepository) Exists(uuid uuid.UUID) bool

func (*InstanceFSRepository) Get added in v0.1.1 

func (r *InstanceFSRepository) Get(uuid uuid.UUID) (*types.Instance, error)

func (*InstanceFSRepository) GetAll added in v0.1.1 

func (r *InstanceFSRepository) GetAll() map[uuid.UUID]*types.Instance

func (*InstanceFSRepository) GetPath added in v0.1.1 

func (r *InstanceFSRepository) GetPath(uuid uuid.UUID) string

func (*InstanceFSRepository) LoadEnv added in v0.1.1 

func (r *InstanceFSRepository) LoadEnv(i *types.Instance) error

func (*InstanceFSRepository) LoadMetadata added in v0.1.1 

func (r *InstanceFSRepository) LoadMetadata(i *types.Instance) error

func (*InstanceFSRepository) ReadService added in v0.1.1 

func (r *InstanceFSRepository) ReadService(instancePath string) (types.Service, error)

func (*InstanceFSRepository) Reload added in v0.1.1 

func (r *InstanceFSRepository) Reload(load func(uuid uuid.UUID))

func (*InstanceFSRepository) SaveEnv added in v0.1.1 

func (r *InstanceFSRepository) SaveEnv(i *types.Instance, variables map[string]string) error

func (*InstanceFSRepository) SaveMetadata added in v0.1.1 

func (r *InstanceFSRepository) SaveMetadata(i *types.Instance) error

func (*InstanceFSRepository) Set added in v0.1.1 

func (r *InstanceFSRepository) Set(uuid uuid.UUID, instance types.Instance) error

type InstanceLogger added in v0.1.1 

type InstanceLogger struct {
	// contains filtered or unexported fields
}

func (*InstanceLogger) Close added in v0.1.1 

func (l *InstanceLogger) Close() error

type InstanceLogsFSRepository added in v0.1.1 

type InstanceLogsFSRepository struct {
	// contains filtered or unexported fields
}

func NewInstanceLogsFSRepository added in v0.1.1 

func NewInstanceLogsFSRepository() InstanceLogsFSRepository

func (*InstanceLogsFSRepository) Close added in v0.1.1 

func (r *InstanceLogsFSRepository) Close(uuid uuid.UUID) error

func (*InstanceLogsFSRepository) CloseAll added in v0.1.1 

func (r *InstanceLogsFSRepository) CloseAll() error

func (*InstanceLogsFSRepository) LoadBuffer added in v0.1.1 

func (r *InstanceLogsFSRepository) LoadBuffer(uuid uuid.UUID) ([]types.LogLine, error)

func (*InstanceLogsFSRepository) Open added in v0.1.1 

func (r *InstanceLogsFSRepository) Open(uuid uuid.UUID) error

func (*InstanceLogsFSRepository) Push added in v0.1.1 

func (r *InstanceLogsFSRepository) Push(uuid uuid.UUID, line types.LogLine)

type PackageFSRepository added in v0.1.1 

type PackageFSRepository struct {
	// contains filtered or unexported fields
}

func NewPackageFSRepository added in v0.1.1 

func NewPackageFSRepository(params *PackageRepositoryParams) PackageFSRepository

func (*PackageFSRepository) Get added in v0.1.1 

func (r *PackageFSRepository) Get(id string) (types.Package, error)

func (*PackageFSRepository) GetPath added in v0.1.1 

func (r *PackageFSRepository) GetPath(id string) string

type PackageRepositoryParams 

type PackageRepositoryParams struct {
	// contains filtered or unexported fields
}

type RunnerDockerRepository added in v0.1.1 

type RunnerDockerRepository struct {
	// contains filtered or unexported fields
}

func NewRunnerDockerRepository added in v0.1.1 

func NewRunnerDockerRepository() RunnerDockerRepository

func (RunnerDockerRepository) CheckForUpdates added in v0.4.0 

func (r RunnerDockerRepository) CheckForUpdates(instance *types.Instance) error

func (RunnerDockerRepository) Delete added in v0.1.1 

func (r RunnerDockerRepository) Delete(instance *types.Instance) error

func (RunnerDockerRepository) HasUpdateAvailable added in v0.4.0 

func (r RunnerDockerRepository) HasUpdateAvailable(instance types.Instance) (bool, error)

func (RunnerDockerRepository) Info added in v0.1.1 

func (r RunnerDockerRepository) Info(instance types.Instance) (map[string]any, error)

func (RunnerDockerRepository) Start added in v0.1.1 

func (r RunnerDockerRepository) Start(instance *types.Instance, onLog func(msg string), onErr func(msg string), setStatus func(status string)) error

func (RunnerDockerRepository) Stop added in v0.1.1 

func (r RunnerDockerRepository) Stop(instance *types.Instance) error

type RunnerFSRepository added in v0.1.1 

type RunnerFSRepository struct {
	// contains filtered or unexported fields
}

func NewRunnerFSRepository added in v0.1.1 

func NewRunnerFSRepository() RunnerFSRepository

func (RunnerFSRepository) CheckForUpdates added in v0.4.0 

func (r RunnerFSRepository) CheckForUpdates(instance *types.Instance) error

func (RunnerFSRepository) Delete added in v0.1.1 

func (r RunnerFSRepository) Delete(instance *types.Instance) error

func (RunnerFSRepository) HasUpdateAvailable added in v0.4.0 

func (r RunnerFSRepository) HasUpdateAvailable(instance types.Instance) (bool, error)

func (RunnerFSRepository) Info added in v0.1.1 

func (r RunnerFSRepository) Info(instance types.Instance) (map[string]any, error)

func (RunnerFSRepository) Start added in v0.1.1 

func (r RunnerFSRepository) Start(instance *types.Instance, onLog func(msg string), onErr func(msg string), setStatus func(status string)) error

func (RunnerFSRepository) Stop added in v0.1.1 

func (r RunnerFSRepository) Stop(instance *types.Instance) error

type ServiceFSRepository added in v0.1.1 

type ServiceFSRepository struct {
	// contains filtered or unexported fields
}

func NewServiceFSRepository added in v0.1.1 

func NewServiceFSRepository(params *ServiceRepositoryParams) ServiceFSRepository

func (*ServiceFSRepository) Get added in v0.2.0 

func (r *ServiceFSRepository) Get(id string) (types.Service, error)

func (*ServiceFSRepository) GetAll added in v0.1.1 

func (r *ServiceFSRepository) GetAll() []types.Service

func (*ServiceFSRepository) GetScript added in v0.3.0 

func (r *ServiceFSRepository) GetScript(id string) ([]byte, error)

type ServiceRepositoryParams 

type ServiceRepositoryParams struct {
	// contains filtered or unexported fields
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.