jobsv1

package
v1.31.0-20221024162547... Latest Latest
Warning

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

 Go to latest Published: unknown License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_jobs_v1_jobs_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type DeclareRequest 

type DeclareRequest struct {
	Pipeline map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

--------------------------------------------- DeclareRequest used to dynamically declare pipeline -> Declare(req *jobsProto.DeclareRequest, _ *jobsProto.Empty) response `message Empty`

func (*DeclareRequest) Descriptor deprecated 

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

Deprecated: Use DeclareRequest.ProtoReflect.Descriptor instead.

func (*DeclareRequest) GetPipeline 

func (x *DeclareRequest) GetPipeline() map[string]string

func (*DeclareRequest) ProtoMessage 

func (*DeclareRequest) ProtoMessage()

func (*DeclareRequest) ProtoReflect 

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

func (*DeclareRequest) Reset 

func (x *DeclareRequest) Reset()

func (*DeclareRequest) String 

func (x *DeclareRequest) String() string

type Empty 

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

some endpoints receives nothing all endpoints returns nothing, except error

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 HeaderValue 

type HeaderValue struct {
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

HeaderValue represents []string value for the header (map[string][]string)

func (*HeaderValue) Descriptor deprecated 

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

Deprecated: Use HeaderValue.ProtoReflect.Descriptor instead.

func (*HeaderValue) GetValue 

func (x *HeaderValue) GetValue() []string

func (*HeaderValue) ProtoMessage 

func (*HeaderValue) ProtoMessage()

func (*HeaderValue) ProtoReflect 

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

func (*HeaderValue) Reset 

func (x *HeaderValue) Reset()

func (*HeaderValue) String 

func (x *HeaderValue) String() string

type Job 

type Job struct {

	// job name, usually PHP class
	Job string `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// unique job id
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// payload, might be embedded json or just byte-string
	Payload string `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// headers map[string][]string
	Headers map[string]*HeaderValue `` /* 155-byte string literal not displayed */
	// job options, contains common and driver specific fields
	Options *Options `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

Job is a main message which user might send to the RR jobs plugin

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetHeaders 

func (x *Job) GetHeaders() map[string]*HeaderValue

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetJob 

func (x *Job) GetJob() string

func (*Job) GetOptions 

func (x *Job) GetOptions() *Options

func (*Job) GetPayload 

func (x *Job) GetPayload() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type Options 

type Options struct {
	Priority int64  `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
	Pipeline string `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Delay    int64  `protobuf:"varint,3,opt,name=delay,proto3" json:"delay,omitempty"`
	// new in 2.10
	AutoAck bool `protobuf:"varint,6,opt,name=auto_ack,json=autoAck,proto3" json:"auto_ack,omitempty"`
	// --------------
	// new in 2.11 (kafka related)
	Topic     string `protobuf:"bytes,7,opt,name=topic,proto3" json:"topic,omitempty"`
	Metadata  string `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Offset    int64  `protobuf:"varint,9,opt,name=offset,proto3" json:"offset,omitempty"`
	Partition int32  `protobuf:"varint,10,opt,name=partition,proto3" json:"partition,omitempty"` // -------------
	// contains filtered or unexported fields
}

Options message represents all Jobs' options

func (*Options) Descriptor deprecated 

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

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) GetAutoAck 

func (x *Options) GetAutoAck() bool

func (*Options) GetDelay 

func (x *Options) GetDelay() int64

func (*Options) GetMetadata 

func (x *Options) GetMetadata() string

func (*Options) GetOffset 

func (x *Options) GetOffset() int64

func (*Options) GetPartition 

func (x *Options) GetPartition() int32

func (*Options) GetPipeline 

func (x *Options) GetPipeline() string

func (*Options) GetPriority 

func (x *Options) GetPriority() int64

func (*Options) GetTopic 

func (x *Options) GetTopic() string

func (*Options) ProtoMessage 

func (*Options) ProtoMessage()

func (*Options) ProtoReflect 

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

func (*Options) Reset 

func (x *Options) Reset()

func (*Options) String 

func (x *Options) String() string

type Pipelines 

type Pipelines struct {
	Pipelines []string `protobuf:"bytes,1,rep,name=pipelines,proto3" json:"pipelines,omitempty"`
	// contains filtered or unexported fields
}

--------------------------------------------- request to pause/resume/list/destroy/declare

func (*Pipelines) Descriptor deprecated 

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

Deprecated: Use Pipelines.ProtoReflect.Descriptor instead.

func (*Pipelines) GetPipelines 

func (x *Pipelines) GetPipelines() []string

func (*Pipelines) ProtoMessage 

func (*Pipelines) ProtoMessage()

func (*Pipelines) ProtoReflect 

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

func (*Pipelines) Reset 

func (x *Pipelines) Reset()

func (*Pipelines) String 

func (x *Pipelines) String() string

type PushBatchRequest 

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

batch jobs request (jobs.PushBatch RPC endpoint) -> PushBatch(j *jobsProto.PushBatchRequest, _ *jobsProto.Empty) response `message Empty`

func (*PushBatchRequest) Descriptor deprecated 

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

Deprecated: Use PushBatchRequest.ProtoReflect.Descriptor instead.

func (*PushBatchRequest) GetJobs 

func (x *PushBatchRequest) GetJobs() []*Job

func (*PushBatchRequest) ProtoMessage 

func (*PushBatchRequest) ProtoMessage()

func (*PushBatchRequest) ProtoReflect 

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

func (*PushBatchRequest) Reset 

func (x *PushBatchRequest) Reset()

func (*PushBatchRequest) String 

func (x *PushBatchRequest) String() string

type PushRequest 

type PushRequest struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

single job request (jobs.Push RPC endpoint) -> Push(j *jobsProto.PushRequest, _ *jobsProto.Empty) response `message Empty`

func (*PushRequest) Descriptor deprecated 

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

Deprecated: Use PushRequest.ProtoReflect.Descriptor instead.

func (*PushRequest) GetJob 

func (x *PushRequest) GetJob() *Job

func (*PushRequest) ProtoMessage 

func (*PushRequest) ProtoMessage()

func (*PushRequest) ProtoReflect 

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

func (*PushRequest) Reset 

func (x *PushRequest) Reset()

func (*PushRequest) String 

func (x *PushRequest) String() string

type Stat 

type Stat struct {
	Pipeline string `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Driver   string `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	Queue    string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	Active   int64  `protobuf:"varint,4,opt,name=active,proto3" json:"active,omitempty"`
	Delayed  int64  `protobuf:"varint,5,opt,name=delayed,proto3" json:"delayed,omitempty"`
	Reserved int64  `protobuf:"varint,6,opt,name=reserved,proto3" json:"reserved,omitempty"`
	Ready    bool   `protobuf:"varint,7,opt,name=ready,proto3" json:"ready,omitempty"`
	// new in 2.10.5
	Priority uint64 `protobuf:"varint,8,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

Stat used as a response for the Stats RPC call

func (*Stat) Descriptor deprecated 

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

Deprecated: Use Stat.ProtoReflect.Descriptor instead.

func (*Stat) GetActive 

func (x *Stat) GetActive() int64

func (*Stat) GetDelayed 

func (x *Stat) GetDelayed() int64

func (*Stat) GetDriver 

func (x *Stat) GetDriver() string

func (*Stat) GetPipeline 

func (x *Stat) GetPipeline() string

func (*Stat) GetPriority 

func (x *Stat) GetPriority() uint64

func (*Stat) GetQueue 

func (x *Stat) GetQueue() string

func (*Stat) GetReady 

func (x *Stat) GetReady() bool

func (*Stat) GetReserved 

func (x *Stat) GetReserved() int64

func (*Stat) ProtoMessage 

func (*Stat) ProtoMessage()

func (*Stat) ProtoReflect 

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

func (*Stat) Reset 

func (x *Stat) Reset()

func (*Stat) String 

func (x *Stat) String() string

type Stats 

type Stats struct {
	Stats []*Stat `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*Stats) Descriptor deprecated 

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

Deprecated: Use Stats.ProtoReflect.Descriptor instead.

func (*Stats) GetStats 

func (x *Stats) GetStats() []*Stat

func (*Stats) ProtoMessage 

func (*Stats) ProtoMessage()

func (*Stats) ProtoReflect 

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

func (*Stats) Reset 

func (x *Stats) Reset()

func (*Stats) String 

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