file

Documentation

Index

• type Sync
  • func (fs *Sync) Init(ctx context.Context) error
  • func (fs *Sync) IsReady() bool
  • func (fs *Sync) ReSync(ctx context.Context, dataSync chan<- sync.DataSync) error
  • func (fs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error

Types

type Sync

type Sync struct {
	URI    string
	Logger *logger.Logger

	Mux *msync.RWMutex
	// contains filtered or unexported fields
}

func (*Sync) Init

func (fs *Sync) Init(ctx context.Context) error

func (*Sync) IsReady

func (fs *Sync) IsReady() bool

func (*Sync) ReSync

func (fs *Sync) ReSync(ctx context.Context, dataSync chan<- sync.DataSync) error

func (*Sync) Sync

func (fs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error