Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var FilesizeLimitBytes int64 = 50 * 1024 * 1024 // 50MB
Functions ¶
This section is empty.
Types ¶
type Source ¶
type Source struct { sources.Progress sources.CommonSourceUnitUnmarshaller // contains filtered or unexported fields }
func (*Source) Init ¶
func (s *Source) Init(_ context.Context, name string, jobId, sourceId int64, verify bool, connection *anypb.Any, concurrency int) error
Init initializes the source.
func (*Source) Type ¶
func (s *Source) Type() sourcespb.SourceType
Type returns the type of source. It is used for matching source types in configuration and job input.
Click to show internal directories.
Click to hide internal directories.