model

package
v0.1.0-alpha.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 13, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ContractFieldTypeStrings 

func ContractFieldTypeStrings() []string

ContractFieldTypeStrings returns a slice of all String values of the enum

func ContractRepresentationStrings 

func ContractRepresentationStrings() []string

ContractRepresentationStrings returns a slice of all String values of the enum

func ContractRootShapeStrings 

func ContractRootShapeStrings() []string

ContractRootShapeStrings returns a slice of all String values of the enum

func DataSourceTypeStrings 

func DataSourceTypeStrings() []string

DataSourceTypeStrings returns a slice of all String values of the enum

func IncrementalCheckpointKindStrings 

func IncrementalCheckpointKindStrings() []string

IncrementalCheckpointKindStrings returns a slice of all String values of the enum

func ParameterDataTypeStrings 

func ParameterDataTypeStrings() []string

ParameterDataTypeStrings returns a slice of all String values of the enum

func PipelineFormatStrings 

func PipelineFormatStrings() []string

PipelineFormatStrings returns a slice of all String values of the enum

func RuntimeVariableValueTypeStrings 

func RuntimeVariableValueTypeStrings() []string

RuntimeVariableValueTypeStrings returns a slice of all String values of the enum

func SinkBackendStrings 

func SinkBackendStrings() []string

SinkBackendStrings returns a slice of all String values of the enum

func TransformOutputKindStrings 

func TransformOutputKindStrings() []string

TransformOutputKindStrings returns a slice of all String values of the enum

Types

type ContractFieldType 

type ContractFieldType int

ContractFieldType defines supported schema field types for step contracts. 

const (
	ContractFieldTypeUnknown       ContractFieldType = iota // unknown
	ContractFieldTypeValueString                            // string
	ContractFieldTypeValueInteger                           // integer
	ContractFieldTypeValueNumber                            // number
	ContractFieldTypeValueBoolean                           // boolean
	ContractFieldTypeValueObject                            // object
	ContractFieldTypeValueArray                             // array
	ContractFieldTypeValueDatetime                          // datetime
)

func ContractFieldTypeString 

func ContractFieldTypeString(s string) (ContractFieldType, error)

ContractFieldTypeString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func ContractFieldTypeValues 

func ContractFieldTypeValues() []ContractFieldType

ContractFieldTypeValues returns all values of the enum

func (ContractFieldType) IsAContractFieldType 

func (i ContractFieldType) IsAContractFieldType() bool

IsAContractFieldType returns "true" if the value is listed in the enum definition. "false" otherwise

func (ContractFieldType) MarshalJSON 

func (i ContractFieldType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for ContractFieldType

func (ContractFieldType) MarshalText 

func (i ContractFieldType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for ContractFieldType

func (ContractFieldType) String 

func (i ContractFieldType) String() string

func (*ContractFieldType) UnmarshalJSON 

func (i *ContractFieldType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for ContractFieldType

func (*ContractFieldType) UnmarshalText 

func (i *ContractFieldType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for ContractFieldType

type ContractRepresentation 

type ContractRepresentation int

ContractRepresentation defines the payload representation at a pipeline edge. 

const (
	ContractRepresentationUnknown       ContractRepresentation = iota // unknown
	ContractRepresentationRows                                        // rows
	ContractRepresentationJSON                                        // json
	ContractRepresentationCSV                                         // csv
	ContractRepresentationFile                                        // file
	ContractRepresentationMultipartForm                               // multipart_form
)

func ContractRepresentationString 

func ContractRepresentationString(s string) (ContractRepresentation, error)

ContractRepresentationString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func ContractRepresentationValues 

func ContractRepresentationValues() []ContractRepresentation

ContractRepresentationValues returns all values of the enum

func (ContractRepresentation) IsAContractRepresentation 

func (i ContractRepresentation) IsAContractRepresentation() bool

IsAContractRepresentation returns "true" if the value is listed in the enum definition. "false" otherwise

func (ContractRepresentation) MarshalJSON 

func (i ContractRepresentation) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for ContractRepresentation

func (ContractRepresentation) MarshalText 

func (i ContractRepresentation) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for ContractRepresentation

func (ContractRepresentation) String 

func (i ContractRepresentation) String() string

func (*ContractRepresentation) UnmarshalJSON 

func (i *ContractRepresentation) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for ContractRepresentation

func (*ContractRepresentation) UnmarshalText 

func (i *ContractRepresentation) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for ContractRepresentation

type ContractRootShape 

type ContractRootShape int

ContractRootShape defines the root JSON container shape when representation is json. 

const (
	ContractRootShapeUnknown ContractRootShape = iota // unknown
	ContractRootShapeObject                           // object
	ContractRootShapeArray                            // array
)

func ContractRootShapeString 

func ContractRootShapeString(s string) (ContractRootShape, error)

ContractRootShapeString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func ContractRootShapeValues 

func ContractRootShapeValues() []ContractRootShape

ContractRootShapeValues returns all values of the enum

func (ContractRootShape) IsAContractRootShape 

func (i ContractRootShape) IsAContractRootShape() bool

IsAContractRootShape returns "true" if the value is listed in the enum definition. "false" otherwise

func (ContractRootShape) MarshalJSON 

func (i ContractRootShape) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for ContractRootShape

func (ContractRootShape) MarshalText 

func (i ContractRootShape) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for ContractRootShape

func (ContractRootShape) String 

func (i ContractRootShape) String() string

func (*ContractRootShape) UnmarshalJSON 

func (i *ContractRootShape) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for ContractRootShape

func (*ContractRootShape) UnmarshalText 

func (i *ContractRootShape) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for ContractRootShape

type DataSourceType 

type DataSourceType int
const (
	DataSourceTypeUnknown   DataSourceType = iota // unknown type, should not be used
	DataSourceTypePostgres                        // postgres
	DataSourceTypeMySQL                           // mysql
	DataSourceTypeBigQuery                        // bigquery
	DataSourceTypeHTTP                            // http
	DataSourceTypeMongoDB                         // mongodb
	DataSourceTypeHubSpot                         // hubspot
	DataSourceTypeFTP                             // ftp
	DataSourceTypeGit                             // git
	DataSourceTypeGithub                          // github
	DataSourceTypeGitlab                          // gitlab
	DataSourceTypeS3                              // s3
	DataSourceTypeSnowflake                       // snowflake
)

func DataSourceTypeString 

func DataSourceTypeString(s string) (DataSourceType, error)

DataSourceTypeString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func DataSourceTypeValues 

func DataSourceTypeValues() []DataSourceType

DataSourceTypeValues returns all values of the enum

func (DataSourceType) IsADataSourceType 

func (i DataSourceType) IsADataSourceType() bool

IsADataSourceType returns "true" if the value is listed in the enum definition. "false" otherwise

func (DataSourceType) MarshalText 

func (i DataSourceType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for DataSourceType

func (DataSourceType) String 

func (i DataSourceType) String() string

func (*DataSourceType) UnmarshalText 

func (i *DataSourceType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for DataSourceType

type IncrementalCheckpointKind 

type IncrementalCheckpointKind int

IncrementalCheckpointKind defines the source checkpoint shape. 

const (
	IncrementalCheckpointKindUnknown   IncrementalCheckpointKind = iota // unknown
	IncrementalCheckpointKindWatermark                                  // watermark
	IncrementalCheckpointKindCursor                                     // cursor
)

func IncrementalCheckpointKindString 

func IncrementalCheckpointKindString(s string) (IncrementalCheckpointKind, error)

IncrementalCheckpointKindString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func IncrementalCheckpointKindValues 

func IncrementalCheckpointKindValues() []IncrementalCheckpointKind

IncrementalCheckpointKindValues returns all values of the enum

func (IncrementalCheckpointKind) IsAIncrementalCheckpointKind 

func (i IncrementalCheckpointKind) IsAIncrementalCheckpointKind() bool

IsAIncrementalCheckpointKind returns "true" if the value is listed in the enum definition. "false" otherwise

func (IncrementalCheckpointKind) MarshalJSON 

func (i IncrementalCheckpointKind) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for IncrementalCheckpointKind

func (IncrementalCheckpointKind) MarshalText 

func (i IncrementalCheckpointKind) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for IncrementalCheckpointKind

func (IncrementalCheckpointKind) String 

func (i IncrementalCheckpointKind) String() string

func (*IncrementalCheckpointKind) UnmarshalJSON 

func (i *IncrementalCheckpointKind) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for IncrementalCheckpointKind

func (*IncrementalCheckpointKind) UnmarshalText 

func (i *IncrementalCheckpointKind) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for IncrementalCheckpointKind

type ParameterDataType 

type ParameterDataType int

ParameterDataType is the data type of a query parameter. 

const (
	ParameterDataTypeUnknown ParameterDataType = iota // unknown
	ParameterDataTypeText                             // text
	ParameterDataTypeInteger                          // integer
	ParameterDataTypeBoolean                          // boolean
	ParameterDataTypeDate                             // date
	ParameterDataTypeUUID                             // uuid
)

func ParameterDataTypeString 

func ParameterDataTypeString(s string) (ParameterDataType, error)

ParameterDataTypeString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func ParameterDataTypeValues 

func ParameterDataTypeValues() []ParameterDataType

ParameterDataTypeValues returns all values of the enum

func (ParameterDataType) IsAParameterDataType 

func (i ParameterDataType) IsAParameterDataType() bool

IsAParameterDataType returns "true" if the value is listed in the enum definition. "false" otherwise

func (ParameterDataType) MarshalJSON 

func (i ParameterDataType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for ParameterDataType

func (ParameterDataType) MarshalText 

func (i ParameterDataType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for ParameterDataType

func (ParameterDataType) String 

func (i ParameterDataType) String() string

func (*ParameterDataType) UnmarshalJSON 

func (i *ParameterDataType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for ParameterDataType

func (*ParameterDataType) UnmarshalText 

func (i *ParameterDataType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for ParameterDataType

type PipelineFormat 

type PipelineFormat int

PipelineFormat defines the serialization format for pipeline spec files. 

const (
	PipelineFormatUnknown PipelineFormat = iota // unknown
	PipelineFormatYAML                          // yaml
	PipelineFormatJSON                          // json
)

func PipelineFormatString 

func PipelineFormatString(s string) (PipelineFormat, error)

PipelineFormatString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func PipelineFormatValues 

func PipelineFormatValues() []PipelineFormat

PipelineFormatValues returns all values of the enum

func (PipelineFormat) IsAPipelineFormat 

func (i PipelineFormat) IsAPipelineFormat() bool

IsAPipelineFormat returns "true" if the value is listed in the enum definition. "false" otherwise

func (PipelineFormat) MarshalJSON 

func (i PipelineFormat) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for PipelineFormat

func (PipelineFormat) MarshalText 

func (i PipelineFormat) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for PipelineFormat

func (PipelineFormat) String 

func (i PipelineFormat) String() string

func (*PipelineFormat) UnmarshalJSON 

func (i *PipelineFormat) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for PipelineFormat

func (*PipelineFormat) UnmarshalText 

func (i *PipelineFormat) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for PipelineFormat

type RuntimeSecretValue 

type RuntimeSecretValue struct {
	Key   string
	Value string
}

type RuntimeVariable 

type RuntimeVariable struct {
	EnvironmentSlug slug.Slug
	Key             string
	ValueType       RuntimeVariableValueType
	Value           string
	Description     *string
	CreatedAt       time.Time
	UpdatedAt       time.Time
}

type RuntimeVariableValueType 

type RuntimeVariableValueType int
const (
	RuntimeVariableValueTypeUnknown RuntimeVariableValueType = iota // unknown
	RuntimeVariableValueTypeText                                    // text
	RuntimeVariableValueTypeInteger                                 // integer
	RuntimeVariableValueTypeBoolean                                 // boolean
	RuntimeVariableValueTypeDate                                    // date
	RuntimeVariableValueTypeUUID                                    // uuid
)

func RuntimeVariableValueTypeString 

func RuntimeVariableValueTypeString(s string) (RuntimeVariableValueType, error)

RuntimeVariableValueTypeString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func RuntimeVariableValueTypeValues 

func RuntimeVariableValueTypeValues() []RuntimeVariableValueType

RuntimeVariableValueTypeValues returns all values of the enum

func (RuntimeVariableValueType) IsARuntimeVariableValueType 

func (i RuntimeVariableValueType) IsARuntimeVariableValueType() bool

IsARuntimeVariableValueType returns "true" if the value is listed in the enum definition. "false" otherwise

func (RuntimeVariableValueType) MarshalJSON 

func (i RuntimeVariableValueType) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for RuntimeVariableValueType

func (RuntimeVariableValueType) MarshalText 

func (i RuntimeVariableValueType) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for RuntimeVariableValueType

func (RuntimeVariableValueType) String 

func (i RuntimeVariableValueType) String() string

func (*RuntimeVariableValueType) UnmarshalJSON 

func (i *RuntimeVariableValueType) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for RuntimeVariableValueType

func (*RuntimeVariableValueType) UnmarshalText 

func (i *RuntimeVariableValueType) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for RuntimeVariableValueType

type SinkBackend 

type SinkBackend int

SinkBackend identifies the sink delivery backend for pipeline sink steps. 

const (
	SinkBackendUnknown SinkBackend = iota // unknown
	SinkBackendFTP                        // ftp
	SinkBackendDB                         // db
	SinkBackendHTTP                       // http
	SinkBackendMongo                      // mongo
	SinkBackendGit                        // git
	SinkBackendGithub                     // github
	SinkBackendGitlab                     // gitlab
	SinkBackendS3                         // s3
)

func SinkBackendString 

func SinkBackendString(s string) (SinkBackend, error)

SinkBackendString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func SinkBackendValues 

func SinkBackendValues() []SinkBackend

SinkBackendValues returns all values of the enum

func (SinkBackend) IsASinkBackend 

func (i SinkBackend) IsASinkBackend() bool

IsASinkBackend returns "true" if the value is listed in the enum definition. "false" otherwise

func (SinkBackend) MarshalJSON 

func (i SinkBackend) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for SinkBackend

func (SinkBackend) MarshalText 

func (i SinkBackend) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for SinkBackend

func (SinkBackend) String 

func (i SinkBackend) String() string

func (*SinkBackend) UnmarshalJSON 

func (i *SinkBackend) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for SinkBackend

func (*SinkBackend) UnmarshalText 

func (i *SinkBackend) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for SinkBackend

type TransformOutputKind 

type TransformOutputKind int

TransformOutputKind defines supported output payload kinds for transforms. 

const (
	TransformOutputKindUnknown TransformOutputKind = iota // unknown
	TransformOutputKindRows                               // rows
	TransformOutputKindJSON                               // json
	TransformOutputKindCSV                                // csv
)

func TransformOutputKindString 

func TransformOutputKindString(s string) (TransformOutputKind, error)

TransformOutputKindString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func TransformOutputKindValues 

func TransformOutputKindValues() []TransformOutputKind

TransformOutputKindValues returns all values of the enum

func (TransformOutputKind) IsATransformOutputKind 

func (i TransformOutputKind) IsATransformOutputKind() bool

IsATransformOutputKind returns "true" if the value is listed in the enum definition. "false" otherwise

func (TransformOutputKind) MarshalJSON 

func (i TransformOutputKind) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for TransformOutputKind

func (TransformOutputKind) MarshalText 

func (i TransformOutputKind) MarshalText() ([]byte, error)

MarshalText implements the encoding.TextMarshaler interface for TransformOutputKind

func (TransformOutputKind) String 

func (i TransformOutputKind) String() string

func (*TransformOutputKind) UnmarshalJSON 

func (i *TransformOutputKind) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for TransformOutputKind

func (*TransformOutputKind) UnmarshalText 

func (i *TransformOutputKind) UnmarshalText(text []byte) error

UnmarshalText implements the encoding.TextUnmarshaler interface for TransformOutputKind

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.