util

Documentation

Index

• Constants
• type DatabaseHandler
  • func InitDatabaseHandler() (*DatabaseHandler, error)
  • func (handler *DatabaseHandler) DeleteJob(id string) error
  • func (handler *DatabaseHandler) ListExpiredJobs() ([]*Job, error)
  • func (handler *DatabaseHandler) ListRunningJobs() ([]*Job, error)
• type Job
• type K8sHandler
  • func InitSimpleScheduler() (*K8sHandler, error)
  • func (handler *K8sHandler) DeleteK8sJob(jobID string) error
• type S3ObjectStorageHandler
  • func InitS3ObjectStorageHandler() (*S3ObjectStorageHandler, error)
  • func (handler *S3ObjectStorageHandler) DeleteObject(bucket string, key string) error

Constants

const COLLECTIONNAME = "jobs"

Types

type DatabaseHandler

type DatabaseHandler struct {
	DB             *mongo.Client
	Collection     *mongo.Collection
	K8sClient      *kubernetes.Clientset
	BaseKey        string
	UserDataBucket string
	DBBucket       string
	Namespace      string
	ExpiryTime     int64
}

func InitDatabaseHandler

func InitDatabaseHandler() (*DatabaseHandler, error)

func (*DatabaseHandler) DeleteJob

func (handler *DatabaseHandler) DeleteJob(id string) error

func (*DatabaseHandler) ListExpiredJobs

func (handler *DatabaseHandler) ListExpiredJobs() ([]*Job, error)

func (*DatabaseHandler) ListRunningJobs

func (handler *DatabaseHandler) ListRunningJobs() ([]*Job, error)

type Job

type Job struct {
	JobID       string
	Secret      string
	K8sID       string
	Updated     primitive.Timestamp
	Created     primitive.Timestamp
	Status      string
	DataBucket  string
	FastaKey    string
	ProdigalKey string
	RepliconKey string
	ResultKey   string
	Error       string
	ExpiryDate  primitive.Timestamp
	ConfString  string
	IsDeleted   bool
	Jobname     string
}

Job The database model for a bakta job

type K8sHandler

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

func InitSimpleScheduler

func InitSimpleScheduler() (*K8sHandler, error)

func (*K8sHandler) DeleteK8sJob

func (handler *K8sHandler) DeleteK8sJob(jobID string) error

type S3ObjectStorageHandler

type S3ObjectStorageHandler struct {
	S3Client   *s3.Client
	S3Endpoint string
}

func InitS3ObjectStorageHandler

func InitS3ObjectStorageHandler() (*S3ObjectStorageHandler, error)

func (*S3ObjectStorageHandler) DeleteObject

func (handler *S3ObjectStorageHandler) DeleteObject(bucket string, key string) error