watchimpl

Documentation

Index

• type Config
  • func (cfg *Config) SetDefault()
• type Watcher
  • func NewWatcher(cfg *Config, as aiccfinetune.AICCFinetune) (*Watcher, error)
  • func (w *Watcher) ApplyWatch(f func(*watch.FinetuneInfo) error) (err error)
  • func (w *Watcher) Exit()
  • func (w *Watcher) Run()

Types

type Config

type Config struct {
	// Interval specifies the interval of second between two loops
	// that check all finetunes in a loop.
	Interval int `json:"interval"`

	// Timeout specifies the time that a finetune can live
	// The unit is second.
	Timeout int `json:"timeout"`

	// MaxWatchNum specifies the max num of finetune
	// which the aicc finetune center can support
	MaxWatchNum int `json:"max_watch_num"`

	Endpoint string `json:"endpoint" required:"true"`
}

func (*Config) SetDefault

func (cfg *Config) SetDefault()

type Watcher

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

Watcher

func NewWatcher

func NewWatcher(
	cfg *Config, as aiccfinetune.AICCFinetune,
) (*Watcher, error)

func (*Watcher) ApplyWatch

func (w *Watcher) ApplyWatch(f func(*watch.FinetuneInfo) error) (err error)

func (*Watcher) Exit

func (w *Watcher) Exit()

func (*Watcher) Run

func (w *Watcher) Run()