simulator

Documentation

Index

• type Source
  • func (m *Source) Close(_ api.StreamContext) error
  • func (m *Source) Configure(_ string, props map[string]interface{}) error
  • func (m *Source) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, errCh chan<- error)

Types

type Source

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

func (*Source) Close

func (m *Source) Close(_ api.StreamContext) error

func (*Source) Configure

func (m *Source) Configure(_ string, props map[string]interface{}) error

func (*Source) Open

func (m *Source) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, errCh chan<- error)