core

Documentation

Index

• func UnmarshalJsonArray(data string) ([]interface{}, error)
• func UnmarshalJsonObject(data string) (map[string]interface{}, error)
• type IntervalProcessor
  • func NewIntervalProcessor(interval time.Duration, processor Processor, stopChan <-chan struct{}, ...) *IntervalProcessor
  • func (p *IntervalProcessor) Run() error
• type OnDemandProcessor
  • func NewOnDemandProcessor(template *Template, client store.Store) *OnDemandProcessor
  • func (p *OnDemandProcessor) Run() error
• type Processor
• type Template
  • func NewTemplate(config *config.TemplateConfig, doNoOp, keepStageFile, useMutex bool) *Template
  • func (t *Template) Render(kvs map[string]string) error
• type WatchProcessor
  • func NewWatchProcessor(template *Template, client store.Store, stopChan <-chan struct{}, ...) *WatchProcessor
  • func (p *WatchProcessor) Run() error

Functions

func UnmarshalJsonArray

func UnmarshalJsonArray(data string) ([]interface{}, error)

func UnmarshalJsonObject

func UnmarshalJsonObject(data string) (map[string]interface{}, error)

Types

type IntervalProcessor

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

func NewIntervalProcessor

func NewIntervalProcessor(interval time.Duration, processor Processor,
	stopChan <-chan struct{}, doneChan chan bool, errChan chan error) *IntervalProcessor

func (*IntervalProcessor) Run

func (p *IntervalProcessor) Run() error

type OnDemandProcessor

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

func NewOnDemandProcessor

func NewOnDemandProcessor(template *Template, client store.Store) *OnDemandProcessor

func (*OnDemandProcessor) Run

func (p *OnDemandProcessor) Run() error

type Processor

type Processor interface {
	Run() error
}

type Template

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

Template is the representation of a parsed template resource.

func NewTemplate

func NewTemplate(config *config.TemplateConfig, doNoOp, keepStageFile, useMutex bool) *Template

func (*Template) Render

func (t *Template) Render(kvs map[string]string) error

Render is a convenience function that wraps calls to the three main tasks required to keep local configuration files in sync. First we stage a candidate configuration file, and finally sync things up. It returns an error if any fails.

type WatchProcessor

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

func NewWatchProcessor

func NewWatchProcessor(template *Template, client store.Store,
	stopChan <-chan struct{}, doneChan chan bool, errChan chan error) *WatchProcessor

func (*WatchProcessor) Run

func (p *WatchProcessor) Run() error