Versions in this module Expand all Collapse all v1 v1.0.0 Dec 12, 2019 Changes in this version + var ErrFlowTerminated = errors.New("flow terminated") + type EtcdFlow struct + func (f *EtcdFlow) RegisterListHandler(path string, h FlowEventHandler) + func (f *EtcdFlow) RegisterWatchHandler(path string, h FlowEventHandler) + func (f *EtcdFlow) Run(ctx context.Context) + type Flow interface + RegisterListHandler func(path string, handler FlowEventHandler) + RegisterWatchHandler func(path string, handler FlowEventHandler) + Run func(ctx context.Context) + func NewEtcdFlow(cli *clientv3.Client, opts ...FlowOption) Flow + type FlowEvent struct + Kv *FlowKeyValue + PrevKv *FlowKeyValue + Type FlowEventType + func (e *FlowEvent) IsCreated() bool + func (e *FlowEvent) IsDeleted() bool + func (e *FlowEvent) IsUpdated() bool + type FlowEventHandler func(event *FlowEvent) error + type FlowEventType string + const FlowEventCreated + const FlowEventDeleted + const FlowEventUpdated + type FlowKeyValue struct + CreateRevision int64 + Key string + ModRevision int64 + Value string + Version int64 + type FlowOption func(config *flowConfig) + func WithPageSize(size int) FlowOption + func WithWatchBufferSize(size int) FlowOption