datasync

Documentation

Index

• func NewDataSync(sid string, stopper *stopper.Stopper, rt moruntime.Runtime, ...) (logservice.DataSync, error)
• type HAKeeperClientFactory
• type LogClient
• type Producer
• type TxnClient
• type Worker

Functions

func NewDataSync

func NewDataSync(
	sid string,
	stopper *stopper.Stopper,
	rt moruntime.Runtime,
	cfg logservice.HAKeeperClientConfig,
	fs fileservice.FileService,
) (logservice.DataSync, error)

NewDataSync creates a new syncer instance.

Types

type HAKeeperClientFactory

type HAKeeperClientFactory func(
	ctx context.Context,
	sid string,
	cfg logservice.HAKeeperClientConfig,
) logservice.ClusterHAKeeperClient

type LogClient

type LogClient interface {
	// contains filtered or unexported methods
}

LogClient is a interface defines the operation of log entries.

type Producer

type Producer interface {
	Worker
	Enqueue(context.Context, *wrappedData)
}

type TxnClient

type TxnClient interface {
	// contains filtered or unexported methods
}

type Worker

type Worker interface {
	Start(ctx context.Context)
	Close()
}