watch

Aug 7, 2020

Changes in this version

type Plan

+ Logger hclog.Logger

Feb 11, 2020

Changes in this version

type Plan

+ func (p *Plan) RunWithClientAndHclog(client *consulapi.Client, logger hclog.Logger) error

May 8, 2019

Changes in this version

+ const DefaultTimeout

+ type BlockingParamVal interface

+ Equal func(other BlockingParamVal) bool

+ Next func(previous BlockingParamVal) BlockingParamVal

+ type HandlerFunc func(uint64, interface{})

+ type HttpHandlerConfig struct

+ Header map[string][]string

+ Method string

+ Path string

+ TLSSkipVerify bool

+ Timeout time.Duration

+ TimeoutRaw string

+ type HybridHandlerFunc func(BlockingParamVal, interface{})

+ type Plan struct

+ Datacenter string

+ Exempt map[string]interface{}

+ Handler HandlerFunc

+ HandlerType string

+ HybridHandler HybridHandlerFunc

+ LogOutput io.Writer

+ Token string

+ Type string

+ Watcher WatcherFunc

+ func Parse(params map[string]interface{}) (*Plan, error)

+ func ParseExempt(params map[string]interface{}, exempt []string) (*Plan, error)

+ func (p *Plan) IsStopped() bool

+ func (p *Plan) Run(address string) error

+ func (p *Plan) RunWithClientAndLogger(client *consulapi.Client, logger *log.Logger) error

+ func (p *Plan) RunWithConfig(address string, conf *consulapi.Config) error

+ func (p *Plan) Stop()

+ type WaitHashVal string

+ func (h WaitHashVal) Equal(other BlockingParamVal) bool

+ func (h WaitHashVal) Next(previous BlockingParamVal) BlockingParamVal

+ type WaitIndexVal uint64

+ func (idx WaitIndexVal) Equal(other BlockingParamVal) bool

+ func (idx WaitIndexVal) Next(previous BlockingParamVal) BlockingParamVal

+ type WatcherFunc func(*Plan) (BlockingParamVal, interface{}, error)