server

Documentation

Index

• Variables
• func SetupLogger()
• func StartAgent() error
• type CustomReader
  • func (r *CustomReader) Read(p []byte) (int, error)
  • func (r *CustomReader) ReadAt(p []byte, off int64) (int, error)
  • func (r *CustomReader) Seek(offset int64, whence int) (int64, error)
• type WorkOrder

Variables

var GRPCServer *grpc.Server

var Version = "development"

Functions

func SetupLogger

func SetupLogger()

func StartAgent

func StartAgent() error

StartAgent initiates the local gRPC server and checks if it runs.

Types

type CustomReader

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

func (*CustomReader) Read

func (r *CustomReader) Read(p []byte) (int, error)

func (*CustomReader) ReadAt

func (r *CustomReader) ReadAt(p []byte, off int64) (int, error)

func (*CustomReader) Seek

func (r *CustomReader) Seek(offset int64, whence int) (int64, error)

type WorkOrder

type WorkOrder struct {
	ProcessID          guuid.UUID                        `json:"ProcessID"`
	FilePath           string                            `json:"FilePath"`
	ManifestID         int32                             `json:"ManifestID"`
	WorkFlowType       api.WorkflowResponse_WorkflowType `json:"WorkFlowType"`
	Input              string                            `json:"Input"`
	Files              string                            `json:"Files"`
	Status             bool                              `json:"Status"`
	WorkFlowOutput     string                            `json:"WorkFlowOutput"`
	ManifestRoots      []string                          `json:"ManifestRoots"`
	NextflowConfigFile string                            `json:"NextflowConfigFile"`
}