worker

package

v0.0.0-...-b9e0ff1 Latest Latest Go to latest Published: Jun 6, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

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/dubin555/kafkascale

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Consumer
type KafkaScaleConsumer
- func NewKafkaScaleConsumer(taskName string, name string, brokers []string, topic []string, ...) *KafkaScaleConsumer
- func (c KafkaScaleConsumer) Consume()
type KafkaScaleProducer
- func NewKafkaScaleProducer(taskName string, name string, brokers []string, topic string, ...) *KafkaScaleProducer
- func (p KafkaScaleProducer) Produce()
type Producer
type Worker
- func NewWorker(name string, inputBrokers []string, inputTopics []string, ...) *Worker

Constants ¶

This section is empty.

Variables ¶

View Source

var AllTasks map[string]Worker

Functions ¶

This section is empty.

Types ¶

type Consumer ¶

type Consumer interface {
	Consume()
}

type KafkaScaleConsumer ¶

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

func NewKafkaScaleConsumer ¶

func NewKafkaScaleConsumer(
	taskName string,
	name string,
	brokers []string,
	topic []string,
	res chan<- model.KafkaLog,
	ctx context.Context,
	numConsumeChan chan<- int64,
	factor int) *KafkaScaleConsumer

func (KafkaScaleConsumer) Consume ¶

func (c KafkaScaleConsumer) Consume()

type KafkaScaleProducer ¶

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

func NewKafkaScaleProducer ¶

func NewKafkaScaleProducer(
	taskName string,
	name string,
	brokers []string,
	topic string,
	res <-chan model.KafkaLog,
	ctx context.Context,
	factor int,
	numProduceSucceedChan chan<- int64,
	numProduceFailedChan chan<- int64) *KafkaScaleProducer

func (KafkaScaleProducer) Produce ¶

func (p KafkaScaleProducer) Produce()

type Producer ¶

type Producer interface {
	Produce()
}

type Worker ¶

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

func NewWorker ¶

func NewWorker(
	name string,
	inputBrokers []string,
	inputTopics []string,
	outputBrokers []string,
	outputTopic string,
	factor int,
	duration time.Duration,
	ms *metric.MetricSystem,
	workerAddress string) *Worker

func (Worker) Fire ¶

func (w Worker) Fire()

func (Worker) GetTaskName ¶

func (w Worker) GetTaskName() string

func (Worker) StopAndClean ¶

func (w Worker) StopAndClean()

Source Files ¶

View all Source files

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