stockcenter

package
v0.0.0-...-4659cd4 Latest Latest
Warning

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

Go to latest
Published: Mar 14, 2026 License: BSD-2-Clause Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
const (
	FOLDER = "folder"
	BUCKET = "bucket"
)

Variables

View Source
var GenoCmd = &cobra.Command{
	Use:   "genotype",
	Short: "load stockcenter genotype data",
	Args:  cobra.NoArgs,
	RunE:  loader.LoadGeno,
	PreRunE: func(_ *cobra.Command, _ []string) error {
		if err := SetAnnoAPIClient(); err != nil {
			return err
		}
		if err := setReader(viper.GetString("genotype-input"), regsc.GenoReader); err != nil {
			return err
		}
		return nil
	},
}

GenoCmd is for loading stockcenter genotype data

View Source
var GwdiCmd = &cobra.Command{
	Use:   "gwdi",
	Short: "load gwdi strains",
	Args:  cobra.NoArgs,
	RunE:  loader.LoadGwdi,
	PreRunE: func(_ *cobra.Command, _ []string) error {
		if err := SetStockAPIClient(); err != nil {
			return err
		}
		if err := SetAnnoAPIClient(); err != nil {
			return err
		}
		if err := setReader(viper.GetString("gwdi-input"), regsc.GwdiReader); err != nil {
			return err
		}
		return nil
	},
}

GwdiCmd is for loading gwdi strains

View Source
var OrderCmd = &cobra.Command{
	Use:     "order",
	Short:   "load stockcenter order data",
	Args:    cobra.NoArgs,
	RunE:    loader.LoadOrder,
	PreRunE: setOrderPreRun,
}

OrderCmd is for loading stockcenter order data

View Source
var PhenoCmd = &cobra.Command{
	Use:   "phenotype",
	Short: "load stockcenter phenotype data",
	Args:  cobra.NoArgs,
	RunE:  loader.LoadPheno,
	PreRunE: func(_ *cobra.Command, _ []string) error {
		if err := SetAnnoAPIClient(); err != nil {
			return err
		}
		if err := setReader(viper.GetString("phenotype-input"), regsc.PhenoReader); err != nil {
			return err
		}
		return nil
	},
}

PhenoCmd is for loading stockcenter phenotype data

View Source
var PlasmidCmd = &cobra.Command{
	Use:     "plasmid",
	Short:   "load stockcenter plasmid data",
	Args:    cobra.NoArgs,
	RunE:    loader.LoadPlasmid,
	PreRunE: setPlasmidPreRun,
}

PlasmidCmd is for loading stockcenter plasmid data

View Source
var PlasmidInvCmd = &cobra.Command{
	Use:   "plasmid-inventory",
	Short: "load plasmid inventory data",
	Args:  cobra.NoArgs,
	RunE:  loader.LoadPlasmidInv,
	PreRunE: func(_ *cobra.Command, _ []string) error {
		if err := SetAnnoAPIClient(); err != nil {
			return err
		}
		if err := setReader(
			viper.GetString("plasmid-inventory-input"),
			regsc.InvReader,
		); err != nil {
			return err
		}
		return nil
	},
}

PlasmidInvCmd is for loading plasmid inventory data

View Source
var ReadFileCmd = &cobra.Command{
	Use:     "readfile",
	Short:   "read data from any file",
	Args:    cobra.NoArgs,
	RunE:    LoadReadFile,
	PreRunE: setReadFilePreRun,
}

ReadFileCmd is for reading any data file

View Source
var StockCenterCmd = &cobra.Command{
	Use:   "stockcenter",
	Short: "subcommand for stockcenter data loading",
}

StockCenterCmd represents the base subcommand for grouping all subcommands for loading stockcenter related data

View Source
var StrainCharCmd = &cobra.Command{
	Use:   "strainchar",
	Short: "load stockcenter strain characteristics data",
	Args:  cobra.NoArgs,
	RunE:  loader.LoadStrainChar,
	PreRunE: func(_ *cobra.Command, _ []string) error {
		if err := SetAnnoAPIClient(); err != nil {
			return err
		}
		if err := setReader(
			viper.GetString("strainchar-input"),
			regsc.StraincharReader,
		); err != nil {
			return err
		}
		return nil
	},
}

StrainCharCmd is for loading stockcenter strain characteristics data

View Source
var StrainCmd = &cobra.Command{
	Use:     "strain",
	Short:   "load stockcenter strain data",
	Args:    cobra.NoArgs,
	RunE:    loader.LoadStrain,
	PreRunE: setStrainPreRun,
}

StrainCmd is for loading stockcenter strain data

View Source
var StrainInvCmd = &cobra.Command{
	Use:   "strain-inventory",
	Short: "load strain inventory data",
	Args:  cobra.NoArgs,
	RunE:  loader.LoadStrainInv,
	PreRunE: func(_ *cobra.Command, _ []string) error {
		if err := SetAnnoAPIClient(); err != nil {
			return err
		}
		if err := setReader(
			viper.GetString("strain-inventory-input"),
			regsc.InvReader,
		); err != nil {
			return err
		}
		return nil
	},
}

StrainInvCmd is for loading strain inventory data

View Source
var StrainPropCmd = &cobra.Command{
	Use:   "strainprop",
	Short: "load stockcenter strain properties data",
	Args:  cobra.NoArgs,
	RunE:  loader.LoadStrainProp,
	PreRunE: func(_ *cobra.Command, _ []string) error {
		if err := SetAnnoAPIClient(); err != nil {
			return err
		}
		if err := setReader(
			viper.GetString("strainprop-input"),
			regsc.StrainpropReader,
		); err != nil {
			return err
		}
		return nil
	},
}

StrainPropCmd is for loading stockcenter strain properties data

View Source
var StrainSynCmd = &cobra.Command{
	Use:   "strainsyn",
	Short: "load stockcenter strain synonyms",
	Args:  cobra.NoArgs,
	RunE:  loader.LoadStrainSynProp,
	PreRunE: func(_ *cobra.Command, _ []string) error {
		if err := SetAnnoAPIClient(); err != nil {
			return err
		}
		if err := setReader(viper.GetString("strainsyn-input"), regsc.StrainSynReader); err != nil {
			return err
		}
		return nil
	},
}

StrainSynCmd is for loading stockcenter strain synonyms

Functions

func AnnotationFlags

func AnnotationFlags() []cli.Flag

AnnotationFlags returns flags for annotation service connection

func GoldenBraidInputFlags

func GoldenBraidInputFlags() []cli.Flag

GoldenBraidInputFlags returns the flag for the goldenbraid plasmid CSV input. Reuses --input-source, --s3-bucket, --s3-bucket-path from InputFlags() for source routing.

func InputFlags

func InputFlags() []cli.Flag

InputFlags returns flags for input file configuration

func InventoryInputFlags

func InventoryInputFlags() []cli.Flag

InventoryInputFlags returns flags for inventory input file configuration

func LoadGoldenBraidInventory

func LoadGoldenBraidInventory(cmd *cli.Context) error

func LoadReadFile

func LoadReadFile(_ *cobra.Command, _ []string) error

LoadReadFile reads at least first config.DefaultPageSize lines of the file

func LoggingFlags

func LoggingFlags() []cli.Flag

LoggingFlags returns flags for logging configuration

func OntologyFlags

func OntologyFlags() []cli.Flag

OntologyFlags returns flags for ontology configuration

func S3Flags

func S3Flags() []cli.Flag

S3Flags returns flags for S3 server configuration

func SetAllClients

func SetAllClients(cltx *cli.Context) error

SetAllClients sets up stock, annotation, and S3 clients Used by the inventory subcommand which requires all three.

func SetAnnoAPIClient

func SetAnnoAPIClient() error

func SetAnnotationClient

func SetAnnotationClient(
	cltx *cli.Context,
) IOE.IOEither[error, *grpc.ClientConn]

SetAnnotationClient creates annotation gRPC connection and registers client

func SetClients

func SetClients(cltx *cli.Context) error

SetClients sets up both stock and annotation clients

func SetS3Client

func SetS3Client(cltx *cli.Context) IOE.IOEither[error, *minio.Client]

SetS3Client initializes the S3 client

func SetStockAPIClient

func SetStockAPIClient() error

func SetStockAndS3Clients

func SetStockAndS3Clients(cltx *cli.Context) error

SetStockAndS3Clients sets up both stock client and S3 client Uses SequenceArraySeq for independent operations that should both succeed

func SetStockClient

func SetStockClient(cltx *cli.Context) IOE.IOEither[error, *grpc.ClientConn]

SetStockClient creates stock gRPC connection and registers client

func SetStockClientWrapper

func SetStockClientWrapper(cltx *cli.Context) error

SetStockClientWrapper wraps SetStockClient for use as a Before hook Returns error directly instead of IOEither for urfave/cli compatibility

func StockConnectionFlags

func StockConnectionFlags() []cli.Flag

StockConnectionFlags returns flags for stock service connection

Types

type GRPCClientConfig

type GRPCClientConfig struct {
	Host        string
	Port        string
	ServiceName string // For error messages
}

GRPCClientConfig holds configuration for creating a gRPC client

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL