stream

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

type Flow interface {
	RegisterWatchHandler(path string, handler FlowEventHandler)
	RegisterListHandler(path string, handler FlowEventHandler)
	Run(ctx context.Context)
}

type FlowEvent struct {
	Type   FlowEventType
	Kv     *FlowKeyValue
	PrevKv *FlowKeyValue
}

type FlowEventHandler func(event *FlowEvent) error

type FlowEventType string

type FlowKeyValue struct {
	Key            string
	CreateRevision int64
	ModRevision    int64
	Version        int64
	Value          string
}

type FlowOption func(config *flowConfig)