loader

Documentation

Index

• Variables
• type Cache
  • func (ca *Cache) WithCacheLoadFunc(fn CacheLoadFunc) *Cache
• type CacheLoadFunc
• type CacheOption
• type Data
  • func LoadFile(path string, lastModifyTime int64, decoder DecodeFunc) (int64, Data, error)
• type DecodeFunc
• type Filer
• type Http
• type LoadFunc
• type Loader
  • func CreateLoader() Loader
  • func New() *Loader
  • func NewCache(key string, dao *dao.Dao, data Data) *Loader
  • func NewFiler(path string, format string, data Data) *Loader
  • func NewHttp(url string, data Data, headFunc commonhttp.HeaderFunc) *Loader
  • func (load *Loader) Get() Data
  • func (load *Loader) JSON() (string, error)
  • func (load *Loader) Read() (error, bool)
  • func (load *Loader) Reset()
  • func (load *Loader) Stop()
  • func (load *Loader) Update(async bool)
  • func (load *Loader) Watch()
  • func (load *Loader) WithCmd(cmd string) *Loader
  • func (load *Loader) WithFormat(format string) *Loader
  • func (load *Loader) WithLoadFunc(l LoadFunc) *Loader
  • func (load *Loader) WithPublisher(p bus.Publisher) *Loader
  • func (load *Loader) WithSecond(second time.Duration) *Loader
  • func (load *Loader) WithTopic(topic string) *Loader
  • func (load *Loader) WithUnmarshal(l coder.Unmarshal) *Loader

Variables

var ErrNoModified = errors.New("file not modified")

Types

type Cache

type Cache struct {
	Loader
	// contains filtered or unexported fields
}

func (*Cache) WithCacheLoadFunc

func (ca *Cache) WithCacheLoadFunc(fn CacheLoadFunc) *Cache

type CacheLoadFunc

type CacheLoadFunc func(dao *dao.Dao, opt *CacheOption) error

type CacheOption

type CacheOption struct {
	Key  string
	Data Data
}

type Data

type Data interface{}

func LoadFile

func LoadFile(path string, lastModifyTime int64, decoder DecodeFunc) (int64, Data, error)

type DecodeFunc

type DecodeFunc func(v []byte) (Data, error)

type Filer

type Filer struct {
	Loader
	// contains filtered or unexported fields
}

type Http

type Http struct {
	Loader
	// contains filtered or unexported fields
}

type LoadFunc

type LoadFunc func() (Data, error)

type Loader

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

func CreateLoader

func CreateLoader() Loader

func New

func New() *Loader

func NewCache

func NewCache(key string, dao *dao.Dao, data Data) *Loader

func NewFiler

func NewFiler(path string, format string, data Data) *Loader

func NewHttp

func NewHttp(url string, data Data, headFunc commonhttp.HeaderFunc) *Loader

func (*Loader) Get

func (load *Loader) Get() Data

func (*Loader) JSON

func (load *Loader) JSON() (string, error)

func (*Loader) Read

func (load *Loader) Read() (error, bool)

func (*Loader) Reset

func (load *Loader) Reset()

func (*Loader) Stop

func (load *Loader) Stop()

func (*Loader) Update

func (load *Loader) Update(async bool)

func (*Loader) Watch

func (load *Loader) Watch()

func (*Loader) WithCmd

func (load *Loader) WithCmd(cmd string) *Loader

func (*Loader) WithFormat

func (load *Loader) WithFormat(format string) *Loader

func (*Loader) WithLoadFunc

func (load *Loader) WithLoadFunc(l LoadFunc) *Loader

func (*Loader) WithPublisher

func (load *Loader) WithPublisher(p bus.Publisher) *Loader

func (*Loader) WithSecond

func (load *Loader) WithSecond(second time.Duration) *Loader

func (*Loader) WithTopic

func (load *Loader) WithTopic(topic string) *Loader

func (*Loader) WithUnmarshal

func (load *Loader) WithUnmarshal(l coder.Unmarshal) *Loader