horizontal

Documentation

Index

• type Flow
  • func NewEtcdFlowProcessor(ctx context.Context, cli *clientv3.Client, path string, consumerName string, ...) (Flow, error)
• type FlowProcessorProvider
  • func (f *FlowProcessorProvider) RegisterHandler(h stream.FlowEventHandler)
  • func (f *FlowProcessorProvider) Run(ctx context.Context, block bool) error

Types

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

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 (*FlowProcessorProvider) RegisterHandler

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

only can be run in the beginning not dynamic

func (*FlowProcessorProvider) Run

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