Documentation ¶
Index ¶
- func GetSource() api.Source
- type SimulatorSource
- func (s SimulatorSource) Close(ctx api.StreamContext) error
- func (s *SimulatorSource) Connect(ctx api.StreamContext) error
- func (s *SimulatorSource) Provision(ctx api.StreamContext, configs map[string]any) error
- func (s *SimulatorSource) Pull(ctx api.StreamContext, trigger time.Time, ingest api.TupleIngest, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type SimulatorSource ¶
type SimulatorSource struct {
// contains filtered or unexported fields
}
func (SimulatorSource) Close ¶
func (s SimulatorSource) Close(ctx api.StreamContext) error
func (*SimulatorSource) Connect ¶
func (s *SimulatorSource) Connect(ctx api.StreamContext) error
func (*SimulatorSource) Provision ¶
func (s *SimulatorSource) Provision(ctx api.StreamContext, configs map[string]any) error
func (*SimulatorSource) Pull ¶
func (s *SimulatorSource) Pull(ctx api.StreamContext, trigger time.Time, ingest api.TupleIngest, ingestError api.ErrorIngest)
Click to show internal directories.
Click to hide internal directories.