workload

package
v0.0.0-...-73e0568 Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2022 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Package workload is a generated GoMock package.

Index

Constants

View Source 
const (
	AuthFileName     = "auth.json"
	WorkloadFileName = "workload.yaml"
)

Variables

This section is empty.

Functions

func PodShouldWaitForMount 

func PodShouldWaitForMount(pod *v1.Pod, deviceConf *models.DeviceConfiguration) bool

Types

type MockWorkloadWrapper 

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

MockWorkloadWrapper is a mock of WorkloadWrapper interface.

func NewMockWorkloadWrapper 

func NewMockWorkloadWrapper(ctrl *gomock.Controller) *MockWorkloadWrapper

NewMockWorkloadWrapper creates a new mock instance.

func (*MockWorkloadWrapper) CreateSecret 

func (m *MockWorkloadWrapper) CreateSecret(arg0, arg1 string) error

CreateSecret mocks base method.

func (*MockWorkloadWrapper) EXPECT 

func (m *MockWorkloadWrapper) EXPECT() *MockWorkloadWrapperMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockWorkloadWrapper) Init 

func (m *MockWorkloadWrapper) Init() error

Init mocks base method.

func (*MockWorkloadWrapper) List 

func (m *MockWorkloadWrapper) List() ([]api.WorkloadInfo, error)

List mocks base method.

func (*MockWorkloadWrapper) ListSecrets 

func (m *MockWorkloadWrapper) ListSecrets() (map[string]struct{}, error)

ListSecrets mocks base method.

func (*MockWorkloadWrapper) Logs 

func (m *MockWorkloadWrapper) Logs(arg0 string, arg1 io.Writer) (context.CancelFunc, error)

Logs mocks base method.

func (*MockWorkloadWrapper) PersistConfiguration 

func (m *MockWorkloadWrapper) PersistConfiguration() error

PersistConfiguration mocks base method.

func (*MockWorkloadWrapper) RegisterObserver 

func (m *MockWorkloadWrapper) RegisterObserver(arg0 Observer)

RegisterObserver mocks base method.

func (*MockWorkloadWrapper) Remove 

func (m *MockWorkloadWrapper) Remove(arg0 string) error

Remove mocks base method.

func (*MockWorkloadWrapper) RemoveMappingFile 

func (m *MockWorkloadWrapper) RemoveMappingFile() error

RemoveMappingFile mocks base method.

func (*MockWorkloadWrapper) RemoveSecret 

func (m *MockWorkloadWrapper) RemoveSecret(arg0 string) error

RemoveSecret mocks base method.

func (*MockWorkloadWrapper) RemoveServicesFile 

func (m *MockWorkloadWrapper) RemoveServicesFile() error

RemoveServicesFile mocks base method.

func (*MockWorkloadWrapper) RemoveTable 

func (m *MockWorkloadWrapper) RemoveTable() error

RemoveTable mocks base method.

func (*MockWorkloadWrapper) Run 

func (m *MockWorkloadWrapper) Run(arg0 *v1.Pod, arg1, arg2 string, arg3 map[string]string) error

Run mocks base method.

func (*MockWorkloadWrapper) Start 

func (m *MockWorkloadWrapper) Start(arg0 *v1.Pod) error

Start mocks base method.

func (*MockWorkloadWrapper) Stop 

func (m *MockWorkloadWrapper) Stop(arg0 string) error

Stop mocks base method.

func (*MockWorkloadWrapper) UpdateSecret 

func (m *MockWorkloadWrapper) UpdateSecret(arg0, arg1 string) error

UpdateSecret mocks base method.

type MockWorkloadWrapperMockRecorder 

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

MockWorkloadWrapperMockRecorder is the mock recorder for MockWorkloadWrapper.

func (*MockWorkloadWrapperMockRecorder) CreateSecret 

func (mr *MockWorkloadWrapperMockRecorder) CreateSecret(arg0, arg1 interface{}) *gomock.Call

CreateSecret indicates an expected call of CreateSecret.

func (*MockWorkloadWrapperMockRecorder) Init 

func (mr *MockWorkloadWrapperMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init.

func (*MockWorkloadWrapperMockRecorder) List 

func (mr *MockWorkloadWrapperMockRecorder) List() *gomock.Call

List indicates an expected call of List.

func (*MockWorkloadWrapperMockRecorder) ListSecrets 

func (mr *MockWorkloadWrapperMockRecorder) ListSecrets() *gomock.Call

ListSecrets indicates an expected call of ListSecrets.

func (*MockWorkloadWrapperMockRecorder) Logs 

func (mr *MockWorkloadWrapperMockRecorder) Logs(arg0, arg1 interface{}) *gomock.Call

Logs indicates an expected call of Logs.

func (*MockWorkloadWrapperMockRecorder) PersistConfiguration 

func (mr *MockWorkloadWrapperMockRecorder) PersistConfiguration() *gomock.Call

PersistConfiguration indicates an expected call of PersistConfiguration.

func (*MockWorkloadWrapperMockRecorder) RegisterObserver 

func (mr *MockWorkloadWrapperMockRecorder) RegisterObserver(arg0 interface{}) *gomock.Call

RegisterObserver indicates an expected call of RegisterObserver.

func (*MockWorkloadWrapperMockRecorder) Remove 

func (mr *MockWorkloadWrapperMockRecorder) Remove(arg0 interface{}) *gomock.Call

Remove indicates an expected call of Remove.

func (*MockWorkloadWrapperMockRecorder) RemoveMappingFile 

func (mr *MockWorkloadWrapperMockRecorder) RemoveMappingFile() *gomock.Call

RemoveMappingFile indicates an expected call of RemoveMappingFile.

func (*MockWorkloadWrapperMockRecorder) RemoveSecret 

func (mr *MockWorkloadWrapperMockRecorder) RemoveSecret(arg0 interface{}) *gomock.Call

RemoveSecret indicates an expected call of RemoveSecret.

func (*MockWorkloadWrapperMockRecorder) RemoveServicesFile 

func (mr *MockWorkloadWrapperMockRecorder) RemoveServicesFile() *gomock.Call

RemoveServicesFile indicates an expected call of RemoveServicesFile.

func (*MockWorkloadWrapperMockRecorder) RemoveTable 

func (mr *MockWorkloadWrapperMockRecorder) RemoveTable() *gomock.Call

RemoveTable indicates an expected call of RemoveTable.

func (*MockWorkloadWrapperMockRecorder) Run 

func (mr *MockWorkloadWrapperMockRecorder) Run(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

Run indicates an expected call of Run.

func (*MockWorkloadWrapperMockRecorder) Start 

func (mr *MockWorkloadWrapperMockRecorder) Start(arg0 interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockWorkloadWrapperMockRecorder) Stop 

func (mr *MockWorkloadWrapperMockRecorder) Stop(arg0 interface{}) *gomock.Call

Stop indicates an expected call of Stop.

func (*MockWorkloadWrapperMockRecorder) UpdateSecret 

func (mr *MockWorkloadWrapperMockRecorder) UpdateSecret(arg0, arg1 interface{}) *gomock.Call

UpdateSecret indicates an expected call of UpdateSecret.

type Observer 

type Observer interface {
	WorkloadRemoved(workloadName string)
	WorkloadStarted(workloadName string, report []*podman.PodReport)
}

type Workload 

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

Workload manages the workload and its configuration on the device

func NewWorkload 

func NewWorkload(p podman.Podman, n network.Netfilter, m mapping.MappingRepository, s service.SystemdManager, monitoringInterval uint) *Workload

func (*Workload) CreateSecret 

func (ww *Workload) CreateSecret(name, data string) error

func (*Workload) Init 

func (ww *Workload) Init() error

func (*Workload) List 

func (ww *Workload) List() ([]api2.WorkloadInfo, error)

func (*Workload) ListSecrets 

func (ww *Workload) ListSecrets() (map[string]struct{}, error)

func (*Workload) Logs 

func (ww *Workload) Logs(podID string, res io.Writer) (context.CancelFunc, error)

func (*Workload) PersistConfiguration 

func (ww *Workload) PersistConfiguration() error

func (*Workload) RegisterObserver 

func (ww *Workload) RegisterObserver(observer Observer)

func (*Workload) Remove 

func (ww *Workload) Remove(workloadName string) error

func (*Workload) RemoveMappingFile 

func (ww *Workload) RemoveMappingFile() error

func (*Workload) RemoveSecret 

func (ww *Workload) RemoveSecret(name string) error

func (*Workload) RemoveServicesFile 

func (ww *Workload) RemoveServicesFile() error

func (*Workload) RemoveTable 

func (ww *Workload) RemoveTable() error

func (*Workload) Run 

func (ww *Workload) Run(workload *v1.Pod, manifestPath string, authFilePath string, podmanAnnotations map[string]string) error

func (*Workload) Start 

func (ww *Workload) Start(workload *v1.Pod) error

func (*Workload) Stop 

func (ww *Workload) Stop(workloadName string) error

func (*Workload) UpdateSecret 

func (ww *Workload) UpdateSecret(name, data string) error

type WorkloadManager 

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

func NewWorkloadManager 

func NewWorkloadManager(dataDir string, deviceId string) (*WorkloadManager, error)

func NewWorkloadManagerWithParams 

func NewWorkloadManagerWithParams(dataDir string, ww WorkloadWrapper, deviceId string) (*WorkloadManager, error)

func NewWorkloadManagerWithParamsAndInterval 

func NewWorkloadManagerWithParamsAndInterval(dataDir string, ww WorkloadWrapper, monitorInterval uint, deviceId string) (*WorkloadManager, error)

func (*WorkloadManager) Deregister 

func (w *WorkloadManager) Deregister() error

func (*WorkloadManager) GetDeviceID 

func (w *WorkloadManager) GetDeviceID() string

func (*WorkloadManager) GetExportedHostPath 

func (w *WorkloadManager) GetExportedHostPath(workloadName string) string

func (*WorkloadManager) Init 

func (w *WorkloadManager) Init(configuration models.DeviceConfigurationMessage) error

func (*WorkloadManager) ListWorkloads 

func (w *WorkloadManager) ListWorkloads() ([]api2.WorkloadInfo, error)

func (*WorkloadManager) Logs 

func (w *WorkloadManager) Logs(podID string, res io.Writer) (context.CancelFunc, error)

func (*WorkloadManager) PopEvents 

func (w *WorkloadManager) PopEvents() []*models.EventInfo

PopEvents return copy of all the events stored in eventQueue

func (*WorkloadManager) RegisterObserver 

func (w *WorkloadManager) RegisterObserver(observer Observer)

func (*WorkloadManager) StopWorkloads 

func (w *WorkloadManager) StopWorkloads() error

func (*WorkloadManager) String 

func (w *WorkloadManager) String() string

func (*WorkloadManager) Update 

func (w *WorkloadManager) Update(configuration models.DeviceConfigurationMessage) error

type WorkloadWrapper 

type WorkloadWrapper interface {
	Init() error
	RegisterObserver(Observer)
	List() ([]api.WorkloadInfo, error)
	Logs(podID string, res io.Writer) (context.CancelFunc, error)
	Remove(string) error
	Stop(string) error
	Run(*v1.Pod, string, string, map[string]string) error
	Start(*v1.Pod) error
	PersistConfiguration() error
	RemoveTable() error
	RemoveMappingFile() error
	RemoveServicesFile() error
	ListSecrets() (map[string]struct{}, error)
	RemoveSecret(string) error
	CreateSecret(string, string) error
	UpdateSecret(string, string) error
}

Source Files

View all Source files

Directories

Path Synopsis
Package mapping is a generated GoMock package.
 Package mapping is a generated GoMock package.
Package network is a generated GoMock package.
 Package network is a generated GoMock package.
Package podman is a generated GoMock package.
 Package podman is a generated GoMock package.

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.