config

Documentation

Index

• func ParseTransfer(yaml []byte) (*model.Transfer, error)
• func StringToDurationHookFunc() mapstructure.DecodeHookFunc
• func TransferFromYaml(params *string) (*model.Transfer, error)
• type Endpoint
  • func (e Endpoint) RawParams() string
• type Runtime
• type TransferYamlView
  • func NewYamlView(tr *model.Transfer) *TransferYamlView
  • func ParseTransferYaml(rawData []byte) (*TransferYamlView, error)
• type UploadTables
  • func ParseTablesYaml(rawData []byte) (*UploadTables, error)
  • func TablesFromYaml(tablesParams *string) (*UploadTables, error)

Functions

func ParseTransfer

func ParseTransfer(yaml []byte) (*model.Transfer, error)

func StringToDurationHookFunc

func StringToDurationHookFunc() mapstructure.DecodeHookFunc

func TransferFromYaml

func TransferFromYaml(params *string) (*model.Transfer, error)

Types

type Endpoint

type Endpoint struct {
	Type   abstract.ProviderType
	Params any
}

func (Endpoint) RawParams

func (e Endpoint) RawParams() string

type Runtime

type Runtime struct {
	Type   string
	Params interface{}
}

type TransferYamlView

type TransferYamlView struct {
	ID                string
	TransferName      string
	Description       string
	Labels            string
	Status            model.TransferStatus
	Type              abstract.TransferType
	FolderID          string
	CloudID           string
	Src               Endpoint
	Dst               Endpoint
	RegularSnapshot   *abstract.RegularSnapshot `yaml:"regular_snapshot"`
	Transformation    *transformer.Transformers `yaml:"transformation"`
	DataObjects       *model.DataObjects        `yaml:"data_objects"`
	TypeSystemVersion int                       `yaml:"type_system_version"`
}

func NewYamlView

func NewYamlView(tr *model.Transfer) *TransferYamlView

func ParseTransferYaml

func ParseTransferYaml(rawData []byte) (*TransferYamlView, error)

type UploadTables

type UploadTables struct {
	Tables []abstract.TableDescription
}

func ParseTablesYaml

func ParseTablesYaml(rawData []byte) (*UploadTables, error)

func TablesFromYaml

func TablesFromYaml(tablesParams *string) (*UploadTables, error)