Golang core.Pipeline类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中github.com/driskell/log-courier/src/lc-lib/core.Pipeline类的典型用法代码示例。如果您正苦于以下问题：Golang Pipeline类的具体用法？Golang Pipeline怎么用？Golang Pipeline使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了Pipeline类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: newStdinRegistrar

func newStdinRegistrar(pipeline *core.Pipeline) *StdinRegistrar {
	ret := &StdinRegistrar{
		registrar_chan: make(chan []registrar.EventProcessor, 16),
		signal_chan:    make(chan int64, 1),
	}

	ret.group.Add(1)

	pipeline.Register(ret)

	return ret
}

开发者ID:atmosx，项目名称:log-courier，代码行数:12，代码来源:stdin_registrar.go

示例2: NewSpooler

func NewSpooler(pipeline *core.Pipeline, config *core.GeneralConfig, publisher_imp *publisher.Publisher) *Spooler {
	ret := &Spooler{
		config: config,
		spool:  make([]*core.EventDescriptor, 0, config.SpoolSize),
		input:  make(chan *core.EventDescriptor, 16), // TODO: Make configurable?
		output: publisher_imp.Connect(),
	}

	pipeline.Register(ret)

	return ret
}

开发者ID:atmosx，项目名称:log-courier，代码行数:12，代码来源:spooler.go

示例3: NewRegistrar

func NewRegistrar(pipeline *core.Pipeline, persistdir string) *Registrar {
	ret := &Registrar{
		registrar_chan: make(chan []EventProcessor, 16), // TODO: Make configurable?
		persistdir:     persistdir,
		statefile:      ".log-courier",
		state:          make(map[core.Stream]*FileState),
	}

	pipeline.Register(ret)

	return ret
}

开发者ID:atmosx，项目名称:log-courier，代码行数:12，代码来源:registrar.go

示例4: NewPublisher

func NewPublisher(pipeline *core.Pipeline, config *core.NetworkConfig, registrar registrar.Registrator) (*Publisher, error) {
	ret := &Publisher{
		config: config,
		input:  make(chan []*core.EventDescriptor, 1),
	}

	if registrar == nil {
		ret.registrar_spool = newNullEventSpool()
	} else {
		ret.registrar_spool = registrar.Connect()
	}

	if err := ret.init(); err != nil {
		return nil, err
	}

	pipeline.Register(ret)

	return ret, nil
}

开发者ID:atmosx，项目名称:log-courier，代码行数:20，代码来源:publisher.go

示例5: NewProspector

func NewProspector(pipeline *core.Pipeline, config *core.Config, from_beginning bool, registrar_imp registrar.Registrator, spooler_imp *spooler.Spooler) (*Prospector, error) {
	ret := &Prospector{
		config:          config,
		prospectorindex: make(map[string]*prospectorInfo),
		prospectors:     make(map[*prospectorInfo]*prospectorInfo),
		from_beginning:  from_beginning,
		registrar:       registrar_imp,
		registrar_spool: registrar_imp.Connect(),
		snapshot_chan:   make(chan interface{}),
		snapshot_sink:   make(chan []*core.Snapshot),
		output:          spooler_imp.Connect(),
	}

	if err := ret.init(); err != nil {
		return nil, err
	}

	pipeline.Register(ret)

	return ret, nil
}

开发者ID:atmosx，项目名称:log-courier，代码行数:21，代码来源:prospector.go

示例6: NewListener

func NewListener(pipeline *core.Pipeline, config *core.GeneralConfig) (*Listener, error) {
	var err error

	ret := &Listener{
		config:          config,
		command_chan:    make(chan string),
		response_chan:   make(chan *Response),
		client_shutdown: make(chan interface{}),
		// TODO: Make this limit configurable
		client_started: make(chan interface{}, 50),
		client_ended:   make(chan interface{}, 50),
	}

	if ret.listener, err = ret.listen(config); err != nil {
		return nil, err
	}

	pipeline.Register(ret)

	return ret, nil
}

开发者ID:atmosx，项目名称:log-courier，代码行数:21，代码来源:listener.go

注：本文中的github.com/driskell/log-courier/src/lc-lib/core.Pipeline类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。