sync

Documentation

Index

• func Mount(ctx context.Context, cfg *config.Setting) (*mount.Mounter, error)
• func Watch(cfg *config.Setting, handlers []*Handler) (*watcher.Watcher, error)
• type Handler
  • 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) Mount() error
  • func (h *Handler) Receive(ev *watcher.Event)
  • func (h *Handler) Unmount()
• type SyncEvent
• type SyncStatus
• type Syncer
  • func NewSyncer() *Syncer
  • func (s *Syncer) Close()
  • func (s *Syncer) Events() <-chan SyncEvent
  • func (s *Syncer) Mount(cfg *config.Setting)
  • 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()

Functions

func Mount

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

func Watch

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

Types

type Handler

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

func NewHandler

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

func (*Handler) Close

func (h *Handler) Close()

func (*Handler) ConfigKey

func (h *Handler) ConfigKey() string

func (*Handler) FS

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

func (*Handler) HasChange

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

func (*Handler) Key

func (h *Handler) Key() string

func (*Handler) Mount

func (h *Handler) Mount() error

func (*Handler) Receive

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

func (*Handler) Unmount

func (h *Handler) Unmount()

type SyncEvent

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

type SyncStatus

type SyncStatus int32

const (
	SyncComplete SyncStatus = iota
	SyncStart
)

type Syncer

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

func NewSyncer

func NewSyncer() *Syncer

func (*Syncer) Close

func (s *Syncer) Close()

func (*Syncer) Events

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

func (*Syncer) Mount

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

func (*Syncer) Reload

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

func (*Syncer) Start

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

func (*Syncer) Sync

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

func (*Syncer) SyncAll

func (s *Syncer) SyncAll()