local

Documentation

Index

• Constants
• func RunReplication(ctx context.Context, cp coordinator.Coordinator, transfer *model.Transfer, ...) error
• func RunReplicationWithMeteringTags(ctx context.Context, cp coordinator.Coordinator, transfer *model.Transfer, ...) error
• func WithLogger(lgr log.Logger)
• type LocalWorker
  • func NewLocalWorker(cp coordinator.Coordinator, transfer *model.Transfer, ...) *LocalWorker
  • func (w *LocalWorker) Error() error
  • func (w *LocalWorker) Run() error
  • func (w *LocalWorker) Runtime() abstract.Runtime
  • func (w *LocalWorker) Start()
  • func (w *LocalWorker) Stop() error
  • func (w *LocalWorker) StopReplicationSource()
• type Spec
• type SyncTask
  • func NewSyncTask(task *model.TransferOperation, cp coordinator.Coordinator, ...) (*SyncTask, error)
  • func (s *SyncTask) Runtime() abstract.Runtime
  • func (s *SyncTask) Stop()

Constants

const ReplicationStatusMessagesCategory string = "replication"

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()