api

package
v0.0.0-...-ac8ba76 Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2021 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	JobFailedStatus_name = map[int32]string{
		0: "NOT_FOUND",
		1: "UNAUTHORIZED",
	}
	JobFailedStatus_value = map[string]int32{
		"NOT_FOUND":    0,
		"UNAUTHORIZED": 1,
	}
)

Enum value maps for JobFailedStatus.

View Source 
var (
	DermType_name = map[int32]string{
		0: "UNKNOWN",
		1: "MONODERM",
		2: "DIDERM",
	}
	DermType_value = map[string]int32{
		"UNKNOWN":  0,
		"MONODERM": 1,
		"DIDERM":   2,
	}
)

Enum value maps for DermType.

View Source 
var (
	RepliconTableType_name = map[int32]string{
		0: "CSV",
		1: "TSV",
	}
	RepliconTableType_value = map[string]int32{
		"CSV": 0,
		"TSV": 1,
	}
)

Enum value maps for RepliconTableType.

View Source 
var (
	JobStatusEnum_name = map[int32]string{
		0: "INIT",
		1: "RUNNING",
		2: "SUCCESSFULL",
		3: "ERROR",
	}
	JobStatusEnum_value = map[string]int32{
		"INIT":        0,
		"RUNNING":     1,
		"SUCCESSFULL": 2,
		"ERROR":       3,
	}
)

Enum value maps for JobStatusEnum.

View Source 
var BaktaJobs_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "bakta.web.api.proto.v1.BaktaJobs",
	HandlerType: (*BaktaJobsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "InitJob",
			Handler:    _BaktaJobs_InitJob_Handler,
		},
		{
			MethodName: "StartJob",
			Handler:    _BaktaJobs_StartJob_Handler,
		},
		{
			MethodName: "JobsStatus",
			Handler:    _BaktaJobs_JobsStatus_Handler,
		},
		{
			MethodName: "JobResult",
			Handler:    _BaktaJobs_JobResult_Handler,
		},
		{
			MethodName: "Version",
			Handler:    _BaktaJobs_Version_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _BaktaJobs_Delete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "bakta/web/api/proto/v1/jobs.proto",
}

BaktaJobs_ServiceDesc is the grpc.ServiceDesc for BaktaJobs service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var BaktaStatusUpdate_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "bakta.web.api.proto.v1.BaktaStatusUpdate",
	HandlerType: (*BaktaStatusUpdateServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateStatus",
			Handler:    _BaktaStatusUpdate_UpdateStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "bakta/web/api/proto/v1/status_update.proto",
}

BaktaStatusUpdate_ServiceDesc is the grpc.ServiceDesc for BaktaStatusUpdate service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_bakta_web_api_proto_v1_jobs_proto protoreflect.FileDescriptor
View Source 
var File_bakta_web_api_proto_v1_status_update_proto protoreflect.FileDescriptor

Functions

func GetSwaggerEmbedded 

func GetSwaggerEmbedded() *embed.FS

func RegisterBaktaJobsHandler 

func RegisterBaktaJobsHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterBaktaJobsHandler registers the http handlers for service BaktaJobs to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterBaktaJobsHandlerClient 

func RegisterBaktaJobsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BaktaJobsClient) error

RegisterBaktaJobsHandlerClient registers the http handlers for service BaktaJobs to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BaktaJobsClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BaktaJobsClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BaktaJobsClient" to call the correct interceptors.

func RegisterBaktaJobsHandlerFromEndpoint 

func RegisterBaktaJobsHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterBaktaJobsHandlerFromEndpoint is same as RegisterBaktaJobsHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterBaktaJobsHandlerServer 

func RegisterBaktaJobsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BaktaJobsServer) error

RegisterBaktaJobsHandlerServer registers the http handlers for service BaktaJobs to "mux". UnaryRPC :call BaktaJobsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBaktaJobsHandlerFromEndpoint instead.

func RegisterBaktaJobsServer 

func RegisterBaktaJobsServer(s grpc.ServiceRegistrar, srv BaktaJobsServer)

func RegisterBaktaStatusUpdateServer 

func RegisterBaktaStatusUpdateServer(s grpc.ServiceRegistrar, srv BaktaStatusUpdateServer)

Types

type BaktaJobsClient 

type BaktaJobsClient interface {
	InitJob(ctx context.Context, in *InitJobRequest, opts ...grpc.CallOption) (*InitJobResponse, error)
	StartJob(ctx context.Context, in *StartJobRequest, opts ...grpc.CallOption) (*Empty, error)
	JobsStatus(ctx context.Context, in *JobStatusRequestList, opts ...grpc.CallOption) (*JobStatusReponseList, error)
	JobResult(ctx context.Context, in *JobAuth, opts ...grpc.CallOption) (*JobResultResponse, error)
	Version(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VersionResponse, error)
	Delete(ctx context.Context, in *JobAuth, opts ...grpc.CallOption) (*Empty, error)
}

BaktaJobsClient is the client API for BaktaJobs service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBaktaJobsClient 

func NewBaktaJobsClient(cc grpc.ClientConnInterface) BaktaJobsClient

type BaktaJobsServer 

type BaktaJobsServer interface {
	InitJob(context.Context, *InitJobRequest) (*InitJobResponse, error)
	StartJob(context.Context, *StartJobRequest) (*Empty, error)
	JobsStatus(context.Context, *JobStatusRequestList) (*JobStatusReponseList, error)
	JobResult(context.Context, *JobAuth) (*JobResultResponse, error)
	Version(context.Context, *Empty) (*VersionResponse, error)
	Delete(context.Context, *JobAuth) (*Empty, error)
}

BaktaJobsServer is the server API for BaktaJobs service. All implementations should embed UnimplementedBaktaJobsServer for forward compatibility

type BaktaStatusUpdateClient 

type BaktaStatusUpdateClient interface {
	UpdateStatus(ctx context.Context, in *UpdateStatusRequest, opts ...grpc.CallOption) (*Empty, error)
}

BaktaStatusUpdateClient is the client API for BaktaStatusUpdate service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBaktaStatusUpdateClient 

func NewBaktaStatusUpdateClient(cc grpc.ClientConnInterface) BaktaStatusUpdateClient

type BaktaStatusUpdateServer 

type BaktaStatusUpdateServer interface {
	UpdateStatus(context.Context, *UpdateStatusRequest) (*Empty, error)
}

BaktaStatusUpdateServer is the server API for BaktaStatusUpdate service. All implementations should embed UnimplementedBaktaStatusUpdateServer for forward compatibility

type DermType 

type DermType int32
const (
	DermType_UNKNOWN  DermType = 0
	DermType_MONODERM DermType = 1
	DermType_DIDERM   DermType = 2
)

func (DermType) Descriptor 

func (DermType) Descriptor() protoreflect.EnumDescriptor

func (DermType) Enum 

func (x DermType) Enum() *DermType

func (DermType) EnumDescriptor deprecated 

func (DermType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DermType.Descriptor instead.

func (DermType) Number 

func (x DermType) Number() protoreflect.EnumNumber

func (DermType) String 

func (x DermType) String() string

func (DermType) Type 

func (DermType) Type() protoreflect.EnumType

type Empty 

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

func (*Empty) Descriptor deprecated 

func (*Empty) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type FailedJob 

type FailedJob struct {
	JobID     string          `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	JobStatus JobFailedStatus `protobuf:"varint,2,opt,name=jobStatus,proto3,enum=bakta.web.api.proto.v1.JobFailedStatus" json:"jobStatus,omitempty"`
	// contains filtered or unexported fields
}

func (*FailedJob) Descriptor deprecated 

func (*FailedJob) Descriptor() ([]byte, []int)

Deprecated: Use FailedJob.ProtoReflect.Descriptor instead.

func (*FailedJob) GetJobID 

func (x *FailedJob) GetJobID() string

func (*FailedJob) GetJobStatus 

func (x *FailedJob) GetJobStatus() JobFailedStatus

func (*FailedJob) ProtoMessage 

func (*FailedJob) ProtoMessage()

func (*FailedJob) ProtoReflect 

func (x *FailedJob) ProtoReflect() protoreflect.Message

func (*FailedJob) Reset 

func (x *FailedJob) Reset()

func (*FailedJob) String 

func (x *FailedJob) String() string

type InitJobRequest 

type InitJobRequest struct {
	RepliconTableType RepliconTableType `` /* 134-byte string literal not displayed */
	Name              string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*InitJobRequest) Descriptor deprecated 

func (*InitJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use InitJobRequest.ProtoReflect.Descriptor instead.

func (*InitJobRequest) GetName 

func (x *InitJobRequest) GetName() string

func (*InitJobRequest) GetRepliconTableType 

func (x *InitJobRequest) GetRepliconTableType() RepliconTableType

func (*InitJobRequest) ProtoMessage 

func (*InitJobRequest) ProtoMessage()

func (*InitJobRequest) ProtoReflect 

func (x *InitJobRequest) ProtoReflect() protoreflect.Message

func (*InitJobRequest) Reset 

func (x *InitJobRequest) Reset()

func (*InitJobRequest) String 

func (x *InitJobRequest) String() string

type InitJobResponse 

type InitJobResponse struct {
	UploadLinkFasta     string   `protobuf:"bytes,1,opt,name=uploadLinkFasta,proto3" json:"uploadLinkFasta,omitempty"`
	UploadLinkProdigal  string   `protobuf:"bytes,2,opt,name=uploadLinkProdigal,proto3" json:"uploadLinkProdigal,omitempty"`
	UploadLinkReplicons string   `protobuf:"bytes,3,opt,name=uploadLinkReplicons,proto3" json:"uploadLinkReplicons,omitempty"`
	Job                 *JobAuth `protobuf:"bytes,4,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*InitJobResponse) Descriptor deprecated 

func (*InitJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use InitJobResponse.ProtoReflect.Descriptor instead.

func (*InitJobResponse) GetJob 

func (x *InitJobResponse) GetJob() *JobAuth

func (*InitJobResponse) GetUploadLinkFasta 

func (x *InitJobResponse) GetUploadLinkFasta() string

func (*InitJobResponse) GetUploadLinkProdigal 

func (x *InitJobResponse) GetUploadLinkProdigal() string

func (*InitJobResponse) GetUploadLinkReplicons 

func (x *InitJobResponse) GetUploadLinkReplicons() string

func (*InitJobResponse) ProtoMessage 

func (*InitJobResponse) ProtoMessage()

func (*InitJobResponse) ProtoReflect 

func (x *InitJobResponse) ProtoReflect() protoreflect.Message

func (*InitJobResponse) Reset 

func (x *InitJobResponse) Reset()

func (*InitJobResponse) String 

func (x *InitJobResponse) String() string

type JobAuth 

type JobAuth struct {
	Secret string `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	JobID  string `protobuf:"bytes,2,opt,name=jobID,proto3" json:"jobID,omitempty"`
	// contains filtered or unexported fields
}

func (*JobAuth) Descriptor deprecated 

func (*JobAuth) Descriptor() ([]byte, []int)

Deprecated: Use JobAuth.ProtoReflect.Descriptor instead.

func (*JobAuth) GetJobID 

func (x *JobAuth) GetJobID() string

func (*JobAuth) GetSecret 

func (x *JobAuth) GetSecret() string

func (*JobAuth) ProtoMessage 

func (*JobAuth) ProtoMessage()

func (*JobAuth) ProtoReflect 

func (x *JobAuth) ProtoReflect() protoreflect.Message

func (*JobAuth) Reset 

func (x *JobAuth) Reset()

func (*JobAuth) String 

func (x *JobAuth) String() string

type JobConfig 

type JobConfig struct {
	HasProdigal        bool     `protobuf:"varint,1,opt,name=hasProdigal,proto3" json:"hasProdigal,omitempty"`
	HasReplicons       bool     `protobuf:"varint,2,opt,name=hasReplicons,proto3" json:"hasReplicons,omitempty"`
	TranslationalTable int32    `protobuf:"varint,3,opt,name=translationalTable,proto3" json:"translationalTable,omitempty"`
	CompleteGenome     bool     `protobuf:"varint,4,opt,name=completeGenome,proto3" json:"completeGenome,omitempty"`
	KeepContigHeaders  bool     `protobuf:"varint,5,opt,name=keepContigHeaders,proto3" json:"keepContigHeaders,omitempty"`
	MinContigLength    int64    `protobuf:"varint,6,opt,name=minContigLength,proto3" json:"minContigLength,omitempty"`
	DermType           DermType `protobuf:"varint,7,opt,name=dermType,proto3,enum=bakta.web.api.proto.v1.DermType" json:"dermType,omitempty"`
	Genus              string   `protobuf:"bytes,8,opt,name=genus,proto3" json:"genus,omitempty"`
	Species            string   `protobuf:"bytes,9,opt,name=species,proto3" json:"species,omitempty"`
	Strain             string   `protobuf:"bytes,10,opt,name=strain,proto3" json:"strain,omitempty"`
	Plasmid            string   `protobuf:"bytes,11,opt,name=plasmid,proto3" json:"plasmid,omitempty"`
	Locus              string   `protobuf:"bytes,12,opt,name=locus,proto3" json:"locus,omitempty"`
	LocusTag           string   `protobuf:"bytes,13,opt,name=locus_tag,json=locusTag,proto3" json:"locus_tag,omitempty"`
	Compliant          bool     `protobuf:"varint,14,opt,name=compliant,proto3" json:"compliant,omitempty"`
	// contains filtered or unexported fields
}

func (*JobConfig) Descriptor deprecated 

func (*JobConfig) Descriptor() ([]byte, []int)

Deprecated: Use JobConfig.ProtoReflect.Descriptor instead.

func (*JobConfig) GetCompleteGenome 

func (x *JobConfig) GetCompleteGenome() bool

func (*JobConfig) GetCompliant 

func (x *JobConfig) GetCompliant() bool

func (*JobConfig) GetDermType 

func (x *JobConfig) GetDermType() DermType

func (*JobConfig) GetGenus 

func (x *JobConfig) GetGenus() string

func (*JobConfig) GetHasProdigal 

func (x *JobConfig) GetHasProdigal() bool

func (*JobConfig) GetHasReplicons 

func (x *JobConfig) GetHasReplicons() bool

func (*JobConfig) GetKeepContigHeaders 

func (x *JobConfig) GetKeepContigHeaders() bool

func (*JobConfig) GetLocus 

func (x *JobConfig) GetLocus() string

func (*JobConfig) GetLocusTag 

func (x *JobConfig) GetLocusTag() string

func (*JobConfig) GetMinContigLength 

func (x *JobConfig) GetMinContigLength() int64

func (*JobConfig) GetPlasmid 

func (x *JobConfig) GetPlasmid() string

func (*JobConfig) GetSpecies 

func (x *JobConfig) GetSpecies() string

func (*JobConfig) GetStrain 

func (x *JobConfig) GetStrain() string

func (*JobConfig) GetTranslationalTable 

func (x *JobConfig) GetTranslationalTable() int32

func (*JobConfig) ProtoMessage 

func (*JobConfig) ProtoMessage()

func (*JobConfig) ProtoReflect 

func (x *JobConfig) ProtoReflect() protoreflect.Message

func (*JobConfig) Reset 

func (x *JobConfig) Reset()

func (*JobConfig) String 

func (x *JobConfig) String() string

type JobFailedStatus 

type JobFailedStatus int32
const (
	JobFailedStatus_NOT_FOUND    JobFailedStatus = 0
	JobFailedStatus_UNAUTHORIZED JobFailedStatus = 1
)

func (JobFailedStatus) Descriptor 

func (JobFailedStatus) Descriptor() protoreflect.EnumDescriptor

func (JobFailedStatus) Enum 

func (x JobFailedStatus) Enum() *JobFailedStatus

func (JobFailedStatus) EnumDescriptor deprecated 

func (JobFailedStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use JobFailedStatus.Descriptor instead.

func (JobFailedStatus) Number 

func (x JobFailedStatus) Number() protoreflect.EnumNumber

func (JobFailedStatus) String 

func (x JobFailedStatus) String() string

func (JobFailedStatus) Type 

func (JobFailedStatus) Type() protoreflect.EnumType

type JobResultResponse 

type JobResultResponse struct {
	JobID       string                 `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	ResultFiles *structpb.Struct       `protobuf:"bytes,2,opt,name=ResultFiles,proto3" json:"ResultFiles,omitempty"`
	Started     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=started,proto3" json:"started,omitempty"`
	Updated     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=updated,proto3" json:"updated,omitempty"`
	Name        string                 `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*JobResultResponse) Descriptor deprecated 

func (*JobResultResponse) Descriptor() ([]byte, []int)

Deprecated: Use JobResultResponse.ProtoReflect.Descriptor instead.

func (*JobResultResponse) GetJobID 

func (x *JobResultResponse) GetJobID() string

func (*JobResultResponse) GetName 

func (x *JobResultResponse) GetName() string

func (*JobResultResponse) GetResultFiles 

func (x *JobResultResponse) GetResultFiles() *structpb.Struct

func (*JobResultResponse) GetStarted 

func (x *JobResultResponse) GetStarted() *timestamppb.Timestamp

func (*JobResultResponse) GetUpdated 

func (x *JobResultResponse) GetUpdated() *timestamppb.Timestamp

func (*JobResultResponse) ProtoMessage 

func (*JobResultResponse) ProtoMessage()

func (*JobResultResponse) ProtoReflect 

func (x *JobResultResponse) ProtoReflect() protoreflect.Message

func (*JobResultResponse) Reset 

func (x *JobResultResponse) Reset()

func (*JobResultResponse) String 

func (x *JobResultResponse) String() string

type JobStatusEnum 

type JobStatusEnum int32
const (
	JobStatusEnum_INIT        JobStatusEnum = 0
	JobStatusEnum_RUNNING     JobStatusEnum = 1
	JobStatusEnum_SUCCESSFULL JobStatusEnum = 2
	JobStatusEnum_ERROR       JobStatusEnum = 3
)

func (JobStatusEnum) Descriptor 

func (JobStatusEnum) Descriptor() protoreflect.EnumDescriptor

func (JobStatusEnum) Enum 

func (x JobStatusEnum) Enum() *JobStatusEnum

func (JobStatusEnum) EnumDescriptor deprecated 

func (JobStatusEnum) EnumDescriptor() ([]byte, []int)

Deprecated: Use JobStatusEnum.Descriptor instead.

func (JobStatusEnum) Number 

func (x JobStatusEnum) Number() protoreflect.EnumNumber

func (JobStatusEnum) String 

func (x JobStatusEnum) String() string

func (JobStatusEnum) Type 

func (JobStatusEnum) Type() protoreflect.EnumType

type JobStatusReponseList 

type JobStatusReponseList struct {
	Jobs       []*JobStatusResponse `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	FailedJobs []*FailedJob         `protobuf:"bytes,2,rep,name=failedJobs,proto3" json:"failedJobs,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStatusReponseList) Descriptor deprecated 

func (*JobStatusReponseList) Descriptor() ([]byte, []int)

Deprecated: Use JobStatusReponseList.ProtoReflect.Descriptor instead.

func (*JobStatusReponseList) GetFailedJobs 

func (x *JobStatusReponseList) GetFailedJobs() []*FailedJob

func (*JobStatusReponseList) GetJobs 

func (x *JobStatusReponseList) GetJobs() []*JobStatusResponse

func (*JobStatusReponseList) ProtoMessage 

func (*JobStatusReponseList) ProtoMessage()

func (*JobStatusReponseList) ProtoReflect 

func (x *JobStatusReponseList) ProtoReflect() protoreflect.Message

func (*JobStatusReponseList) Reset 

func (x *JobStatusReponseList) Reset()

func (*JobStatusReponseList) String 

func (x *JobStatusReponseList) String() string

type JobStatusRequestList 

type JobStatusRequestList struct {
	Jobs []*JobAuth `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStatusRequestList) Descriptor deprecated 

func (*JobStatusRequestList) Descriptor() ([]byte, []int)

Deprecated: Use JobStatusRequestList.ProtoReflect.Descriptor instead.

func (*JobStatusRequestList) GetJobs 

func (x *JobStatusRequestList) GetJobs() []*JobAuth

func (*JobStatusRequestList) ProtoMessage 

func (*JobStatusRequestList) ProtoMessage()

func (*JobStatusRequestList) ProtoReflect 

func (x *JobStatusRequestList) ProtoReflect() protoreflect.Message

func (*JobStatusRequestList) Reset 

func (x *JobStatusRequestList) Reset()

func (*JobStatusRequestList) String 

func (x *JobStatusRequestList) String() string

type JobStatusResponse 

type JobStatusResponse struct {
	JobID     string                 `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	JobStatus JobStatusEnum          `protobuf:"varint,2,opt,name=jobStatus,proto3,enum=bakta.web.api.proto.v1.JobStatusEnum" json:"jobStatus,omitempty"`
	Started   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=started,proto3" json:"started,omitempty"`
	Updated   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=updated,proto3" json:"updated,omitempty"`
	Name      string                 `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*JobStatusResponse) Descriptor deprecated 

func (*JobStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use JobStatusResponse.ProtoReflect.Descriptor instead.

func (*JobStatusResponse) GetJobID 

func (x *JobStatusResponse) GetJobID() string

func (*JobStatusResponse) GetJobStatus 

func (x *JobStatusResponse) GetJobStatus() JobStatusEnum

func (*JobStatusResponse) GetName 

func (x *JobStatusResponse) GetName() string

func (*JobStatusResponse) GetStarted 

func (x *JobStatusResponse) GetStarted() *timestamppb.Timestamp

func (*JobStatusResponse) GetUpdated 

func (x *JobStatusResponse) GetUpdated() *timestamppb.Timestamp

func (*JobStatusResponse) ProtoMessage 

func (*JobStatusResponse) ProtoMessage()

func (*JobStatusResponse) ProtoReflect 

func (x *JobStatusResponse) ProtoReflect() protoreflect.Message

func (*JobStatusResponse) Reset 

func (x *JobStatusResponse) Reset()

func (*JobStatusResponse) String 

func (x *JobStatusResponse) String() string

type RepliconTableType 

type RepliconTableType int32
const (
	RepliconTableType_CSV RepliconTableType = 0
	RepliconTableType_TSV RepliconTableType = 1
)

func (RepliconTableType) Descriptor 

func (RepliconTableType) Descriptor() protoreflect.EnumDescriptor

func (RepliconTableType) Enum 

func (x RepliconTableType) Enum() *RepliconTableType

func (RepliconTableType) EnumDescriptor deprecated 

func (RepliconTableType) EnumDescriptor() ([]byte, []int)

Deprecated: Use RepliconTableType.Descriptor instead.

func (RepliconTableType) Number 

func (x RepliconTableType) Number() protoreflect.EnumNumber

func (RepliconTableType) String 

func (x RepliconTableType) String() string

func (RepliconTableType) Type 

func (RepliconTableType) Type() protoreflect.EnumType

type StartJobRequest 

type StartJobRequest struct {
	Job    *JobAuth   `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Config *JobConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*StartJobRequest) Descriptor deprecated 

func (*StartJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartJobRequest.ProtoReflect.Descriptor instead.

func (*StartJobRequest) GetConfig 

func (x *StartJobRequest) GetConfig() *JobConfig

func (*StartJobRequest) GetJob 

func (x *StartJobRequest) GetJob() *JobAuth

func (*StartJobRequest) ProtoMessage 

func (*StartJobRequest) ProtoMessage()

func (*StartJobRequest) ProtoReflect 

func (x *StartJobRequest) ProtoReflect() protoreflect.Message

func (*StartJobRequest) Reset 

func (x *StartJobRequest) Reset()

func (*StartJobRequest) String 

func (x *StartJobRequest) String() string

type UnimplementedBaktaJobsServer 

type UnimplementedBaktaJobsServer struct {
}

UnimplementedBaktaJobsServer should be embedded to have forward compatible implementations.

func (UnimplementedBaktaJobsServer) Delete 

func (UnimplementedBaktaJobsServer) Delete(context.Context, *JobAuth) (*Empty, error)

func (UnimplementedBaktaJobsServer) InitJob 

func (UnimplementedBaktaJobsServer) InitJob(context.Context, *InitJobRequest) (*InitJobResponse, error)

func (UnimplementedBaktaJobsServer) JobResult 

func (UnimplementedBaktaJobsServer) JobResult(context.Context, *JobAuth) (*JobResultResponse, error)

func (UnimplementedBaktaJobsServer) JobsStatus 

func (UnimplementedBaktaJobsServer) JobsStatus(context.Context, *JobStatusRequestList) (*JobStatusReponseList, error)

func (UnimplementedBaktaJobsServer) StartJob 

func (UnimplementedBaktaJobsServer) StartJob(context.Context, *StartJobRequest) (*Empty, error)

func (UnimplementedBaktaJobsServer) Version 

func (UnimplementedBaktaJobsServer) Version(context.Context, *Empty) (*VersionResponse, error)

type UnimplementedBaktaStatusUpdateServer 

type UnimplementedBaktaStatusUpdateServer struct {
}

UnimplementedBaktaStatusUpdateServer should be embedded to have forward compatible implementations.

func (UnimplementedBaktaStatusUpdateServer) UpdateStatus 

func (UnimplementedBaktaStatusUpdateServer) UpdateStatus(context.Context, *UpdateStatusRequest) (*Empty, error)

type UnsafeBaktaJobsServer 

type UnsafeBaktaJobsServer interface {
	// contains filtered or unexported methods
}

UnsafeBaktaJobsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BaktaJobsServer will result in compilation errors.

type UnsafeBaktaStatusUpdateServer 

type UnsafeBaktaStatusUpdateServer interface {
	// contains filtered or unexported methods
}

UnsafeBaktaStatusUpdateServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BaktaStatusUpdateServer will result in compilation errors.

type UpdateStatusRequest 

type UpdateStatusRequest struct {
	JobID string `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStatusRequest) Descriptor deprecated 

func (*UpdateStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateStatusRequest) GetJobID 

func (x *UpdateStatusRequest) GetJobID() string

func (*UpdateStatusRequest) ProtoMessage 

func (*UpdateStatusRequest) ProtoMessage()

func (*UpdateStatusRequest) ProtoReflect 

func (x *UpdateStatusRequest) ProtoReflect() protoreflect.Message

func (*UpdateStatusRequest) Reset 

func (x *UpdateStatusRequest) Reset()

func (*UpdateStatusRequest) String 

func (x *UpdateStatusRequest) String() string

type VersionResponse 

type VersionResponse struct {
	ToolVersion    string `protobuf:"bytes,1,opt,name=toolVersion,proto3" json:"toolVersion,omitempty"`
	DbVersion      string `protobuf:"bytes,2,opt,name=dbVersion,proto3" json:"dbVersion,omitempty"`
	BackendVersion string `protobuf:"bytes,3,opt,name=backendVersion,proto3" json:"backendVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated 

func (*VersionResponse) Descriptor() ([]byte, []int)

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetBackendVersion 

func (x *VersionResponse) GetBackendVersion() string

func (*VersionResponse) GetDbVersion 

func (x *VersionResponse) GetDbVersion() string

func (*VersionResponse) GetToolVersion 

func (x *VersionResponse) GetToolVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

func (x *VersionResponse) ProtoReflect() protoreflect.Message

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) String 

func (x *VersionResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.