blob

Documentation

Index

• type Cron
• type MockBlob
  • func NewMockBlob(scheme string, getSync func() *Sync) *MockBlob
  • func (mb *MockBlob) AddObject(object, content string)
  • func (mb *MockBlob) URLMux() *blob.URLMux
• type Sync
  • func (hs *Sync) Init(_ context.Context) error
  • func (hs *Sync) IsReady() bool
  • func (hs *Sync) ReSync(ctx context.Context, dataSync chan<- sync.DataSync) error
  • func (hs *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error

Types

type Cron

type Cron interface {
	AddFunc(spec string, cmd func()) error
	Start()
	Stop()
}

Cron defines the behaviour required of a cron

type MockBlob

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

func NewMockBlob

func NewMockBlob(scheme string, getSync func() *Sync) *MockBlob

func (*MockBlob) AddObject

func (mb *MockBlob) AddObject(object, content string)

func (*MockBlob) URLMux

func (mb *MockBlob) URLMux() *blob.URLMux

type Sync

type Sync struct {
	Bucket     string
	Object     string
	BlobURLMux *blob.URLMux
	Cron       Cron
	Logger     *logger.Logger
	Interval   uint32
	// contains filtered or unexported fields
}

func (*Sync) Init

func (hs *Sync) Init(_ context.Context) error

func (*Sync) IsReady

func (hs *Sync) IsReady() bool

func (*Sync) ReSync

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

func (*Sync) Sync

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