Versions in this module Expand all Collapse all v0 v0.5.22 Jul 17, 2023 v0.5.21 Mar 24, 2023 v0.5.20 Sep 30, 2022 v0.5.19 Jul 1, 2022 v0.5.18 May 31, 2022 Changes in this version + type ImpInputConnectionNoCache struct + func (i *ImpInputConnectionNoCache) Metadata() IncomingRecordInfo + func (i *ImpInputConnectionNoCache) Name() string + func (i *ImpInputConnectionNoCache) Progress() float64 + func (i *ImpInputConnectionNoCache) Read() RecordPacket + func (i *ImpInputConnectionNoCache) Status() Status type OptionSetter + func NoCache(value bool) OptionSetter type RecordCollector + PacketsReceived int type RecordPacket + func NewSingleRecord(record Record) RecordPacket + type ToolOptionSetter func(toolOptions) toolOptions + func ToolNoCache() ToolOptionSetter v0.5.17 Apr 12, 2022 v0.5.16 Apr 12, 2022 Changes in this version + const Closed + const Created + const Initialized + const ReceivingRecords + func RegisterTool(plugin Plugin, toolId int, xmlProperties unsafe.Pointer, ...) int + type AddFieldOptionSetter func(AddFieldOptions) AddFieldOptions + func InsertAt(position int) AddFieldOptionSetter + type AddFieldOptions struct + type BoolGetter func(Record) (bool, bool) + type BytesGetter func(Record) []byte + type EditingRecordInfo struct + func (i *EditingRecordInfo) AddBlobField(name string, source string, size int, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddBoolField(name string, source string, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddByteField(name string, source string, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddDateField(name string, source string, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddDateTimeField(name string, source string, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddDoubleField(name string, source string, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddFixedDecimalField(name string, source string, size int, scale int, ...) string + func (i *EditingRecordInfo) AddFloatField(name string, source string, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddInt16Field(name string, source string, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddInt32Field(name string, source string, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddInt64Field(name string, source string, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddSpatialObjField(name string, source string, size int, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddStringField(name string, source string, size int, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddV_StringField(name string, source string, size int, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddV_WStringField(name string, source string, size int, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) AddWStringField(name string, source string, size int, options ...AddFieldOptionSetter) string + func (i *EditingRecordInfo) Fields() []IncomingField + func (i *EditingRecordInfo) GenerateOutgoingRecordInfo() *OutgoingRecordInfo + func (i *EditingRecordInfo) MoveField(name string, newIndex int) error + func (i *EditingRecordInfo) NumFields() int + func (i *EditingRecordInfo) RemoveFields(fieldNames ...string) + type Environment interface + AlteryxInstallDir func() string + AlteryxLocale func() string + DesignerVersion func() string + ToolId func() int + UpdateMode func() string + UpdateOnly func() bool + UpdateToolConfig func(string) + WorkflowDir func() string + type FilePusher struct + func (f *FilePusher) Init(provider Provider) + func (f *FilePusher) OnComplete() + func (f *FilePusher) OnInputConnectionOpened(_ InputConnection) + func (f *FilePusher) OnRecordPacket(_ InputConnection) + type FileTestRunner struct + func RegisterToolTest(plugin Plugin, toolId int, xmlProperties string, optionSetters ...OptionSetter) *FileTestRunner + func (r *FileTestRunner) CaptureOutgoingAnchor(name string) *RecordCollector + func (r *FileTestRunner) ConnectInput(name string, dataFile string) + func (r *FileTestRunner) SimulateLifecycle() + type FloatGetter func(Record) (float64, bool) + type ImpInputConnection struct + func (i *ImpInputConnection) Metadata() IncomingRecordInfo + func (i *ImpInputConnection) Name() string + func (i *ImpInputConnection) Progress() float64 + func (i *ImpInputConnection) Read() RecordPacket + func (i *ImpInputConnection) Status() Status + type IncomingBlobField struct + GetValue BytesGetter + Name string + Size int + Source string + Type string + type IncomingBoolField struct + GetValue BoolGetter + Name string + Source string + Type string + type IncomingField struct + GetBytes BytesGetter + Name string + Scale int + Size int + Source string + Type string + type IncomingFloatField struct + GetValue FloatGetter + Name string + Source string + Type string + type IncomingIntField struct + GetValue IntGetter + Name string + Source string + Type string + type IncomingRecordInfo struct + func (i IncomingRecordInfo) Clone() *EditingRecordInfo + func (i IncomingRecordInfo) Fields() []b.FieldBase + func (i IncomingRecordInfo) GetBlobField(name string) (IncomingBlobField, error) + func (i IncomingRecordInfo) GetBoolField(name string) (IncomingBoolField, error) + func (i IncomingRecordInfo) GetFloatField(name string) (IncomingFloatField, error) + func (i IncomingRecordInfo) GetIntField(name string) (IncomingIntField, error) + func (i IncomingRecordInfo) GetStringField(name string) (IncomingStringField, error) + func (i IncomingRecordInfo) GetTimeField(name string) (IncomingTimeField, error) + func (i IncomingRecordInfo) NumFields() int + type IncomingStringField struct + GetValue StringGetter + Name string + Size int + Source string + Type string + type IncomingTimeField struct + GetValue TimeGetter + Name string + Source string + Type string + type InputConnection interface + Metadata func() IncomingRecordInfo + Name func() string + Progress func() float64 + Read func() RecordPacket + Status func() Status + type IntGetter func(Record) (int, bool) + type Io interface + CreateTempFile func(string) string + DecryptPassword func(string) string + Error func(string) + Info func(string) + NotifyFileInput func(string) + NotifyFileOutput func(string) + UpdateProgress func(float64) + Warn func(string) + type MessageStatus int + const BrowseEverywhereFileName + const Complete + const Error + const FieldConversionError + const FileInput + const FileOutput + const Info + const RecordCountString + const TransientFieldConversionError + const TransientInfo + const TransientWarning + const UpdateOutputMetaInfoXml + const Warning + type NewOutgoingField func() *outgoingField + func NewBlobField(name string, source string, size int) NewOutgoingField + func NewBoolField(name string, source string) NewOutgoingField + func NewByteField(name string, source string) NewOutgoingField + func NewDateField(name string, source string) NewOutgoingField + func NewDateTimeField(name string, source string) NewOutgoingField + func NewDoubleField(name string, source string) NewOutgoingField + func NewFixedDecimalField(name string, source string, size int, scale int) NewOutgoingField + func NewFloatField(name string, source string) NewOutgoingField + func NewInt16Field(name string, source string) NewOutgoingField + func NewInt32Field(name string, source string) NewOutgoingField + func NewInt64Field(name string, source string) NewOutgoingField + func NewSpatialObjField(name string, source string, size int) NewOutgoingField + func NewStringField(name string, source string, size int) NewOutgoingField + func NewV_StringField(name string, source string, size int) NewOutgoingField + func NewV_WStringField(name string, source string, size int) NewOutgoingField + func NewWStringField(name string, source string, size int) NewOutgoingField + type NullableField interface + GetNull func() bool + SetNull func() + type OptionSetter func(testOptions) testOptions + func AlteryxLocale(value string) OptionSetter + func UpdateMode(value string) OptionSetter + func UpdateOnly(value bool) OptionSetter + func WorkflowDir(value string) OptionSetter + type OutgoingBlobField interface + GetCurrentBlob func() ([]byte, bool) + SetBlob func([]byte) + type OutgoingBoolField interface + GetCurrentBool func() (bool, bool) + SetBool func(bool) + type OutgoingDateTimeField interface + GetCurrentDateTime func() (time.Time, bool) + SetDateTime func(time.Time) + type OutgoingFloatField interface + GetCurrentFloat func() (float64, bool) + SetFloat func(float64) + type OutgoingIntField interface + GetCurrentInt func() (int, bool) + SetInt func(int) + type OutgoingRecordInfo struct + BlobFields map[string]OutgoingBlobField + BoolFields map[string]OutgoingBoolField + DateTimeFields map[string]OutgoingDateTimeField + FloatFields map[string]OutgoingFloatField + IntFields map[string]OutgoingIntField + StringFields map[string]OutgoingStringField + func NewOutgoingRecordInfo(fields []NewOutgoingField) (*OutgoingRecordInfo, []string) + func (i *OutgoingRecordInfo) CopyFrom(record Record) + func (i *OutgoingRecordInfo) DataSize() uint32 + func (i *OutgoingRecordInfo) FixedSize() int + func (i *OutgoingRecordInfo) HasVarFields() bool + type OutgoingStringField interface + GetCurrentString func() (string, bool) + SetString func(string) + type OutputAnchor interface + Close func() + IsOpen func() bool + Metadata func() *OutgoingRecordInfo + Name func() string + NumConnections func() int + Open func(info *OutgoingRecordInfo) + UpdateProgress func(float64) + Write func() + type Plugin interface + Init func(Provider) + OnComplete func() + OnInputConnectionOpened func(InputConnection) + OnRecordPacket func(InputConnection) + type Provider interface + Environment func() Environment + GetOutputAnchor func(string) OutputAnchor + Io func() Io + ToolConfig func() string + type Record = unsafe.Pointer + type RecordCache unsafe.Pointer + type RecordCollector struct + Config IncomingRecordInfo + Data map[string][]interface{} + Name string + Progress float64 + func (r *RecordCollector) Init(_ Provider) + func (r *RecordCollector) OnComplete() + func (r *RecordCollector) OnInputConnectionOpened(connection InputConnection) + func (r *RecordCollector) OnRecordPacket(connection InputConnection) + type RecordPacket interface + Next func() bool + Record func() Record + func NewRecordPacket(cache RecordCache, size int, fixedLen int, hasVarData bool) RecordPacket + type Status byte + type StringGetter func(Record) (string, bool) + type TimeGetter func(Record) (time.Time, bool)