resource

Documentation

Index

• Constants
• type Assets
  • func NewAssets(assets []storage.Object) Assets
  • func (a Assets) Added(assets Assets, fn func(object storage.Object))
  • func (a Assets) Deleted(assets Assets, fn func(object storage.Object))
  • func (a Assets) Modified(assets Assets, fn func(object storage.Object))
• type Operation
• type Tracker
  • func New(baseURL string, checkFrequency time.Duration) *Tracker
  • func (m *Tracker) Notify(ctx context.Context, fs afs.Service, ...) error

Constants

const (
	OperationUndefined = -1
	OperationAdded     = Operation(iota)
	OperationModified
	OperationDeleted
)

Types

type Assets

type Assets map[string]storage.Object

func NewAssets

func NewAssets(assets []storage.Object) Assets

func (Assets) Added

func (a Assets) Added(assets Assets, fn func(object storage.Object))

func (Assets) Deleted

func (a Assets) Deleted(assets Assets, fn func(object storage.Object))

func (Assets) Modified

func (a Assets) Modified(assets Assets, fn func(object storage.Object))

type Operation

type Operation int

type Tracker

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

func New

func New(baseURL string, checkFrequency time.Duration) *Tracker

func (*Tracker) Notify

func (m *Tracker) Notify(ctx context.Context, fs afs.Service, callback func(URL string, operation Operation)) error

Notify returns true if resource under base URL have changed