generator

Documentation

Overview

Package generator contains an implementation of a in memory generator that generates payloads in json format.

Index

• func NewMemGen(vertexInstance *dfv1.VertexInstance, writers []isb.BufferWriter, ...) (*memgen, error)
• type Option
  • func WithLogger(l *zap.SugaredLogger) Option
  • func WithReadTimeOut(timeout time.Duration) Option

Functions

func NewMemGen

func NewMemGen(vertexInstance *dfv1.VertexInstance,
	writers []isb.BufferWriter,
	fetchWM fetch.Fetcher, publishWM map[string]publish.Publisher, publishWMStores store.WatermarkStorer,
	opts ...Option) (*memgen, error)

NewMemGen function creates an instance of generator. ctx - context passed by the cmd/start.go a new context with cancel

is created for use by this vertex.

name - name of this vertex writers - destinations to write to

Types

type Option

type Option func(*memgen) error

func WithLogger

func WithLogger(l *zap.SugaredLogger) Option

WithLogger is used to return logger information

func WithReadTimeOut

func WithReadTimeOut(timeout time.Duration) Option