batchpipe

package module

v0.0.0-...-7f03e8a Latest Latest Go to latest Published: Dec 3, 2021 License: MIT Imports: 4 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Caviarion/BatchPipe

Links

Open Source Insights

Documentation ¶

Index ¶

type BatchDelayNode
- func NewBatchDelayNode(name string, batchSize int, batchWait time.Duration, ...) *BatchDelayNode
type BatchPipeline
- func NewBatchPipeline() *BatchPipeline
type CompNode
type Pipeline
type Switch
- func NewSwitch() *Switch
type TimerTask
- func NewTimerTask() *TimerTask

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BatchDelayNode ¶

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

func NewBatchDelayNode ¶

func NewBatchDelayNode(name string, batchSize int, batchWait time.Duration, calc func(int) time.Duration) *BatchDelayNode

func (*BatchDelayNode) Execute ¶

func (b *BatchDelayNode) Execute()

func (*BatchDelayNode) GetName ¶

func (b *BatchDelayNode) GetName() string

func (*BatchDelayNode) GetOutput ¶

func (b *BatchDelayNode) GetOutput() chan interface{}

func (*BatchDelayNode) PutInput ¶

func (b *BatchDelayNode) PutInput(input interface{}) error

func (*BatchDelayNode) SetDelayFunc ¶

func (b *BatchDelayNode) SetDelayFunc(f func(int) time.Duration) error

func (*BatchDelayNode) SetInput ¶

func (b *BatchDelayNode) SetInput(input chan interface{})

func (*BatchDelayNode) Shutdown ¶

func (b *BatchDelayNode) Shutdown()

Nodes after shutdown is not thread safe

type BatchPipeline ¶

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

func NewBatchPipeline ¶

func NewBatchPipeline() *BatchPipeline

func (*BatchPipeline) AddNode ¶

func (p *BatchPipeline) AddNode(index int, node CompNode) error

func (*BatchPipeline) DeleteNode ¶

func (p *BatchPipeline) DeleteNode(index int) error

func (*BatchPipeline) GetNode ¶

func (p *BatchPipeline) GetNode(index int) CompNode

func (*BatchPipeline) GetNodes ¶

func (p *BatchPipeline) GetNodes() []CompNode

func (*BatchPipeline) GetOutput ¶

func (p *BatchPipeline) GetOutput() chan interface{}

func (*BatchPipeline) InputFrom ¶

func (p *BatchPipeline) InputFrom(index int, value interface{}) error

func (*BatchPipeline) ShutdownPipeline ¶

func (p *BatchPipeline) ShutdownPipeline()

func (*BatchPipeline) StartPipeline ¶

func (p *BatchPipeline) StartPipeline()

type CompNode ¶

type CompNode interface {
	GetName() string
	Execute()
	SetInput(chan interface{})
	PutInput(interface{}) error
	GetOutput() chan interface{}
	Shutdown()
}

type Pipeline ¶

type Pipeline interface {
	StartPipeline()
	ShutdownPipeline()
	InputFrom(int, interface{}) error
	GetOutput() chan interface{}
	GetNodes() []CompNode
	GetNode(int) CompNode
	AddNode(int, CompNode) error
	DeleteNode(int)
}

type Switch ¶

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

func NewSwitch ¶

func NewSwitch() *Switch

func (*Switch) IsOn ¶

func (s *Switch) IsOn() bool

func (*Switch) Off ¶

func (s *Switch) Off()

func (*Switch) On ¶

func (s *Switch) On()

func (*Switch) WaitOn ¶

func (s *Switch) WaitOn() chan struct{}

type TimerTask ¶

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

func NewTimerTask ¶

func NewTimerTask() *TimerTask

func (*TimerTask) CostTime ¶

func (t *TimerTask) CostTime() (time.Duration, error)

func (*TimerTask) Finish ¶

func (t *TimerTask) Finish()

func (*TimerTask) Start ¶

func (t *TimerTask) Start()

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cmd

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL