code

Documentation

Index

• Constants
• Variables
• func AskForCodeIntegrationName(codeIntegrations []CodeIntegration) (name string, err error)
• func BundleCodeIntoTempFile(filesDir string, workspaceConfig *workspace.WorkspaceConfig) (close func(), tarGzFile *os.File, err error)
• func CloneCodeIntegrationVersion(ctx context.Context, codeIntegrationVersion *tensorleapapi.DatasetVersion, ...) ([]string, error)
• func CompareCodeVersion(ctx context.Context, compareVersion *CodeIntegrationVersion, ...) (bool, error)
• func DeleteCodeIntegration(ctx context.Context, codeIntegration *CodeIntegration) error
• func FetchFileFromTarGz(blobURL string, filename string) (string, error)
• func GetDatasetMappingYaml(ctx context.Context, codeIntegrationId string) string
• func GetLatestVersion(ctx context.Context, codeIntegrationId string) (*tensorleapapi.DatasetVersion, error)
• func IsCodeParseFailed(codeIntegrationVersion *CodeIntegrationVersion) bool
• func IsCodeParsing(codeIntegrationVersion *CodeIntegrationVersion) bool
• func PrintCodeIntegrationVersionParserErr(civ *CodeIntegrationVersion)
• func SelectOrCreateCodeIntegration(ctx context.Context, codeIntegrations []CodeIntegration, ...) (*tensorleapapi.Dataset, bool, error)
• type CodeIntegration
  • func AddCodeIntegration(ctx context.Context, name string) (*CodeIntegration, error)
  • func CreateCodeIntegration(ctx context.Context, codeIntegrations []CodeIntegration) (*CodeIntegration, error)
  • func GetAndUpdateCodeIntegrationIfNotExists(ctx context.Context, workspaceConfig *workspace.WorkspaceConfig) (code *CodeIntegration, wasCreated bool, err error)
  • func GetCodeIntegrationFromFlag(ctx context.Context, codeIntegrationIdFlag string, askForNewProjectFirst bool) (code *CodeIntegration, wasCreated bool, err error)
  • func GetCodeIntegrations(ctx context.Context) ([]CodeIntegration, error)
• type CodeIntegrationVersion
  • func AddCodeIntegrationVersion(ctx context.Context, tarGzFile io.Reader, fileSize int64, ...) (*CodeIntegrationVersion, error)
  • func GetCodeIntegration(ctx context.Context, id string) (*CodeIntegrationVersion, error)
  • func GetCodeIntegrationVersions(ctx context.Context, codeIntegrationId string) ([]CodeIntegrationVersion, error)
  • func PushCode(ctx context.Context, force bool, codeIntegrationId string, tarGzFile *os.File, ...) (pushed bool, current *CodeIntegrationVersion, err error)
  • func WaitForCodeIntegrationStatus(ctx context.Context, codeIntegrationId string) (ok bool, codeIntegrationVersion *CodeIntegrationVersion, err error)

Constants

const BindingFilePath = "leap_mapping.yaml"

Variables

var CodeIntegrationEntityDesc = entity.NewEntityDescriptor[CodeIntegration](
	"code integration",
	"code integrations",
	func(p *CodeIntegration) string { return p.GetName() },
	func(p *CodeIntegration) string { return p.GetCid() },
)

var CodeIntegrationVersionEntityDesc = entity.NewEntityDescriptor[CodeIntegrationVersion](
	"code integration version",
	"code integration versions",
	func(p *CodeIntegrationVersion) string { return p.GetNote() },
	func(p *CodeIntegrationVersion) string { return p.GetCid() },
)

var ErrEmptyCodeIntegrationVersion = fmt.Errorf("CodeIntegration is empty")

Functions

func AskForCodeIntegrationName

func AskForCodeIntegrationName(codeIntegrations []CodeIntegration) (name string, err error)

func BundleCodeIntoTempFile

func BundleCodeIntoTempFile(filesDir string, workspaceConfig *workspace.WorkspaceConfig) (close func(), tarGzFile *os.File, err error)

func CloneCodeIntegrationVersion

func CloneCodeIntegrationVersion(ctx context.Context, codeIntegrationVersion *tensorleapapi.DatasetVersion, outputDir string) ([]string, error)

func CompareCodeVersion

func CompareCodeVersion(ctx context.Context, compareVersion *CodeIntegrationVersion, tarGzFile *os.File, entryFile, secretId string) (bool, error)

func DeleteCodeIntegration

func DeleteCodeIntegration(ctx context.Context, codeIntegration *CodeIntegration) error

func FetchFileFromTarGz

func FetchFileFromTarGz(blobURL string, filename string) (string, error)

func GetDatasetMappingYaml

func GetDatasetMappingYaml(ctx context.Context, codeIntegrationId string) string

func GetLatestVersion

func GetLatestVersion(ctx context.Context, codeIntegrationId string) (*tensorleapapi.DatasetVersion, error)

func IsCodeParseFailed

func IsCodeParseFailed(codeIntegrationVersion *CodeIntegrationVersion) bool

func IsCodeParsing

func IsCodeParsing(codeIntegrationVersion *CodeIntegrationVersion) bool

func PrintCodeIntegrationVersionParserErr

func PrintCodeIntegrationVersionParserErr(civ *CodeIntegrationVersion)

func SelectOrCreateCodeIntegration

func SelectOrCreateCodeIntegration(ctx context.Context, codeIntegrations []CodeIntegration, askIsCreateNewFirst bool) (*tensorleapapi.Dataset, bool, error)

Types

type CodeIntegration

type CodeIntegration = tensorleapapi.Dataset

func AddCodeIntegration

func AddCodeIntegration(ctx context.Context, name string) (*CodeIntegration, error)

func CreateCodeIntegration

func CreateCodeIntegration(ctx context.Context, codeIntegrations []CodeIntegration) (*CodeIntegration, error)

func GetAndUpdateCodeIntegrationIfNotExists

func GetAndUpdateCodeIntegrationIfNotExists(ctx context.Context, workspaceConfig *workspace.WorkspaceConfig) (code *CodeIntegration, wasCreated bool, err error)

func GetCodeIntegrationFromFlag

func GetCodeIntegrationFromFlag(ctx context.Context, codeIntegrationIdFlag string, askForNewProjectFirst bool) (code *CodeIntegration, wasCreated bool, err error)

func GetCodeIntegrations

func GetCodeIntegrations(ctx context.Context) ([]CodeIntegration, error)

type CodeIntegrationVersion

type CodeIntegrationVersion = tensorleapapi.DatasetVersion

func AddCodeIntegrationVersion

func AddCodeIntegrationVersion(ctx context.Context, tarGzFile io.Reader, fileSize int64, codeIntegrationId, entryFile, secretId string) (*CodeIntegrationVersion, error)

func GetCodeIntegration

func GetCodeIntegration(ctx context.Context, id string) (*CodeIntegrationVersion, error)

func GetCodeIntegrationVersions

func GetCodeIntegrationVersions(ctx context.Context, codeIntegrationId string) ([]CodeIntegrationVersion, error)

func PushCode

func PushCode(ctx context.Context, force bool, codeIntegrationId string, tarGzFile *os.File, entryFile, secretId string) (pushed bool, current *CodeIntegrationVersion, err error)

func WaitForCodeIntegrationStatus

func WaitForCodeIntegrationStatus(ctx context.Context, codeIntegrationId string) (ok bool, codeIntegrationVersion *CodeIntegrationVersion, err error)