worker

Documentation

Index

• type Worker
  • func New(store store.Store) *Worker
  • func (w *Worker) ModifiedResources() map[string]time.Time
  • func (w *Worker) Process(resource govdata.Resource) error

Types

type Worker

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

Worker is responsible for processing incoming data.

func New

func New(store store.Store) *Worker

New returns new instance of worker.

func (*Worker) ModifiedResources

func (w *Worker) ModifiedResources() map[string]time.Time

func (*Worker) Process

func (w *Worker) Process(resource govdata.Resource) error

Process dispatches event as to a handler.