generator

Aug 7, 2024

Changes in this version

+ const ConfigBurstGenerateTime

+ const ConfigBurstSleepTime

+ const ConfigCollectionsFormatOptions

+ const ConfigCollectionsFormatOptionsPath

+ const ConfigCollectionsFormatType

+ const ConfigCollectionsOperations

+ const ConfigFormatOptions

+ const ConfigFormatOptionsPath

+ const ConfigFormatType

+ const ConfigOperations

+ const ConfigRate

+ const ConfigReadTime

+ const ConfigRecordCount

Apr 24, 2024

Changes in this version

+ const FormatTypeFile

+ const FormatTypeRaw

+ const FormatTypeStructured

+ type BurstConfig struct

+ GenerateTime time.Duration

+ SleepTime time.Duration

+ type CollectionConfig struct

+ Format FormatConfig

+ Operations []string

+ func (c CollectionConfig) SdkOperations() []sdk.Operation

+ func (c CollectionConfig) Validate() error

type Config

+ Burst BurstConfig

+ Collections map[string]CollectionConfig

+ Rate float64

+ func (Config) Parameters() map[string]sdk.Parameter

+ func (c Config) GetCollectionConfigs() map[string]CollectionConfig

+ func (c Config) RateLimit() rate.Limit

+ func (c Config) Validate() error

+ type FormatConfig struct

+ FileOptionsPath string

+ Options map[string]string

+ Type string

+ func (c FormatConfig) Validate() error

Sep 27, 2022

Changes in this version

+ var Connector = sdk.Connector

type Source

+ func (s *Source) Parameters() map[string]sdk.Parameter

Jul 21, 2022

Changes in this version

+ const FormatFile

+ const FormatOptions

+ const FormatType

+ const GenerateTime

+ const SleepTime

type Config

+ GenerateTime time.Duration

+ RecordConfig RecordConfig

+ SleepTime time.Duration

+ type RecordConfig struct

+ FormatOptions interface{}

+ FormatType string

+ func ParseRecordConfig(formatType, formatOptions string) (RecordConfig, error)

Apr 5, 2022

Changes in this version

+ const Fields

+ const Format

+ const FormatRaw

+ const FormatStructured

+ const ReadTime

+ const RecordCount

+ func NewSource() sdk.Source

+ func Specification() sdk.Specification

+ type Config struct

+ Fields map[string]string

+ Format string

+ ReadTime time.Duration

+ RecordCount int64

+ func Parse(config map[string]string) (Config, error)

+ type Source struct

+ Config Config

+ func (s *Source) Ack(ctx context.Context, position sdk.Position) error

+ func (s *Source) Configure(ctx context.Context, config map[string]string) error

+ func (s *Source) Open(ctx context.Context, position sdk.Position) error

+ func (s *Source) Read(ctx context.Context) (sdk.Record, error)

+ func (s *Source) Teardown(ctx context.Context) error