local

package
v0.0.0-rc12 Latest Latest
Warning

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

Go to latest
Published: Dec 2, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source
const ReplicationStatusMessagesCategory string = "replication"

Variables

This section is empty.

Functions

func RunReplication

func RunReplication(ctx context.Context, cp coordinator.Coordinator, transfer *model.Transfer, registry metrics.Registry) error

func RunReplicationWithMeteringTags

func RunReplicationWithMeteringTags(ctx context.Context, cp coordinator.Coordinator, transfer *model.Transfer, registry metrics.Registry, runtimeTags map[string]interface{}) error

func WithLogger

func WithLogger(lgr log.Logger)

WithLogger temproray hack to injest global logger into dataplane

Types

type LocalWorker

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

func NewLocalWorker

func NewLocalWorker(cp coordinator.Coordinator, transfer *model.Transfer, registry metrics.Registry, lgr log.Logger) *LocalWorker

func (*LocalWorker) Error

func (w *LocalWorker) Error() error

func (*LocalWorker) Run

func (w *LocalWorker) Run() error

func (*LocalWorker) Runtime

func (w *LocalWorker) Runtime() abstract.Runtime

func (*LocalWorker) Start

func (w *LocalWorker) Start()

func (*LocalWorker) Stop

func (w *LocalWorker) Stop() error

func (*LocalWorker) StopReplicationSource

func (w *LocalWorker) StopReplicationSource()

type Spec

type Spec struct {
	ID   string
	Src  model.Source
	Dst  model.Destination
	Type abstract.TransferType

	Transformation *model.Transformation
	DataObjects    *model.DataObjects
	FolderID       string

	TypeSystemVersion int
}

type SyncTask

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

func NewSyncTask

func NewSyncTask(
	task *model.TransferOperation,
	cp coordinator.Coordinator,
	workflow model.OperationWorkflow,
	transfer model.Transfer,
) (*SyncTask, error)

NewSyncTask only used for local debug, can operate properly only on single machine transfer server installation with enable `all_in_one_binary` flag

func (*SyncTask) Runtime

func (s *SyncTask) Runtime() abstract.Runtime

func (*SyncTask) Stop

func (s *SyncTask) Stop()

Jump to

Keyboard shortcuts

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