stdin

package

v3.95.9 Latest Latest Go to latest Published: Jul 9, 2026 License: AGPL-3.0 Imports: 8 Imported by: 0

Details

View Source

const SourceType = sourcespb.SourceType_SOURCE_TYPE_STDIN

This section is empty.

This section is empty.

type Source struct {
	sources.Progress
	sources.CommonSourceUnitUnmarshaller
	// contains filtered or unexported fields
}

func (s *Source) ChunkUnit(ctx context.Context, unit sources.SourceUnit, reporter sources.ChunkReporter) error

func (s *Source) Chunks(ctx context.Context, chunksChan chan *sources.Chunk, _ ...sources.ChunkingTarget) error

func (s *Source) Enumerate(ctx context.Context, reporter sources.UnitReporter) error

func (s *Source) Init(aCtx context.Context, name string, jobId sources.JobID, sourceId sources.SourceID, verify bool, _ *anypb.Any, _ int) error

func (s *Source) JobID() sources.JobID

func (s *Source) SourceID() sources.SourceID

func (s *Source) Type() sourcespb.SourceType