horizontal

type Flow ¶

type Flow interface {
	RegisterHandler(h stream.FlowEventHandler)
	Run(ctx context.Context, block bool) error
}

Flow is same as Flow but makes sure the handlers get only partitioned data it's not able to distinguish between the the list and watch because of the nature of other members joining and leaving might need to process the data of an old member who just left

func NewEtcdFlowProcessor(ctx context.Context, cli *clientv3.Client, path string, consumerName string, fromEnd bool, logger *logrus.Entry, opts ...lb.Option) (Flow, error)

type FlowProcessorProvider ¶

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

func (f *FlowProcessorProvider) RegisterHandler(h stream.FlowEventHandler)

func (f *FlowProcessorProvider) Run(ctx context.Context, block bool) error