datatransfer

package

v0.0.0-...-73e0568 Latest Latest Go to latest Published: Oct 16, 2022 License: Apache-2.0 Imports: 17 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/project-flotta/flotta-device-worker

Links

Open Source Insights

Documentation ¶

Overview ¶

Package datatransfer is a generated GoMock package.

Index ¶

Variables
func GetRegistry() prometheus.Gatherer
func UnixMilli(timestamp time.Time) int64
type MockFileSync
- func NewMockFileSync(ctrl *gomock.Controller) *MockFileSync
type MockFileSyncMockRecorder
type Monitor
- func NewMonitor(workloadsManager *workload.WorkloadManager, ...) *Monitor

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	FilesTransferredCounter = factory.NewCounterVec(
		prometheus.CounterOpts{
			Name: "flotta_agent_datasync_files_transferred_counter",
			Help: "The total of files uploaded for a workload",
		}, []string{"workload_name", "direction"})
	BytesTransferredCounter = factory.NewCounterVec(
		prometheus.CounterOpts{
			Name: "flotta_agent_datasync_bytes_transferred_counter",
			Help: "The total number of bytes uploaded for a workload",
		}, []string{"workload_name", "direction"})
	TimeTransferredCounter = factory.NewCounterVec(
		prometheus.CounterOpts{
			Name: "flotta_agent_datasync_time_transferred_counter",
			Help: "The total amount of time spent transferring bytes for a workload",
		}, []string{"workload_name", "direction"})
	DeletedRemoteFilesTransferredCounter = factory.NewCounterVec(
		prometheus.CounterOpts{
			Name: "flotta_agent_datasync_deleted_files_transferred_counter",
			Help: "The total number of files deleted from the target destination",
		}, []string{"workload_name", "direction"})
)

Functions ¶

func GetRegistry ¶

func GetRegistry() prometheus.Gatherer

func UnixMilli ¶

func UnixMilli(timestamp time.Time) int64

Types ¶

type MockFileSync ¶

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

MockFileSync is a mock of FileSync interface.

func NewMockFileSync ¶

func NewMockFileSync(ctrl *gomock.Controller) *MockFileSync

NewMockFileSync creates a new mock instance.

func (*MockFileSync) Connect ¶

func (m *MockFileSync) Connect() error

Connect mocks base method.

func (*MockFileSync) Disconnect ¶

func (m *MockFileSync) Disconnect()

Disconnect mocks base method.

func (*MockFileSync) EXPECT ¶

func (m *MockFileSync) EXPECT() *MockFileSyncMockRecorder

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

func (*MockFileSync) GetStatistics ¶

func (m *MockFileSync) GetStatistics() model.DataSyncStatistics

GetStatistics mocks base method.

func (*MockFileSync) SyncPath ¶

func (m *MockFileSync) SyncPath(arg0, arg1 string) error

SyncPath mocks base method.

type MockFileSyncMockRecorder ¶

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

MockFileSyncMockRecorder is the mock recorder for MockFileSync.

func (*MockFileSyncMockRecorder) Connect ¶

func (mr *MockFileSyncMockRecorder) Connect() *gomock.Call

Connect indicates an expected call of Connect.

func (*MockFileSyncMockRecorder) Disconnect ¶

func (mr *MockFileSyncMockRecorder) Disconnect() *gomock.Call

Disconnect indicates an expected call of Disconnect.

func (*MockFileSyncMockRecorder) GetStatistics ¶

func (mr *MockFileSyncMockRecorder) GetStatistics() *gomock.Call

GetStatistics indicates an expected call of GetStatistics.

func (*MockFileSyncMockRecorder) SyncPath ¶

func (mr *MockFileSyncMockRecorder) SyncPath(arg0, arg1 interface{}) *gomock.Call

SyncPath indicates an expected call of SyncPath.

type Monitor ¶

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

func NewMonitor ¶

func NewMonitor(workloadsManager *workload.WorkloadManager, configManager *configuration.Manager) *Monitor

func (*Monitor) Deregister ¶

func (m *Monitor) Deregister() error

func (*Monitor) ForceSync ¶

func (m *Monitor) ForceSync() error

func (*Monitor) GetLastSuccessfulSyncTime ¶

func (m *Monitor) GetLastSuccessfulSyncTime(workloadName string) *time.Time

func (*Monitor) HasStorageDefined ¶

func (m *Monitor) HasStorageDefined() bool

func (*Monitor) Init ¶

func (m *Monitor) Init(configuration models.DeviceConfigurationMessage) error

func (*Monitor) SetStorage ¶

func (m *Monitor) SetStorage(fs model.FileSync)

func (*Monitor) Start ¶

func (m *Monitor) Start()

func (*Monitor) String ¶

func (m *Monitor) String() string

func (*Monitor) Update ¶

func (m *Monitor) Update(configuration models.DeviceConfigurationMessage) error

func (*Monitor) WorkloadRemoved ¶

func (m *Monitor) WorkloadRemoved(workloadName string)

func (*Monitor) WorkloadStarted ¶

func (m *Monitor) WorkloadStarted(workloadName string, report []*podman.PodReport)

WorkloadStarted is defined to satisfied the workload.Observer Interface, do nothing.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
model
s3

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