queues_queues

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

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

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

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:"-"`
}

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:"-"`
}

type Queue_Unit int32

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)
}

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)
}

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

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

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}

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:"-"`
}