workerapipb

type AckRequest struct {

	// Pull endpoint path.
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Exactly one of lease_id or lease_ids must be set.
	LeaseId  string   `protobuf:"bytes,2,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	LeaseIds []string `protobuf:"bytes,3,rep,name=lease_ids,json=leaseIds,proto3" json:"lease_ids,omitempty"`
	// contains filtered or unexported fields
}

type AckResponse struct {

	// Number of successful acks. Includes idempotent duplicate retries.
	Acked     uint32           `protobuf:"varint,1,opt,name=acked,proto3" json:"acked,omitempty"`
	Conflicts []*LeaseConflict `protobuf:"bytes,2,rep,name=conflicts,proto3" json:"conflicts,omitempty"`
	// contains filtered or unexported fields
}

type DequeueItem struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	LeaseId    string                 `protobuf:"bytes,2,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	ReceivedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=received_at,json=receivedAt,proto3" json:"received_at,omitempty"`
	Attempt    int32                  `protobuf:"varint,4,opt,name=attempt,proto3" json:"attempt,omitempty"`
	NextRunAt  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=next_run_at,json=nextRunAt,proto3" json:"next_run_at,omitempty"`
	Route      string                 `protobuf:"bytes,6,opt,name=route,proto3" json:"route,omitempty"`
	Payload    []byte                 `protobuf:"bytes,7,opt,name=payload,proto3" json:"payload,omitempty"`
	Headers    map[string]string      `` /* 141-byte string literal not displayed */
	Trace      map[string]string      `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DequeueRequest struct {

	// Pull endpoint path (same route selector used by HTTP Pull API).
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Optional; defaults to 1 and is capped by server policy.
	Batch uint32 `protobuf:"varint,2,opt,name=batch,proto3" json:"batch,omitempty"`
	// Optional dequeue wait and lease values.
	MaxWait  *durationpb.Duration `protobuf:"bytes,3,opt,name=max_wait,json=maxWait,proto3" json:"max_wait,omitempty"`
	LeaseTtl *durationpb.Duration `protobuf:"bytes,4,opt,name=lease_ttl,json=leaseTtl,proto3" json:"lease_ttl,omitempty"`
	// contains filtered or unexported fields
}

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

type ExtendRequest struct {

	// Pull endpoint path.
	Endpoint string               `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	LeaseId  string               `protobuf:"bytes,2,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	ExtendBy *durationpb.Duration `protobuf:"bytes,3,opt,name=extend_by,json=extendBy,proto3" json:"extend_by,omitempty"`
	// contains filtered or unexported fields
}

type LeaseConflict struct {
	LeaseId string `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	Expired bool   `protobuf:"varint,2,opt,name=expired,proto3" json:"expired,omitempty"`
	// contains filtered or unexported fields
}

type NackRequest struct {

	// Pull endpoint path.
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Exactly one of lease_id or lease_ids must be set.
	LeaseId  string   `protobuf:"bytes,2,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	LeaseIds []string `protobuf:"bytes,3,rep,name=lease_ids,json=leaseIds,proto3" json:"lease_ids,omitempty"`
	// Ignored when dead=true.
	Delay  *durationpb.Duration `protobuf:"bytes,4,opt,name=delay,proto3" json:"delay,omitempty"`
	Dead   bool                 `protobuf:"varint,5,opt,name=dead,proto3" json:"dead,omitempty"`
	Reason string               `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type NackResponse struct {

	// Number of successful nack/dead operations. Includes idempotent retries.
	Succeeded uint32           `protobuf:"varint,1,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	Conflicts []*LeaseConflict `protobuf:"bytes,2,rep,name=conflicts,proto3" json:"conflicts,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedWorkerServiceServer struct{}

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

type WorkerServiceClient interface {
	Dequeue(ctx context.Context, in *DequeueRequest, opts ...grpc.CallOption) (*DequeueResponse, error)
	Ack(ctx context.Context, in *AckRequest, opts ...grpc.CallOption) (*AckResponse, error)
	Nack(ctx context.Context, in *NackRequest, opts ...grpc.CallOption) (*NackResponse, error)
	Extend(ctx context.Context, in *ExtendRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type WorkerServiceServer interface {
	Dequeue(context.Context, *DequeueRequest) (*DequeueResponse, error)
	Ack(context.Context, *AckRequest) (*AckResponse, error)
	Nack(context.Context, *NackRequest) (*NackResponse, error)
	Extend(context.Context, *ExtendRequest) (*emptypb.Empty, error)
}