endpoints

Documentation

Index

• func RunGrpcJobServer() error
• type AuthHandler
  • func InitAuthHandler() (*AuthHandler, error)
• type BaktaJobAPI
  • func InitBaktaAPI(dbHandler *database.Handler, scheduler *scheduler.SimpleScheduler, ...) *BaktaJobAPI
  • func (apiHandler *BaktaJobAPI) GetJobResult(ctx context.Context, request *api.JobAuth) (*api.JobResultResponse, error)
  • func (apiHandler *BaktaJobAPI) GetJobsStatus(ctx context.Context, request *api.JobStatusRequestList) (*api.JobStatusReponseList, error)
  • func (apiHandler *BaktaJobAPI) InitJob(ctx context.Context, request *api.InitJobRequest) (*api.InitJobResponse, error)
  • func (apiHandler *BaktaJobAPI) StartJob(ctx context.Context, request *api.StartJobRequest) (*api.Empty, error)
  • func (apiHandler *BaktaJobAPI) Version(ctx context.Context, request *api.Empty) (*api.VersionResponse, error)
• type BaktaUpdateAPI
  • func (apiHandler *BaktaUpdateAPI) UpdateStatus(ctx context.Context, request *api.UpdateStatusRequest) (*api.Empty, error)

Functions

func RunGrpcJobServer

func RunGrpcJobServer() error

RunGrpcJobServer Runs the Grpc server

Types

type AuthHandler

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

AuthHandler Simple auth handler to check if a grpc call has a token Only for testing purposes

func InitAuthHandler

func InitAuthHandler() (*AuthHandler, error)

InitAuthHandler Initiates a simple auth handler

type BaktaJobAPI

type BaktaJobAPI struct {
	api.UnimplementedBaktaJobsServer
	// contains filtered or unexported fields
}

BaktaJobAPI implements the job endpoints of the bakta-web-api

func InitBaktaAPI

func InitBaktaAPI(dbHandler *database.Handler, scheduler *scheduler.SimpleScheduler, s3Handler *objectStorage.S3ObjectStorageHandler, monitor *monitor.SimpleMonitor) *BaktaJobAPI

InitBaktaAPI Initiates the Bakta API handler

func (*BaktaJobAPI) GetJobResult

func (apiHandler *BaktaJobAPI) GetJobResult(ctx context.Context, request *api.JobAuth) (*api.JobResultResponse, error)

GetJobResult Returns the results for a specific jobs

func (*BaktaJobAPI) GetJobsStatus

func (apiHandler *BaktaJobAPI) GetJobsStatus(ctx context.Context, request *api.JobStatusRequestList) (*api.JobStatusReponseList, error)

GetJobsStatus Get the job status of the provided list of jobs

func (*BaktaJobAPI) InitJob

func (apiHandler *BaktaJobAPI) InitJob(ctx context.Context, request *api.InitJobRequest) (*api.InitJobResponse, error)

InitJob Initiates a bakta job and returns upload links for the fasta, prodigal training and replicon file

func (*BaktaJobAPI) StartJob

func (apiHandler *BaktaJobAPI) StartJob(ctx context.Context, request *api.StartJobRequest) (*api.Empty, error)

StartJob Starts a job based on the provided configuration

func (*BaktaJobAPI) Version

func (apiHandler *BaktaJobAPI) Version(ctx context.Context, request *api.Empty) (*api.VersionResponse, error)

type BaktaUpdateAPI

type BaktaUpdateAPI struct {
	api.UnimplementedBaktaStatusUpdateServer
	// contains filtered or unexported fields
}

BaktaUpdateAPI implements the endpoints of the bakta-web-api

func (*BaktaUpdateAPI) UpdateStatus

func (apiHandler *BaktaUpdateAPI) UpdateStatus(ctx context.Context, request *api.UpdateStatusRequest) (*api.Empty, error)

UpdateStatus Updates the status of a running job