v1

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2021 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Overview

Package v1 contains types for the v1 job-manager api.

Index

Constants

This section is empty.

Variables

View Source 
var File_api_v1_ack_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_api_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_dequeue_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_enqueue_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_errors_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_job_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_pagination_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_queue_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_stats_proto protoreflect.FileDescriptor

Functions

func ErrorMessage 

func ErrorMessage(e *GenericError) string

func ErrorProto 

func ErrorProto(rerr *resource.Error) *protoError

func PaginationToResource 

func PaginationToResource(page *Pagination) *resource.Pagination

Types

type AckJobsRequest 

type AckJobsRequest struct {
	Acks []*AckJobsRequestArgs `protobuf:"bytes,1,rep,name=acks,proto3" json:"acks,omitempty"`
	// contains filtered or unexported fields
}

func (*AckJobsRequest) Descriptor deprecated 

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

Deprecated: Use AckJobsRequest.ProtoReflect.Descriptor instead.

func (*AckJobsRequest) GetAcks 

func (x *AckJobsRequest) GetAcks() []*AckJobsRequestArgs

func (*AckJobsRequest) ProtoMessage 

func (*AckJobsRequest) ProtoMessage()

func (*AckJobsRequest) ProtoReflect 

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

func (*AckJobsRequest) Reset 

func (x *AckJobsRequest) Reset()

func (*AckJobsRequest) String 

func (x *AckJobsRequest) String() string

type AckJobsRequestArgs 

type AckJobsRequestArgs struct {
	Id     string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status v1.Status `protobuf:"varint,2,opt,name=status,proto3,enum=job.v1.Status" json:"status,omitempty"`
	Data   []byte    `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Error  string    `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*AckJobsRequestArgs) Descriptor deprecated 

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

Deprecated: Use AckJobsRequestArgs.ProtoReflect.Descriptor instead.

func (*AckJobsRequestArgs) GetData 

func (x *AckJobsRequestArgs) GetData() []byte

func (*AckJobsRequestArgs) GetError 

func (x *AckJobsRequestArgs) GetError() string

func (*AckJobsRequestArgs) GetId 

func (x *AckJobsRequestArgs) GetId() string

func (*AckJobsRequestArgs) GetStatus 

func (x *AckJobsRequestArgs) GetStatus() v1.Status

func (*AckJobsRequestArgs) ProtoMessage 

func (*AckJobsRequestArgs) ProtoMessage()

func (*AckJobsRequestArgs) ProtoReflect 

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

func (*AckJobsRequestArgs) Reset 

func (x *AckJobsRequestArgs) Reset()

func (*AckJobsRequestArgs) String 

func (x *AckJobsRequestArgs) String() string

type AckJobsResponse 

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

func (*AckJobsResponse) Descriptor deprecated 

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

Deprecated: Use AckJobsResponse.ProtoReflect.Descriptor instead.

func (*AckJobsResponse) ProtoMessage 

func (*AckJobsResponse) ProtoMessage()

func (*AckJobsResponse) ProtoReflect 

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

func (*AckJobsResponse) Reset 

func (x *AckJobsResponse) Reset()

func (*AckJobsResponse) String 

func (x *AckJobsResponse) String() string

type BlockQueueRequest added in v0.4.0 

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

func (*BlockQueueRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use BlockQueueRequest.ProtoReflect.Descriptor instead.

func (*BlockQueueRequest) GetQueue added in v0.4.0 

func (x *BlockQueueRequest) GetQueue() string

func (*BlockQueueRequest) ProtoMessage added in v0.4.0 

func (*BlockQueueRequest) ProtoMessage()

func (*BlockQueueRequest) ProtoReflect added in v0.4.0 

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

func (*BlockQueueRequest) Reset added in v0.4.0 

func (x *BlockQueueRequest) Reset()

func (*BlockQueueRequest) String added in v0.4.0 

func (x *BlockQueueRequest) String() string

type BlockQueueResponse added in v0.4.0 

type BlockQueueResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockQueueResponse) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use BlockQueueResponse.ProtoReflect.Descriptor instead.

func (*BlockQueueResponse) GetOk added in v0.4.0 

func (x *BlockQueueResponse) GetOk() bool

func (*BlockQueueResponse) ProtoMessage added in v0.4.0 

func (*BlockQueueResponse) ProtoMessage()

func (*BlockQueueResponse) ProtoReflect added in v0.4.0 

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

func (*BlockQueueResponse) Reset added in v0.4.0 

func (x *BlockQueueResponse) Reset()

func (*BlockQueueResponse) String added in v0.4.0 

func (x *BlockQueueResponse) String() string

type DeleteQueueRequest added in v0.4.0 

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

func (*DeleteQueueRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use DeleteQueueRequest.ProtoReflect.Descriptor instead.

func (*DeleteQueueRequest) GetId added in v0.4.0 

func (x *DeleteQueueRequest) GetId() string

func (*DeleteQueueRequest) ProtoMessage added in v0.4.0 

func (*DeleteQueueRequest) ProtoMessage()

func (*DeleteQueueRequest) ProtoReflect added in v0.4.0 

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

func (*DeleteQueueRequest) Reset added in v0.4.0 

func (x *DeleteQueueRequest) Reset()

func (*DeleteQueueRequest) String added in v0.4.0 

func (x *DeleteQueueRequest) String() string

type DeleteQueueResponse added in v0.4.0 

type DeleteQueueResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteQueueResponse) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use DeleteQueueResponse.ProtoReflect.Descriptor instead.

func (*DeleteQueueResponse) GetOk added in v0.4.0 

func (x *DeleteQueueResponse) GetOk() bool

func (*DeleteQueueResponse) ProtoMessage added in v0.4.0 

func (*DeleteQueueResponse) ProtoMessage()

func (*DeleteQueueResponse) ProtoReflect added in v0.4.0 

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

func (*DeleteQueueResponse) Reset added in v0.4.0 

func (x *DeleteQueueResponse) Reset()

func (*DeleteQueueResponse) String added in v0.4.0 

func (x *DeleteQueueResponse) String() string

type DequeueJobsRequest 

type DequeueJobsRequest struct {
	Num       int32    `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"`
	Queues    []string `protobuf:"bytes,2,rep,name=queues,proto3" json:"queues,omitempty"`
	Selectors []string `protobuf:"bytes,3,rep,name=selectors,proto3" json:"selectors,omitempty"`
	Claims    []string `protobuf:"bytes,4,rep,name=claims,proto3" json:"claims,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueJobsRequest) Descriptor deprecated 

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

Deprecated: Use DequeueJobsRequest.ProtoReflect.Descriptor instead.

func (*DequeueJobsRequest) GetClaims 

func (x *DequeueJobsRequest) GetClaims() []string

func (*DequeueJobsRequest) GetNum 

func (x *DequeueJobsRequest) GetNum() int32

func (*DequeueJobsRequest) GetQueues 

func (x *DequeueJobsRequest) GetQueues() []string

func (*DequeueJobsRequest) GetSelectors 

func (x *DequeueJobsRequest) GetSelectors() []string

func (*DequeueJobsRequest) ProtoMessage 

func (*DequeueJobsRequest) ProtoMessage()

func (*DequeueJobsRequest) ProtoReflect 

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

func (*DequeueJobsRequest) Reset 

func (x *DequeueJobsRequest) Reset()

func (*DequeueJobsRequest) String 

func (x *DequeueJobsRequest) String() string

type DequeueJobsResponse 

type DequeueJobsResponse struct {
	Items  []*v1.Job        `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	Errors []*ErrorResponse `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*DequeueJobsResponse) Descriptor deprecated 

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

Deprecated: Use DequeueJobsResponse.ProtoReflect.Descriptor instead.

func (*DequeueJobsResponse) GetErrors 

func (x *DequeueJobsResponse) GetErrors() []*ErrorResponse

func (*DequeueJobsResponse) GetItems 

func (x *DequeueJobsResponse) GetItems() []*v1.Job

func (*DequeueJobsResponse) ProtoMessage 

func (*DequeueJobsResponse) ProtoMessage()

func (*DequeueJobsResponse) ProtoReflect 

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

func (*DequeueJobsResponse) Reset 

func (x *DequeueJobsResponse) Reset()

func (*DequeueJobsResponse) String 

func (x *DequeueJobsResponse) String() string

type EnqueueJobsRequest 

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

func (*EnqueueJobsRequest) Descriptor deprecated 

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

Deprecated: Use EnqueueJobsRequest.ProtoReflect.Descriptor instead.

func (*EnqueueJobsRequest) GetJobs 

func (x *EnqueueJobsRequest) GetJobs() []*EnqueueJobsRequestArgs

func (*EnqueueJobsRequest) ProtoMessage 

func (*EnqueueJobsRequest) ProtoMessage()

func (*EnqueueJobsRequest) ProtoReflect 

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

func (*EnqueueJobsRequest) Reset 

func (x *EnqueueJobsRequest) Reset()

func (*EnqueueJobsRequest) String 

func (x *EnqueueJobsRequest) String() string

type EnqueueJobsRequestArgs 

type EnqueueJobsRequestArgs struct {
	Job  string   `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Args []byte   `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	Data *v1.Data `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*EnqueueJobsRequestArgs) Descriptor deprecated 

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

Deprecated: Use EnqueueJobsRequestArgs.ProtoReflect.Descriptor instead.

func (*EnqueueJobsRequestArgs) GetArgs 

func (x *EnqueueJobsRequestArgs) GetArgs() []byte

func (*EnqueueJobsRequestArgs) GetData 

func (x *EnqueueJobsRequestArgs) GetData() *v1.Data

func (*EnqueueJobsRequestArgs) GetJob 

func (x *EnqueueJobsRequestArgs) GetJob() string

func (*EnqueueJobsRequestArgs) ProtoMessage 

func (*EnqueueJobsRequestArgs) ProtoMessage()

func (*EnqueueJobsRequestArgs) ProtoReflect 

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

func (*EnqueueJobsRequestArgs) Reset 

func (x *EnqueueJobsRequestArgs) Reset()

func (*EnqueueJobsRequestArgs) String 

func (x *EnqueueJobsRequestArgs) String() string

type EnqueueJobsResponse 

type EnqueueJobsResponse struct {
	Jobs   []string         `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	Errors []*ErrorResponse `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*EnqueueJobsResponse) Descriptor deprecated 

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

Deprecated: Use EnqueueJobsResponse.ProtoReflect.Descriptor instead.

func (*EnqueueJobsResponse) GetErrors 

func (x *EnqueueJobsResponse) GetErrors() []*ErrorResponse

func (*EnqueueJobsResponse) GetJobs 

func (x *EnqueueJobsResponse) GetJobs() []string

func (*EnqueueJobsResponse) ProtoMessage 

func (*EnqueueJobsResponse) ProtoMessage()

func (*EnqueueJobsResponse) ProtoReflect 

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

func (*EnqueueJobsResponse) Reset 

func (x *EnqueueJobsResponse) Reset()

func (*EnqueueJobsResponse) String 

func (x *EnqueueJobsResponse) String() string

type ErrorResponse 

type ErrorResponse struct {

	// Types that are assignable to ErrorResponse:
	//	*ErrorResponse_Error
	//	*ErrorResponse_Invalid
	ErrorResponse isErrorResponse_ErrorResponse `protobuf_oneof:"error_response"`
	// contains filtered or unexported fields
}

func (*ErrorResponse) Descriptor deprecated 

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

Deprecated: Use ErrorResponse.ProtoReflect.Descriptor instead.

func (*ErrorResponse) GetError 

func (x *ErrorResponse) GetError() *GenericError

func (*ErrorResponse) GetErrorResponse 

func (m *ErrorResponse) GetErrorResponse() isErrorResponse_ErrorResponse

func (*ErrorResponse) GetInvalid 

func (x *ErrorResponse) GetInvalid() *ValidationErrorResponse

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) ProtoReflect 

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

func (*ErrorResponse) Reset 

func (x *ErrorResponse) Reset()

func (*ErrorResponse) String 

func (x *ErrorResponse) String() string

type ErrorResponse_Error 

type ErrorResponse_Error struct {
	Error *GenericError `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type ErrorResponse_Invalid 

type ErrorResponse_Invalid struct {
	Invalid *ValidationErrorResponse `protobuf:"bytes,2,opt,name=invalid,proto3,oneof"`
}

type GenericError 

type GenericError struct {
	Kind       string             `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Message    string             `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Resource   string             `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	ResourceId string             `protobuf:"bytes,4,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	Reason     string             `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	Ids        []string           `protobuf:"bytes,6,rep,name=ids,proto3" json:"ids,omitempty"`
	Invalid    []*ValidationError `protobuf:"bytes,7,rep,name=invalid,proto3" json:"invalid,omitempty"`
	// contains filtered or unexported fields
}

func (*GenericError) Descriptor deprecated 

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

Deprecated: Use GenericError.ProtoReflect.Descriptor instead.

func (*GenericError) GetIds 

func (x *GenericError) GetIds() []string

func (*GenericError) GetInvalid 

func (x *GenericError) GetInvalid() []*ValidationError

func (*GenericError) GetKind 

func (x *GenericError) GetKind() string

func (*GenericError) GetMessage 

func (x *GenericError) GetMessage() string

func (*GenericError) GetReason 

func (x *GenericError) GetReason() string

func (*GenericError) GetResource 

func (x *GenericError) GetResource() string

func (*GenericError) GetResourceId 

func (x *GenericError) GetResourceId() string

func (*GenericError) ProtoMessage 

func (*GenericError) ProtoMessage()

func (*GenericError) ProtoReflect 

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

func (*GenericError) Reset 

func (x *GenericError) Reset()

func (*GenericError) String 

func (x *GenericError) String() string

type GetJobRequest 

type GetJobRequest struct {
	Id      string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Include []string `protobuf:"bytes,2,rep,name=include,proto3" json:"include,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetId 

func (x *GetJobRequest) GetId() string

func (*GetJobRequest) GetInclude 

func (x *GetJobRequest) GetInclude() []string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

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

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetQueueRequest 

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

func (*GetQueueRequest) Descriptor deprecated 

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

Deprecated: Use GetQueueRequest.ProtoReflect.Descriptor instead.

func (*GetQueueRequest) GetId 

func (x *GetQueueRequest) GetId() string

func (*GetQueueRequest) ProtoMessage 

func (*GetQueueRequest) ProtoMessage()

func (*GetQueueRequest) ProtoReflect 

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

func (*GetQueueRequest) Reset 

func (x *GetQueueRequest) Reset()

func (*GetQueueRequest) String 

func (x *GetQueueRequest) String() string

type GetQueueResponse 

type GetQueueResponse struct {
	Data *v1.Queue `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetQueueResponse) Descriptor deprecated 

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

Deprecated: Use GetQueueResponse.ProtoReflect.Descriptor instead.

func (*GetQueueResponse) GetData 

func (x *GetQueueResponse) GetData() *v1.Queue

func (*GetQueueResponse) ProtoMessage 

func (*GetQueueResponse) ProtoMessage()

func (*GetQueueResponse) ProtoReflect 

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

func (*GetQueueResponse) Reset 

func (x *GetQueueResponse) Reset()

func (*GetQueueResponse) String 

func (x *GetQueueResponse) String() string

type ListJobsRequest 

type ListJobsRequest struct {
	Queue        []string             `protobuf:"bytes,1,rep,name=queue,proto3" json:"queue,omitempty"`
	Status       []string             `protobuf:"bytes,2,rep,name=status,proto3" json:"status,omitempty"`
	Selector     []string             `protobuf:"bytes,3,rep,name=selector,proto3" json:"selector,omitempty"`
	Claim        []string             `protobuf:"bytes,4,rep,name=claim,proto3" json:"claim,omitempty"`
	NoUnclaimed  bool                 `protobuf:"varint,5,opt,name=no_unclaimed,json=noUnclaimed,proto3" json:"no_unclaimed,omitempty"`
	CreatedSince *timestamp.Timestamp `protobuf:"bytes,6,opt,name=created_since,json=createdSince,proto3" json:"created_since,omitempty"`
	CreatedUntil *timestamp.Timestamp `protobuf:"bytes,7,opt,name=created_until,json=createdUntil,proto3" json:"created_until,omitempty"`
	Page         *Pagination          `protobuf:"bytes,8,opt,name=page,proto3" json:"page,omitempty"`
	Include      []string             `protobuf:"bytes,9,rep,name=include,proto3" json:"include,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsRequest) Descriptor deprecated 

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetClaim 

func (x *ListJobsRequest) GetClaim() []string

func (*ListJobsRequest) GetCreatedSince 

func (x *ListJobsRequest) GetCreatedSince() *timestamp.Timestamp

func (*ListJobsRequest) GetCreatedUntil 

func (x *ListJobsRequest) GetCreatedUntil() *timestamp.Timestamp

func (*ListJobsRequest) GetInclude 

func (x *ListJobsRequest) GetInclude() []string

func (*ListJobsRequest) GetNoUnclaimed 

func (x *ListJobsRequest) GetNoUnclaimed() bool

func (*ListJobsRequest) GetPage 

func (x *ListJobsRequest) GetPage() *Pagination

func (*ListJobsRequest) GetQueue 

func (x *ListJobsRequest) GetQueue() []string

func (*ListJobsRequest) GetSelector 

func (x *ListJobsRequest) GetSelector() []string

func (*ListJobsRequest) GetStatus 

func (x *ListJobsRequest) GetStatus() []string

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect 

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

func (*ListJobsRequest) Reset 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (x *ListJobsRequest) String() string

type ListJobsResponse 

type ListJobsResponse struct {
	Items  []*v1.Job        `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	Errors []*ErrorResponse `protobuf:"bytes,2,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsResponse) Descriptor deprecated 

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

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetErrors 

func (x *ListJobsResponse) GetErrors() []*ErrorResponse

func (*ListJobsResponse) GetItems 

func (x *ListJobsResponse) GetItems() []*v1.Job

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect 

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

func (*ListJobsResponse) Reset 

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (x *ListJobsResponse) String() string

type ListQueuesRequest 

type ListQueuesRequest struct {
	Names     []string    `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
	Selectors []string    `protobuf:"bytes,2,rep,name=selectors,proto3" json:"selectors,omitempty"`
	Page      *Pagination `protobuf:"bytes,3,opt,name=page,proto3" json:"page,omitempty"`
	Include   []string    `protobuf:"bytes,4,rep,name=include,proto3" json:"include,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuesRequest) Descriptor deprecated 

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

Deprecated: Use ListQueuesRequest.ProtoReflect.Descriptor instead.

func (*ListQueuesRequest) GetInclude 

func (x *ListQueuesRequest) GetInclude() []string

func (*ListQueuesRequest) GetNames 

func (x *ListQueuesRequest) GetNames() []string

func (*ListQueuesRequest) GetPage 

func (x *ListQueuesRequest) GetPage() *Pagination

func (*ListQueuesRequest) GetSelectors 

func (x *ListQueuesRequest) GetSelectors() []string

func (*ListQueuesRequest) ProtoMessage 

func (*ListQueuesRequest) ProtoMessage()

func (*ListQueuesRequest) ProtoReflect 

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

func (*ListQueuesRequest) Reset 

func (x *ListQueuesRequest) Reset()

func (*ListQueuesRequest) String 

func (x *ListQueuesRequest) String() string

type ListQueuesResponse 

type ListQueuesResponse struct {
	Items []*v1.Queue `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuesResponse) Descriptor deprecated 

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

Deprecated: Use ListQueuesResponse.ProtoReflect.Descriptor instead.

func (*ListQueuesResponse) GetItems 

func (x *ListQueuesResponse) GetItems() []*v1.Queue

func (*ListQueuesResponse) ProtoMessage 

func (*ListQueuesResponse) ProtoMessage()

func (*ListQueuesResponse) ProtoReflect 

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

func (*ListQueuesResponse) Reset 

func (x *ListQueuesResponse) Reset()

func (*ListQueuesResponse) String 

func (x *ListQueuesResponse) String() string

type Pagination 

type Pagination struct {
	Limit  int64  `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	LastId string `protobuf:"bytes,2,opt,name=last_id,json=lastId,proto3" json:"last_id,omitempty"`
	// contains filtered or unexported fields
}

func PaginationToProto 

func PaginationToProto(page *resource.Pagination) *Pagination

func (*Pagination) Descriptor deprecated 

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

Deprecated: Use Pagination.ProtoReflect.Descriptor instead.

func (*Pagination) GetLastId 

func (x *Pagination) GetLastId() string

func (*Pagination) GetLimit 

func (x *Pagination) GetLimit() int64

func (*Pagination) ProtoMessage 

func (*Pagination) ProtoMessage()

func (*Pagination) ProtoReflect 

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

func (*Pagination) Reset 

func (x *Pagination) Reset()

func (*Pagination) String 

func (x *Pagination) String() string

type PauseQueueRequest added in v0.4.0 

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

func (*PauseQueueRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use PauseQueueRequest.ProtoReflect.Descriptor instead.

func (*PauseQueueRequest) GetQueue added in v0.4.0 

func (x *PauseQueueRequest) GetQueue() string

func (*PauseQueueRequest) ProtoMessage added in v0.4.0 

func (*PauseQueueRequest) ProtoMessage()

func (*PauseQueueRequest) ProtoReflect added in v0.4.0 

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

func (*PauseQueueRequest) Reset added in v0.4.0 

func (x *PauseQueueRequest) Reset()

func (*PauseQueueRequest) String added in v0.4.0 

func (x *PauseQueueRequest) String() string

type PauseQueueResponse added in v0.4.0 

type PauseQueueResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*PauseQueueResponse) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use PauseQueueResponse.ProtoReflect.Descriptor instead.

func (*PauseQueueResponse) GetOk added in v0.4.0 

func (x *PauseQueueResponse) GetOk() bool

func (*PauseQueueResponse) ProtoMessage added in v0.4.0 

func (*PauseQueueResponse) ProtoMessage()

func (*PauseQueueResponse) ProtoReflect added in v0.4.0 

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

func (*PauseQueueResponse) Reset added in v0.4.0 

func (x *PauseQueueResponse) Reset()

func (*PauseQueueResponse) String added in v0.4.0 

func (x *PauseQueueResponse) String() string

type SaveQueueParamArgs 

type SaveQueueParamArgs struct {
	Name                   string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	V                      int32              `protobuf:"varint,2,opt,name=v,proto3" json:"v,omitempty"`
	MaxRetries             int32              `protobuf:"varint,3,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	Duration               *duration.Duration `protobuf:"bytes,4,opt,name=duration,proto3" json:"duration,omitempty"`
	ClaimDuration          *duration.Duration `protobuf:"bytes,5,opt,name=claim_duration,json=claimDuration,proto3" json:"claim_duration,omitempty"`
	CheckinDuration        *duration.Duration `protobuf:"bytes,6,opt,name=checkin_duration,json=checkinDuration,proto3" json:"checkin_duration,omitempty"`
	Labels                 map[string]string  `` /* 153-byte string literal not displayed */
	Schema                 []byte             `protobuf:"bytes,8,opt,name=schema,proto3" json:"schema,omitempty"`
	Unique                 bool               `protobuf:"varint,9,opt,name=unique,proto3" json:"unique,omitempty"`
	BackoffInitialDuration *duration.Duration `` /* 130-byte string literal not displayed */
	BackoffMaxDuration     *duration.Duration `protobuf:"bytes,11,opt,name=backoff_max_duration,json=backoffMaxDuration,proto3" json:"backoff_max_duration,omitempty"`
	BackoffFactor          float32            `protobuf:"fixed32,12,opt,name=backoff_factor,json=backoffFactor,proto3" json:"backoff_factor,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveQueueParamArgs) Descriptor deprecated 

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

Deprecated: Use SaveQueueParamArgs.ProtoReflect.Descriptor instead.

func (*SaveQueueParamArgs) GetBackoffFactor 

func (x *SaveQueueParamArgs) GetBackoffFactor() float32

func (*SaveQueueParamArgs) GetBackoffInitialDuration 

func (x *SaveQueueParamArgs) GetBackoffInitialDuration() *duration.Duration

func (*SaveQueueParamArgs) GetBackoffMaxDuration 

func (x *SaveQueueParamArgs) GetBackoffMaxDuration() *duration.Duration

func (*SaveQueueParamArgs) GetCheckinDuration 

func (x *SaveQueueParamArgs) GetCheckinDuration() *duration.Duration

func (*SaveQueueParamArgs) GetClaimDuration 

func (x *SaveQueueParamArgs) GetClaimDuration() *duration.Duration

func (*SaveQueueParamArgs) GetDuration 

func (x *SaveQueueParamArgs) GetDuration() *duration.Duration

func (*SaveQueueParamArgs) GetLabels 

func (x *SaveQueueParamArgs) GetLabels() map[string]string

func (*SaveQueueParamArgs) GetMaxRetries 

func (x *SaveQueueParamArgs) GetMaxRetries() int32

func (*SaveQueueParamArgs) GetName 

func (x *SaveQueueParamArgs) GetName() string

func (*SaveQueueParamArgs) GetSchema 

func (x *SaveQueueParamArgs) GetSchema() []byte

func (*SaveQueueParamArgs) GetUnique 

func (x *SaveQueueParamArgs) GetUnique() bool

func (*SaveQueueParamArgs) GetV 

func (x *SaveQueueParamArgs) GetV() int32

func (*SaveQueueParamArgs) ProtoMessage 

func (*SaveQueueParamArgs) ProtoMessage()

func (*SaveQueueParamArgs) ProtoReflect 

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

func (*SaveQueueParamArgs) Reset 

func (x *SaveQueueParamArgs) Reset()

func (*SaveQueueParamArgs) String 

func (x *SaveQueueParamArgs) String() string

type SaveQueueRequest 

type SaveQueueRequest struct {
	Queues []*SaveQueueParamArgs `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveQueueRequest) Descriptor deprecated 

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

Deprecated: Use SaveQueueRequest.ProtoReflect.Descriptor instead.

func (*SaveQueueRequest) GetQueues 

func (x *SaveQueueRequest) GetQueues() []*SaveQueueParamArgs

func (*SaveQueueRequest) ProtoMessage 

func (*SaveQueueRequest) ProtoMessage()

func (*SaveQueueRequest) ProtoReflect 

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

func (*SaveQueueRequest) Reset 

func (x *SaveQueueRequest) Reset()

func (*SaveQueueRequest) String 

func (x *SaveQueueRequest) String() string

type SaveQueueResponse 

type SaveQueueResponse struct {
	Queue *v1.Queue `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveQueueResponse) Descriptor deprecated 

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

Deprecated: Use SaveQueueResponse.ProtoReflect.Descriptor instead.

func (*SaveQueueResponse) GetQueue 

func (x *SaveQueueResponse) GetQueue() *v1.Queue

func (*SaveQueueResponse) ProtoMessage 

func (*SaveQueueResponse) ProtoMessage()

func (*SaveQueueResponse) ProtoReflect 

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

func (*SaveQueueResponse) Reset 

func (x *SaveQueueResponse) Reset()

func (*SaveQueueResponse) String 

func (x *SaveQueueResponse) String() string

type StatsRequest 

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

func (*StatsRequest) Descriptor deprecated 

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

Deprecated: Use StatsRequest.ProtoReflect.Descriptor instead.

func (*StatsRequest) ProtoMessage 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) ProtoReflect 

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

func (*StatsRequest) Reset 

func (x *StatsRequest) Reset()

func (*StatsRequest) String 

func (x *StatsRequest) String() string

type StatsResponse 

type StatsResponse struct {
	Queued               int64 `protobuf:"varint,1,opt,name=queued,proto3" json:"queued,omitempty"`
	Running              int64 `protobuf:"varint,2,opt,name=running,proto3" json:"running,omitempty"`
	Complete             int64 `protobuf:"varint,3,opt,name=complete,proto3" json:"complete,omitempty"`
	Dead                 int64 `protobuf:"varint,4,opt,name=dead,proto3" json:"dead,omitempty"`
	Cancelled            int64 `protobuf:"varint,5,opt,name=cancelled,proto3" json:"cancelled,omitempty"`
	Invalid              int64 `protobuf:"varint,6,opt,name=invalid,proto3" json:"invalid,omitempty"`
	Failed               int64 `protobuf:"varint,7,opt,name=failed,proto3" json:"failed,omitempty"`
	LongestUnstartedSecs int64 `protobuf:"varint,8,opt,name=longest_unstarted_secs,json=longestUnstartedSecs,proto3" json:"longest_unstarted_secs,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsResponse) Descriptor deprecated 

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

Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.

func (*StatsResponse) GetCancelled 

func (x *StatsResponse) GetCancelled() int64

func (*StatsResponse) GetComplete 

func (x *StatsResponse) GetComplete() int64

func (*StatsResponse) GetDead 

func (x *StatsResponse) GetDead() int64

func (*StatsResponse) GetFailed 

func (x *StatsResponse) GetFailed() int64

func (*StatsResponse) GetInvalid 

func (x *StatsResponse) GetInvalid() int64

func (*StatsResponse) GetLongestUnstartedSecs 

func (x *StatsResponse) GetLongestUnstartedSecs() int64

func (*StatsResponse) GetQueued 

func (x *StatsResponse) GetQueued() int64

func (*StatsResponse) GetRunning 

func (x *StatsResponse) GetRunning() int64

func (*StatsResponse) ProtoMessage 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) ProtoReflect 

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

func (*StatsResponse) Reset 

func (x *StatsResponse) Reset()

func (*StatsResponse) String 

func (x *StatsResponse) String() string

type UnblockQueueRequest added in v0.4.0 

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

func (*UnblockQueueRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use UnblockQueueRequest.ProtoReflect.Descriptor instead.

func (*UnblockQueueRequest) GetQueue added in v0.4.0 

func (x *UnblockQueueRequest) GetQueue() string

func (*UnblockQueueRequest) ProtoMessage added in v0.4.0 

func (*UnblockQueueRequest) ProtoMessage()

func (*UnblockQueueRequest) ProtoReflect added in v0.4.0 

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

func (*UnblockQueueRequest) Reset added in v0.4.0 

func (x *UnblockQueueRequest) Reset()

func (*UnblockQueueRequest) String added in v0.4.0 

func (x *UnblockQueueRequest) String() string

type UnblockQueueResponse added in v0.4.0 

type UnblockQueueResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*UnblockQueueResponse) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use UnblockQueueResponse.ProtoReflect.Descriptor instead.

func (*UnblockQueueResponse) GetOk added in v0.4.0 

func (x *UnblockQueueResponse) GetOk() bool

func (*UnblockQueueResponse) ProtoMessage added in v0.4.0 

func (*UnblockQueueResponse) ProtoMessage()

func (*UnblockQueueResponse) ProtoReflect added in v0.4.0 

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

func (*UnblockQueueResponse) Reset added in v0.4.0 

func (x *UnblockQueueResponse) Reset()

func (*UnblockQueueResponse) String added in v0.4.0 

func (x *UnblockQueueResponse) String() string

type UnpauseQueueRequest added in v0.4.0 

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

func (*UnpauseQueueRequest) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use UnpauseQueueRequest.ProtoReflect.Descriptor instead.

func (*UnpauseQueueRequest) GetQueue added in v0.4.0 

func (x *UnpauseQueueRequest) GetQueue() string

func (*UnpauseQueueRequest) ProtoMessage added in v0.4.0 

func (*UnpauseQueueRequest) ProtoMessage()

func (*UnpauseQueueRequest) ProtoReflect added in v0.4.0 

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

func (*UnpauseQueueRequest) Reset added in v0.4.0 

func (x *UnpauseQueueRequest) Reset()

func (*UnpauseQueueRequest) String added in v0.4.0 

func (x *UnpauseQueueRequest) String() string

type UnpauseQueueResponse added in v0.4.0 

type UnpauseQueueResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*UnpauseQueueResponse) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use UnpauseQueueResponse.ProtoReflect.Descriptor instead.

func (*UnpauseQueueResponse) GetOk added in v0.4.0 

func (x *UnpauseQueueResponse) GetOk() bool

func (*UnpauseQueueResponse) ProtoMessage added in v0.4.0 

func (*UnpauseQueueResponse) ProtoMessage()

func (*UnpauseQueueResponse) ProtoReflect added in v0.4.0 

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

func (*UnpauseQueueResponse) Reset added in v0.4.0 

func (x *UnpauseQueueResponse) Reset()

func (*UnpauseQueueResponse) String added in v0.4.0 

func (x *UnpauseQueueResponse) String() string

type ValidationError 

type ValidationError struct {
	Path    string         `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Message string         `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Value   *_struct.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidationError) Descriptor deprecated 

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

Deprecated: Use ValidationError.ProtoReflect.Descriptor instead.

func (*ValidationError) GetMessage 

func (x *ValidationError) GetMessage() string

func (*ValidationError) GetPath 

func (x *ValidationError) GetPath() string

func (*ValidationError) GetValue 

func (x *ValidationError) GetValue() *_struct.Value

func (*ValidationError) ProtoMessage 

func (*ValidationError) ProtoMessage()

func (*ValidationError) ProtoReflect 

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

func (*ValidationError) Reset 

func (x *ValidationError) Reset()

func (*ValidationError) String 

func (x *ValidationError) String() string

type ValidationErrorArg 

type ValidationErrorArg struct {
	Path    string         `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Message string         `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Value   *_struct.Value `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidationErrorArg) Descriptor deprecated 

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

Deprecated: Use ValidationErrorArg.ProtoReflect.Descriptor instead.

func (*ValidationErrorArg) GetMessage 

func (x *ValidationErrorArg) GetMessage() string

func (*ValidationErrorArg) GetPath 

func (x *ValidationErrorArg) GetPath() string

func (*ValidationErrorArg) GetValue 

func (x *ValidationErrorArg) GetValue() *_struct.Value

func (*ValidationErrorArg) ProtoMessage 

func (*ValidationErrorArg) ProtoMessage()

func (*ValidationErrorArg) ProtoReflect 

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

func (*ValidationErrorArg) Reset 

func (x *ValidationErrorArg) Reset()

func (*ValidationErrorArg) String 

func (x *ValidationErrorArg) String() string

type ValidationErrorResponse 

type ValidationErrorResponse struct {
	Errs []*ValidationErrorArg `protobuf:"bytes,1,rep,name=errs,proto3" json:"errs,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidationErrorResponse) Descriptor deprecated 

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

Deprecated: Use ValidationErrorResponse.ProtoReflect.Descriptor instead.

func (*ValidationErrorResponse) GetErrs 

func (x *ValidationErrorResponse) GetErrs() []*ValidationErrorArg

func (*ValidationErrorResponse) ProtoMessage 

func (*ValidationErrorResponse) ProtoMessage()

func (*ValidationErrorResponse) ProtoReflect 

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

func (*ValidationErrorResponse) Reset 

func (x *ValidationErrorResponse) Reset()

func (*ValidationErrorResponse) String 

func (x *ValidationErrorResponse) 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.