sync

package

v1.0.4 Latest Latest Go to latest Published: Nov 8, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

func Mount(ctx context.Context, cfg *config.Setting) (*mount.Mounter, error)

func Watch(cfg *config.Setting, handlers []*Handler) (*watcher.Watcher, error)

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

func NewHandler(cfg *config.Setting, statusCh chan<- SyncEvent) (*Handler, error)

func (h *Handler) Close()

func (h *Handler) ConfigKey() string

func (h *Handler) FS() *oss.FS

func (h *Handler) HasChange(cfg *config.Setting) bool

func (h *Handler) Key() string

func (h *Handler) OpenMount() error

func (h *Handler) Receive(ev *watcher.Event)

type SyncEvent struct {
	Handler    *Handler
	SettingKey string
	Status     SyncStatus
}

type SyncStatus int32

const (
	SyncComplete SyncStatus = iota
	SyncStart
)

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

func NewSyncer() *Syncer

func (s *Syncer) Close()

func (s *Syncer) Events() <-chan SyncEvent

func (s *Syncer) FSByConfig(cfg *config.Setting) (*oss.FS, error)

func (s *Syncer) HandlerByConfig(cfg *config.Setting) (*Handler, error)

func (s *Syncer) Reload(cfg *config.Config)

func (s *Syncer) Start(ctx context.Context, cfg *config.Config) error

func (s *Syncer) Sync(cfg *config.Setting)

func (s *Syncer) SyncAll()