queues_queues

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2018 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Queue_Unit_name = map[int32]string{
	0: "UNIT_UNKNOWN",
	1: "UNIT_SECONDS",
	2: "UNIT_MINUTES",
}
View Source 
var Queue_Unit_value = map[string]int32{
	"UNIT_UNKNOWN": 0,
	"UNIT_SECONDS": 1,
	"UNIT_MINUTES": 2,
}

Functions

func RegisterQueuesServiceServer 

func RegisterQueuesServiceServer(s *grpc.Server, srv QueuesServiceServer)

Types

type Ack 

type Ack struct {
	// Código de la tarea que confirmamos.
	Code string `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"`
	// Tag para indicar si la tarea se ha completado correctamente.
	Success              bool     `protobuf:"varint,4,opt,name=success,proto3" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ack) Descriptor 

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

func (*Ack) GetCode 

func (m *Ack) GetCode() string

func (*Ack) GetSuccess 

func (m *Ack) GetSuccess() bool

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) Reset 

func (m *Ack) Reset()

func (*Ack) String 

func (m *Ack) String() string

func (*Ack) XXX_DiscardUnknown 

func (m *Ack) XXX_DiscardUnknown()

func (*Ack) XXX_Marshal 

func (m *Ack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ack) XXX_Merge 

func (m *Ack) XXX_Merge(src proto.Message)

func (*Ack) XXX_Size 

func (m *Ack) XXX_Size() int

func (*Ack) XXX_Unmarshal 

func (m *Ack) XXX_Unmarshal(b []byte) error

type ListReply 

type ListReply struct {
	Queues               []*Queue `protobuf:"bytes,2,rep,name=queues,proto3" json:"queues,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListReply) Descriptor 

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

func (*ListReply) GetQueues 

func (m *ListReply) GetQueues() []*Queue

func (*ListReply) ProtoMessage 

func (*ListReply) ProtoMessage()

func (*ListReply) Reset 

func (m *ListReply) Reset()

func (*ListReply) String 

func (m *ListReply) String() string

func (*ListReply) XXX_DiscardUnknown 

func (m *ListReply) XXX_DiscardUnknown()

func (*ListReply) XXX_Marshal 

func (m *ListReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListReply) XXX_Merge 

func (m *ListReply) XXX_Merge(src proto.Message)

func (*ListReply) XXX_Size 

func (m *ListReply) XXX_Size() int

func (*ListReply) XXX_Unmarshal 

func (m *ListReply) XXX_Unmarshal(b []byte) error

type ListRequest 

type ListRequest struct {
	// Código de proyecto.
	Project              string   `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) GetProject 

func (m *ListRequest) GetProject() string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRequest) XXX_Merge 

func (m *ListRequest) XXX_Merge(src proto.Message)

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

func (m *ListRequest) XXX_Unmarshal(b []byte) error

type ListTasksReply 

type ListTasksReply struct {
	// Listado de máximo 30 elementos de las próximas tareas que se van a ejecutar
	// en la cola que hemos pedido.
	Tasks                []*Task  `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTasksReply) Descriptor 

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

func (*ListTasksReply) GetTasks 

func (m *ListTasksReply) GetTasks() []*Task

func (*ListTasksReply) ProtoMessage 

func (*ListTasksReply) ProtoMessage()

func (*ListTasksReply) Reset 

func (m *ListTasksReply) Reset()

func (*ListTasksReply) String 

func (m *ListTasksReply) String() string

func (*ListTasksReply) XXX_DiscardUnknown 

func (m *ListTasksReply) XXX_DiscardUnknown()

func (*ListTasksReply) XXX_Marshal 

func (m *ListTasksReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTasksReply) XXX_Merge 

func (m *ListTasksReply) XXX_Merge(src proto.Message)

func (*ListTasksReply) XXX_Size 

func (m *ListTasksReply) XXX_Size() int

func (*ListTasksReply) XXX_Unmarshal 

func (m *ListTasksReply) XXX_Unmarshal(b []byte) error

type ListTasksRequest 

type ListTasksRequest struct {
	// Código de proyecto.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Nombre de la cola.
	QueueName            string   `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTasksRequest) Descriptor 

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

func (*ListTasksRequest) GetProject 

func (m *ListTasksRequest) GetProject() string

func (*ListTasksRequest) GetQueueName 

func (m *ListTasksRequest) GetQueueName() string

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) Reset 

func (m *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (m *ListTasksRequest) String() string

func (*ListTasksRequest) XXX_DiscardUnknown 

func (m *ListTasksRequest) XXX_DiscardUnknown()

func (*ListTasksRequest) XXX_Marshal 

func (m *ListTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTasksRequest) XXX_Merge 

func (m *ListTasksRequest) XXX_Merge(src proto.Message)

func (*ListTasksRequest) XXX_Size 

func (m *ListTasksRequest) XXX_Size() int

func (*ListTasksRequest) XXX_Unmarshal 

func (m *ListTasksRequest) XXX_Unmarshal(b []byte) error

type ListenInitial 

type ListenInitial struct {
	// Código de proyecto.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Nombre de la cola.
	QueueName            string   `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListenInitial) Descriptor 

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

func (*ListenInitial) GetProject 

func (m *ListenInitial) GetProject() string

func (*ListenInitial) GetQueueName 

func (m *ListenInitial) GetQueueName() string

func (*ListenInitial) ProtoMessage 

func (*ListenInitial) ProtoMessage()

func (*ListenInitial) Reset 

func (m *ListenInitial) Reset()

func (*ListenInitial) String 

func (m *ListenInitial) String() string

func (*ListenInitial) XXX_DiscardUnknown 

func (m *ListenInitial) XXX_DiscardUnknown()

func (*ListenInitial) XXX_Marshal 

func (m *ListenInitial) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenInitial) XXX_Merge 

func (m *ListenInitial) XXX_Merge(src proto.Message)

func (*ListenInitial) XXX_Size 

func (m *ListenInitial) XXX_Size() int

func (*ListenInitial) XXX_Unmarshal 

func (m *ListenInitial) XXX_Unmarshal(b []byte) error

type ListenReply 

type ListenReply struct {
	// Tarea que debe ejecutar el worker.
	Task                 *Task    `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListenReply) Descriptor 

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

func (*ListenReply) GetTask 

func (m *ListenReply) GetTask() *Task

func (*ListenReply) ProtoMessage 

func (*ListenReply) ProtoMessage()

func (*ListenReply) Reset 

func (m *ListenReply) Reset()

func (*ListenReply) String 

func (m *ListenReply) String() string

func (*ListenReply) XXX_DiscardUnknown 

func (m *ListenReply) XXX_DiscardUnknown()

func (*ListenReply) XXX_Marshal 

func (m *ListenReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenReply) XXX_Merge 

func (m *ListenReply) XXX_Merge(src proto.Message)

func (*ListenReply) XXX_Size 

func (m *ListenReply) XXX_Size() int

func (*ListenReply) XXX_Unmarshal 

func (m *ListenReply) XXX_Unmarshal(b []byte) error

type ListenRequest 

type ListenRequest struct {
	// Types that are valid to be assigned to Request:
	//  *ListenRequest_Initial
	//  *ListenRequest_Ack
	Request              isListenRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ListenRequest) Descriptor 

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

func (*ListenRequest) GetAck 

func (m *ListenRequest) GetAck() *Ack

func (*ListenRequest) GetInitial 

func (m *ListenRequest) GetInitial() *ListenInitial

func (*ListenRequest) GetRequest 

func (m *ListenRequest) GetRequest() isListenRequest_Request

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset 

func (m *ListenRequest) Reset()

func (*ListenRequest) String 

func (m *ListenRequest) String() string

func (*ListenRequest) XXX_DiscardUnknown 

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal 

func (m *ListenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListenRequest) XXX_Merge 

func (m *ListenRequest) XXX_Merge(src proto.Message)

func (*ListenRequest) XXX_OneofFuncs 

func (*ListenRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ListenRequest) XXX_Size 

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal 

func (m *ListenRequest) XXX_Unmarshal(b []byte) error

type ListenRequest_Ack 

type ListenRequest_Ack struct {
	Ack *Ack `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type ListenRequest_Initial 

type ListenRequest_Initial struct {
	Initial *ListenInitial `protobuf:"bytes,1,opt,name=initial,proto3,oneof"`
}

type PauseRequest 

type PauseRequest struct {
	// Código de proyecto.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Nombre de la cola.
	QueueName            string   `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PauseRequest) Descriptor 

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

func (*PauseRequest) GetProject 

func (m *PauseRequest) GetProject() string

func (*PauseRequest) GetQueueName 

func (m *PauseRequest) GetQueueName() string

func (*PauseRequest) ProtoMessage 

func (*PauseRequest) ProtoMessage()

func (*PauseRequest) Reset 

func (m *PauseRequest) Reset()

func (*PauseRequest) String 

func (m *PauseRequest) String() string

func (*PauseRequest) XXX_DiscardUnknown 

func (m *PauseRequest) XXX_DiscardUnknown()

func (*PauseRequest) XXX_Marshal 

func (m *PauseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseRequest) XXX_Merge 

func (m *PauseRequest) XXX_Merge(src proto.Message)

func (*PauseRequest) XXX_Size 

func (m *PauseRequest) XXX_Size() int

func (*PauseRequest) XXX_Unmarshal 

func (m *PauseRequest) XXX_Unmarshal(b []byte) error

type Queue 

type Queue struct {
	// Código de proyecto.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Nombre de la cola.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Número de tareas que se ejecutarán por unidad de tiempo en esta cola.
	TasksPerUnit int64 `protobuf:"varint,3,opt,name=tasks_per_unit,json=tasksPerUnit,proto3" json:"tasks_per_unit,omitempty"`
	// Unidad de tiempos que determina el ritmo de ejecución.
	Unit Queue_Unit `protobuf:"varint,4,opt,name=unit,proto3,enum=queues.queues.Queue_Unit" json:"unit,omitempty"`
	// Estado de runtime de la cola si está ejecutando tareas activamente o no.
	Paused bool `protobuf:"varint,5,opt,name=paused,proto3" json:"paused,omitempty"`
	// Número de reintentos que tiene cada tarea en la cola. Los reintentos se harán
	// con un backoff doblando el tiempo de espera cada vez. Los 10 primeros tiempos son:
	//   1m, 2m, 4m, 8m, 16m, 32m, 1h4m, 2h8m, 4h16m, 8h32m.
	MaxRetries int32 `protobuf:"varint,6,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	// Tareas máximas que se estarán ejecutando al mismo tiempo.
	MaxConcurrent        int32    `protobuf:"varint,7,opt,name=max_concurrent,json=maxConcurrent,proto3" json:"max_concurrent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Queue) Descriptor 

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

func (*Queue) GetMaxConcurrent 

func (m *Queue) GetMaxConcurrent() int32

func (*Queue) GetMaxRetries 

func (m *Queue) GetMaxRetries() int32

func (*Queue) GetName 

func (m *Queue) GetName() string

func (*Queue) GetPaused 

func (m *Queue) GetPaused() bool

func (*Queue) GetProject 

func (m *Queue) GetProject() string

func (*Queue) GetTasksPerUnit 

func (m *Queue) GetTasksPerUnit() int64

func (*Queue) GetUnit 

func (m *Queue) GetUnit() Queue_Unit

func (*Queue) ProtoMessage 

func (*Queue) ProtoMessage()

func (*Queue) Reset 

func (m *Queue) Reset()

func (*Queue) String 

func (m *Queue) String() string

func (*Queue) XXX_DiscardUnknown 

func (m *Queue) XXX_DiscardUnknown()

func (*Queue) XXX_Marshal 

func (m *Queue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Queue) XXX_Merge 

func (m *Queue) XXX_Merge(src proto.Message)

func (*Queue) XXX_Size 

func (m *Queue) XXX_Size() int

func (*Queue) XXX_Unmarshal 

func (m *Queue) XXX_Unmarshal(b []byte) error

type Queue_Unit 

type Queue_Unit int32
const (
	Queue_UNIT_UNKNOWN Queue_Unit = 0
	Queue_UNIT_SECONDS Queue_Unit = 1
	Queue_UNIT_MINUTES Queue_Unit = 2
)

func (Queue_Unit) EnumDescriptor 

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

func (Queue_Unit) String 

func (x Queue_Unit) String() string

type QueuesServiceClient 

type QueuesServiceClient interface {
	// Abre una conexión permanente para recibir tareas.
	Listen(ctx context.Context, opts ...grpc.CallOption) (QueuesService_ListenClient, error)
	// Manda una o varias tareas a una cola.
	SendTasks(ctx context.Context, in *SendTasksRequest, opts ...grpc.CallOption) (*SendTasksReply, error)
	// Lista las 30 próximas tareas de la cola.
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksReply, error)
	// Lista las colas disponibles en el sistema.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListReply, error)
	// Pausa la ejecución de tareas en una cola.
	//
	// TODO(ernesto): Cambiar la ruta a {queue_name}:pause cuando esté soportada.
	Pause(ctx context.Context, in *PauseRequest, opts ...grpc.CallOption) (*Queue, error)
	// Continua con la ejecución de tareas en una cola.
	//
	// TODO(ernesto): Cambiar la ruta a {queue_name}:resume cuando esté soportada.
	Resume(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*Queue, error)
}

QueuesServiceClient is the client API for QueuesService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueuesServiceClient 

func NewQueuesServiceClient(cc *grpc.ClientConn) QueuesServiceClient

type QueuesServiceServer 

type QueuesServiceServer interface {
	// Abre una conexión permanente para recibir tareas.
	Listen(QueuesService_ListenServer) error
	// Manda una o varias tareas a una cola.
	SendTasks(context.Context, *SendTasksRequest) (*SendTasksReply, error)
	// Lista las 30 próximas tareas de la cola.
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksReply, error)
	// Lista las colas disponibles en el sistema.
	List(context.Context, *ListRequest) (*ListReply, error)
	// Pausa la ejecución de tareas en una cola.
	//
	// TODO(ernesto): Cambiar la ruta a {queue_name}:pause cuando esté soportada.
	Pause(context.Context, *PauseRequest) (*Queue, error)
	// Continua con la ejecución de tareas en una cola.
	//
	// TODO(ernesto): Cambiar la ruta a {queue_name}:resume cuando esté soportada.
	Resume(context.Context, *ResumeRequest) (*Queue, error)
}

QueuesServiceServer is the server API for QueuesService service.

type QueuesService_ListenClient 

type QueuesService_ListenClient interface {
	Send(*ListenRequest) error
	Recv() (*ListenReply, error)
	grpc.ClientStream
}

type QueuesService_ListenServer 

type QueuesService_ListenServer interface {
	Send(*ListenReply) error
	Recv() (*ListenRequest, error)
	grpc.ServerStream
}

type ResumeRequest 

type ResumeRequest struct {
	// Código de proyecto.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Nombre de la cola.
	QueueName            string   `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResumeRequest) Descriptor 

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

func (*ResumeRequest) GetProject 

func (m *ResumeRequest) GetProject() string

func (*ResumeRequest) GetQueueName 

func (m *ResumeRequest) GetQueueName() string

func (*ResumeRequest) ProtoMessage 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) Reset 

func (m *ResumeRequest) Reset()

func (*ResumeRequest) String 

func (m *ResumeRequest) String() string

func (*ResumeRequest) XXX_DiscardUnknown 

func (m *ResumeRequest) XXX_DiscardUnknown()

func (*ResumeRequest) XXX_Marshal 

func (m *ResumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResumeRequest) XXX_Merge 

func (m *ResumeRequest) XXX_Merge(src proto.Message)

func (*ResumeRequest) XXX_Size 

func (m *ResumeRequest) XXX_Size() int

func (*ResumeRequest) XXX_Unmarshal 

func (m *ResumeRequest) XXX_Unmarshal(b []byte) error

type SendTask 

type SendTask struct {
	// Contenido JSON de la tarea.
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// ETA (Estimated Time of Arrival) mínimo que debe tener la tarea. Nos permite
	// retrasar una tarea si le pasamos una fecha futura. Si no está especificada
	// o es una fecha pasada la tarea se ejecutará lo antes posible.
	MinEta               *timestamp.Timestamp `protobuf:"bytes,2,opt,name=min_eta,json=minEta,proto3" json:"min_eta,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*SendTask) Descriptor 

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

func (*SendTask) GetMinEta 

func (m *SendTask) GetMinEta() *timestamp.Timestamp

func (*SendTask) GetPayload 

func (m *SendTask) GetPayload() []byte

func (*SendTask) ProtoMessage 

func (*SendTask) ProtoMessage()

func (*SendTask) Reset 

func (m *SendTask) Reset()

func (*SendTask) String 

func (m *SendTask) String() string

func (*SendTask) XXX_DiscardUnknown 

func (m *SendTask) XXX_DiscardUnknown()

func (*SendTask) XXX_Marshal 

func (m *SendTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendTask) XXX_Merge 

func (m *SendTask) XXX_Merge(src proto.Message)

func (*SendTask) XXX_Size 

func (m *SendTask) XXX_Size() int

func (*SendTask) XXX_Unmarshal 

func (m *SendTask) XXX_Unmarshal(b []byte) error

type SendTasksReply 

type SendTasksReply struct {
	// Listado de códigos de tareas que se han creado en el servidor.
	Codes                []string `protobuf:"bytes,1,rep,name=codes,proto3" json:"codes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendTasksReply) Descriptor 

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

func (*SendTasksReply) GetCodes 

func (m *SendTasksReply) GetCodes() []string

func (*SendTasksReply) ProtoMessage 

func (*SendTasksReply) ProtoMessage()

func (*SendTasksReply) Reset 

func (m *SendTasksReply) Reset()

func (*SendTasksReply) String 

func (m *SendTasksReply) String() string

func (*SendTasksReply) XXX_DiscardUnknown 

func (m *SendTasksReply) XXX_DiscardUnknown()

func (*SendTasksReply) XXX_Marshal 

func (m *SendTasksReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendTasksReply) XXX_Merge 

func (m *SendTasksReply) XXX_Merge(src proto.Message)

func (*SendTasksReply) XXX_Size 

func (m *SendTasksReply) XXX_Size() int

func (*SendTasksReply) XXX_Unmarshal 

func (m *SendTasksReply) XXX_Unmarshal(b []byte) error

type SendTasksRequest 

type SendTasksRequest struct {
	// Código de proyecto.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Nombre de la cola.
	QueueName string `protobuf:"bytes,2,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	// Listado de tareas que queremos enviar a la cola.
	Tasks                []*SendTask `protobuf:"bytes,3,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*SendTasksRequest) Descriptor 

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

func (*SendTasksRequest) GetProject 

func (m *SendTasksRequest) GetProject() string

func (*SendTasksRequest) GetQueueName 

func (m *SendTasksRequest) GetQueueName() string

func (*SendTasksRequest) GetTasks 

func (m *SendTasksRequest) GetTasks() []*SendTask

func (*SendTasksRequest) ProtoMessage 

func (*SendTasksRequest) ProtoMessage()

func (*SendTasksRequest) Reset 

func (m *SendTasksRequest) Reset()

func (*SendTasksRequest) String 

func (m *SendTasksRequest) String() string

func (*SendTasksRequest) XXX_DiscardUnknown 

func (m *SendTasksRequest) XXX_DiscardUnknown()

func (*SendTasksRequest) XXX_Marshal 

func (m *SendTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendTasksRequest) XXX_Merge 

func (m *SendTasksRequest) XXX_Merge(src proto.Message)

func (*SendTasksRequest) XXX_Size 

func (m *SendTasksRequest) XXX_Size() int

func (*SendTasksRequest) XXX_Unmarshal 

func (m *SendTasksRequest) XXX_Unmarshal(b []byte) error

type Task 

type Task struct {
	// Código único que identifica la tarea.
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// Contenido de la tarea.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// Momento en el que se mandó a la cola la tarea.
	Created *timestamp.Timestamp `protobuf:"bytes,3,opt,name=created,proto3" json:"created,omitempty"`
	// Número de reintento de la ejecución.
	Retry int32 `protobuf:"varint,4,opt,name=retry,proto3" json:"retry,omitempty"`
	// ETA (Estimated Time of Arrival) mínimo que debe tener la tarea. Nos permite
	// retrasar una tarea si le pasamos una fecha futura. Si no está especificada
	// o es una fecha pasada la tarea se ejecutará lo antes posible.
	MinEta *timestamp.Timestamp `protobuf:"bytes,5,opt,name=min_eta,json=minEta,proto3" json:"min_eta,omitempty"`
	// Proyecto que ejecuta esta tarea.
	Project string `protobuf:"bytes,6,opt,name=project,proto3" json:"project,omitempty"`
	// Nombre de la cola que ejecuta esta tarea.
	QueueName            string   `protobuf:"bytes,7,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Task) Descriptor 

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

func (*Task) GetCode 

func (m *Task) GetCode() string

func (*Task) GetCreated 

func (m *Task) GetCreated() *timestamp.Timestamp

func (*Task) GetMinEta 

func (m *Task) GetMinEta() *timestamp.Timestamp

func (*Task) GetPayload 

func (m *Task) GetPayload() []byte

func (*Task) GetProject 

func (m *Task) GetProject() string

func (*Task) GetQueueName 

func (m *Task) GetQueueName() string

func (*Task) GetRetry 

func (m *Task) GetRetry() int32

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) String 

func (m *Task) String() string

func (*Task) XXX_DiscardUnknown 

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal 

func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Task) XXX_Merge 

func (m *Task) XXX_Merge(src proto.Message)

func (*Task) XXX_Size 

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal 

func (m *Task) XXX_Unmarshal(b []byte) error

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.