playground

package
v1.16.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 13, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPlaygroundSourcePlugin

func NewPlaygroundSourcePlugin(config Config, s []schema.StreamSchema) sources.DataSource

Types

type Config

type Config struct {
	DataType               string `json:"data_type" yaml:"data_type"`
	PublishIntervalSeconds int64  `json:"publish_interval" yaml:"publish_interval"`
	// Historical batch will produce 1k messages before starting the interval
	HistoricalBatch bool `json:"historical_batch" yaml:"historical_batch"`
}

type SourcePlugin

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

func (*SourcePlugin) Connect

func (s *SourcePlugin) Connect(ctx context.Context) error

func (*SourcePlugin) Events

func (s *SourcePlugin) Events() chan sources.MessageEvent

func (*SourcePlugin) Start

func (s *SourcePlugin) Start()

func (*SourcePlugin) Stop

func (s *SourcePlugin) Stop()

Jump to

Keyboard shortcuts

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