sdk

type AddFieldOptionSetter func(AddFieldOptions) AddFieldOptions

type AddFieldOptions struct {
	// contains filtered or unexported fields
}

type BoolGetter func(Record) (bool, bool)

type BytesGetter func(Record) []byte

type EditingRecordInfo struct {
	// contains filtered or unexported fields
}

type Environment interface {
	UpdateOnly() bool
	UpdateMode() string
	DesignerVersion() string
	WorkflowDir() string
	AlteryxInstallDir() string
	AlteryxLocale() string
	ToolId() int
	UpdateToolConfig(string)
}

type FilePusher struct {
	// contains filtered or unexported fields
}

type FileTestRunner struct {
	// contains filtered or unexported fields
}

type FloatGetter func(Record) (float64, bool)

type ImpInputConnection struct {
	// contains filtered or unexported fields
}

type ImpInputConnectionNoCache struct {
	// contains filtered or unexported fields
}

type IncomingBlobField struct {
	Name     string
	Type     string
	Source   string
	Size     int
	GetValue BytesGetter
}

type IncomingBoolField struct {
	Name     string
	Type     string
	Source   string
	GetValue BoolGetter
}

type IncomingField struct {
	Name     string `xml:"name,attr"`
	Type     string `xml:"type,attr"`
	Source   string `xml:"source,attr"`
	Size     int    `xml:"size,attr"`
	Scale    int    `xml:"scale,attr"`
	GetBytes BytesGetter
}

type IncomingFloatField struct {
	Name     string
	Type     string
	Source   string
	GetValue FloatGetter
}

type IncomingIntField struct {
	Name     string
	Type     string
	Source   string
	GetValue IntGetter
}

type IncomingRecordInfo struct {
	// contains filtered or unexported fields
}

type IncomingStringField struct {
	Name     string
	Type     string
	Source   string
	Size     int
	GetValue StringGetter
}

type IncomingTimeField struct {
	Name     string
	Type     string
	Source   string
	GetValue TimeGetter
}

type InputConnection interface {
	Name() string
	Metadata() IncomingRecordInfo
	Read() RecordPacket
	Progress() float64
	Status() Status
}

type IntGetter func(Record) (int, bool)

type Io interface {
	Error(string)
	Warn(string)
	Info(string)
	UpdateProgress(float64) bool
	DecryptPassword(string) string
	CreateTempFile(string) string
	NotifyFileInput(string)
	NotifyFileOutput(string)
}

type MessageStatus int

type NewOutgoingField func() *outgoingField

type NullableField interface {
	GetNull() bool
	SetNull()
}

type OptionSetter func(testOptions) testOptions

type OutgoingBlobField interface {
	NullableField
	SetBlob([]byte)
	GetCurrentBlob() ([]byte, bool)
}

type OutgoingBoolField interface {
	NullableField
	SetBool(bool)
	GetCurrentBool() (bool, bool)
}

type OutgoingDateTimeField interface {
	NullableField
	SetDateTime(time.Time)
	GetCurrentDateTime() (time.Time, bool)
}

type OutgoingFloatField interface {
	NullableField
	SetFloat(float64)
	GetCurrentFloat() (float64, bool)
}

type OutgoingIntField interface {
	NullableField
	SetInt(int)
	GetCurrentInt() (int, bool)
}

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
	// contains filtered or unexported fields
}

type OutgoingStringField interface {
	NullableField
	SetString(string)
	GetCurrentString() (string, bool)
}

type OutputAnchor interface {
	Name() string
	IsOpen() bool
	Metadata() *OutgoingRecordInfo
	Open(info *OutgoingRecordInfo)
	Write()
	UpdateProgress(float64)
	Close()
	NumConnections() int
}

type Plugin interface {
	Init(Provider)
	OnInputConnectionOpened(InputConnection)
	OnRecordPacket(InputConnection)
	OnComplete()
}

type Provider interface {
	ToolConfig() string
	Io() Io
	GetOutputAnchor(string) OutputAnchor
	Environment() Environment
}

type Record = unsafe.Pointer

type RecordCache unsafe.Pointer

type RecordCollector struct {
	Config          IncomingRecordInfo
	Name            string
	Data            map[string][]interface{}
	Progress        float64
	PacketsReceived int
	// contains filtered or unexported fields
}

type RecordPacket interface {
	Next() bool
	Record() Record
}

type Status byte

type StringGetter func(Record) (string, bool)

type TimeGetter func(Record) (time.Time, bool)

type ToolOptionSetter func(toolOptions) toolOptions