generator

Documentation

Overview

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

Index

• func NewMemGen(ctx context.Context, vertexInstance *dfv1.VertexInstance, opts ...Option) (sourcer.SourceReader, error)
• type Data
• type Option
  • func WithReadTimeout(timeout time.Duration) Option

Functions

func NewMemGen

func NewMemGen(ctx context.Context, vertexInstance *dfv1.VertexInstance, opts ...Option) (sourcer.SourceReader, error)

NewMemGen function creates an instance of generator source reader.

Types

type Data

type Data struct {
	Value uint64 `json:"value,omitempty"`
	// only to ensure a desired message size
	Padding []byte `json:"padding,omitempty"`
}

type Option

type Option func(*memGen) error

func WithReadTimeout

func WithReadTimeout(timeout time.Duration) Option

WithReadTimeout sets the read timeout for the reader.