protopb

type CancelRequest struct {

	// Globally unique identifier of the land request to cancel, returned by a prior Land call.
	Sqid string `protobuf:"bytes,1,opt,name=sqid,proto3" json:"sqid,omitempty"`
	// Optional human-readable reason for the cancellation. Recorded for observability.
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// Name of the queue processing the request. Required. A sqid is only resolvable within its own queue,
	// so naming a queue the request does not belong to is reported as not found.
	Queue string `protobuf:"bytes,3,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

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

type Error struct {

	// Free text error message describing the error.
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type FxSubmitQueueGatewayYARPCClientParams struct {
	fx.In

	Provider    yarpc.ClientConfig
	AnyResolver v2.AnyResolver      `name:"yarpcfx" optional:"true"`
	Restriction restriction.Checker `optional:"true"`
}

type FxSubmitQueueGatewayYARPCClientResult struct {
	fx.Out

	Client SubmitQueueGatewayYARPCClient
}

type FxSubmitQueueGatewayYARPCProceduresParams struct {
	fx.In

	Server      SubmitQueueGatewayYARPCServer
	AnyResolver v2.AnyResolver `name:"yarpcfx" optional:"true"`
}

type FxSubmitQueueGatewayYARPCProceduresResult struct {
	fx.Out

	Procedures     []transport.Procedure `group:"yarpcfx"`
	ReflectionMeta reflection.ServerMeta `group:"yarpcfx"`
}

type GetRequestHistoryByChangeURIRequest struct {

	// Exact change URI supplied in a Land request.
	ChangeUri string `protobuf:"bytes,1,opt,name=change_uri,json=changeUri,proto3" json:"change_uri,omitempty"`
	// Name of the queue to search. Required. Results are scoped to this queue: a change URI landed
	// into several queues is looked up one queue at a time.
	Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type GetRequestHistoryByChangeURIResponse struct {

	// Matching request histories.
	Histories []*RequestHistory `protobuf:"bytes,1,rep,name=histories,proto3" json:"histories,omitempty"`
	// contains filtered or unexported fields
}

type GetRequestHistoryByIDRequest struct {

	// Globally unique identifier for the request.
	Sqid string `protobuf:"bytes,1,opt,name=sqid,proto3" json:"sqid,omitempty"`
	// Name of the queue processing the request. Required. A sqid is only resolvable within its own queue,
	// so naming a queue the request does not belong to is reported as not found.
	Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type GetRequestHistoryByIDResponse struct {

	// Events ordered by timestamp ascending with a stable storage tie-breaker.
	Events []*HistoryEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type GetRequestSummaryByChangeURIRequest struct {

	// Exact change URI supplied in a Land request.
	ChangeUri string `protobuf:"bytes,1,opt,name=change_uri,json=changeUri,proto3" json:"change_uri,omitempty"`
	// Name of the queue to search. Required. Results are scoped to this queue: a change URI landed
	// into several queues is looked up one queue at a time.
	Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type GetRequestSummaryByChangeURIResponse struct {

	// Matching requests ordered by receipt time descending, then sqid descending.
	Requests []*RequestSummary `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

type GetRequestSummaryByIDRequest struct {

	// Globally unique identifier for the request.
	Sqid string `protobuf:"bytes,1,opt,name=sqid,proto3" json:"sqid,omitempty"`
	// Name of the queue processing the request. Required. A sqid is only resolvable within its own queue,
	// so naming a queue the request does not belong to is reported as not found.
	Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type GetRequestSummaryByIDResponse struct {

	// Matching request.
	Request *RequestSummary `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

type HistoryEvent struct {

	// Time the request-log entry was created, in Unix milliseconds.
	TimestampMs int64 `protobuf:"varint,1,opt,name=timestamp_ms,json=timestampMs,proto3" json:"timestamp_ms,omitempty"`
	// Customer-friendly request status recorded by the event. Set only when type is "status".
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// Error message associated with the event. Empty when absent.
	LastError string `protobuf:"bytes,3,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
	// Display and debugging metadata associated with this event. Each lifecycle event carries its own values.
	Metadata map[string]string `` /* 143-byte string literal not displayed */
	// What this entry records: "status" when the request reached a position in the pipeline,
	// "event" when something happened while it sat at one. Exactly one of status and event is set.
	Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	// Occurrence recorded by the entry, e.g. a build starting or finishing. Set only when type is "event".
	// A request records many of these — one per build — and they never change its current status.
	Event string `protobuf:"bytes,6,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type LandRequest struct {

	// Name of the queue processing the land request. The queue should be defined in the configuration, otherwise an error is returned.
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// Change (such as a pull request) to land into the target branch. Target branch is defined by the queue configuration.
	Change *protopb.Change `protobuf:"bytes,2,opt,name=change,proto3" json:"change,omitempty"`
	// Source control integration strategy to use for this land operation. If not specified, the default queue strategy is used.
	// It applies to every URI the change carries, the same way to each — a land
	// request cannot pick a different strategy per URI.
	Strategy protopb1.Strategy `protobuf:"varint,4,opt,name=strategy,proto3,enum=uber.base.mergestrategy.Strategy" json:"strategy,omitempty"`
	// contains filtered or unexported fields
}

type LandResponse struct {

	// Globally unique identifier for the land request. Used to track the land request lifecycle.
	Sqid string `protobuf:"bytes,1,opt,name=sqid,proto3" json:"sqid,omitempty"`
	// contains filtered or unexported fields
}

type ListRequest struct {

	// Exact queue to query.
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// Inclusive lower receipt-time bound in Unix milliseconds.
	ReceivedAtOrAfterMs int64 `protobuf:"varint,2,opt,name=received_at_or_after_ms,json=receivedAtOrAfterMs,proto3" json:"received_at_or_after_ms,omitempty"`
	// Exclusive upper receipt-time bound in Unix milliseconds.
	ReceivedBeforeMs int64 `protobuf:"varint,3,opt,name=received_before_ms,json=receivedBeforeMs,proto3" json:"received_before_ms,omitempty"`
	// Maximum results to return. Zero selects the server default; values above the server maximum are invalid.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Opaque continuation token from a previous response. Empty selects the first page.
	PageToken string `protobuf:"bytes,5,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

type ListResponse struct {

	// Requests ordered by receipt time descending, then sqid descending.
	Requests []*RequestSummary `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// Opaque continuation token. Empty when this is the last page.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

type PingRequest struct {

	// Optional message to include in the ping
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type PingResponse struct {

	// The response message
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// The service name that handled the request
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Timestamp of when the ping was received
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Hostname of the server that handled the request
	Hostname string `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

type RequestHistory struct {

	// Globally unique request identifier.
	Sqid string `protobuf:"bytes,1,opt,name=sqid,proto3" json:"sqid,omitempty"`
	// Retained events ordered chronologically.
	Events []*HistoryEvent `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type RequestNotFoundError struct {

	// Free text error message describing the error.
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// The sqid that was not found.
	Sqid string `protobuf:"bytes,2,opt,name=sqid,proto3" json:"sqid,omitempty"`
	// Exact change URI that was not found. Populated only for change-URI lookup.
	ChangeUri string `protobuf:"bytes,3,opt,name=change_uri,json=changeUri,proto3" json:"change_uri,omitempty"`
	// contains filtered or unexported fields
}

type RequestSummary struct {

	// Globally unique request identifier. This is request_id in internal storage.
	Sqid string `protobuf:"bytes,1,opt,name=sqid,proto3" json:"sqid,omitempty"`
	// Queue supplied when the request was received.
	Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// Change URIs supplied when the request was received, in caller order.
	ChangeUris []string `protobuf:"bytes,3,rep,name=change_uris,json=changeUris,proto3" json:"change_uris,omitempty"`
	// Receipt time in Unix milliseconds.
	ReceivedAtMs int64 `protobuf:"varint,4,opt,name=received_at_ms,json=receivedAtMs,proto3" json:"received_at_ms,omitempty"`
	// Current customer-friendly status of the request.
	Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// Last error associated with the current status. Empty when absent.
	LastError string `protobuf:"bytes,6,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
	// Display and debugging metadata associated with the current status.
	Metadata map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SubmitQueueGatewayClient interface {
	// Ping returns a response indicating the service is alive
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// Land lands a set of code changes into a target branch, performing the necessary validations across all other changes in the queue.
	// The processing is asynchronous and returns a LandResponse immediately. The land request is processed in the background.
	Land(ctx context.Context, in *LandRequest, opts ...grpc.CallOption) (*LandResponse, error)
	// Cancel cancels an in-flight land request identified by its sqid. If the request has already been included in a batch,
	// the entire batch is cancelled. Cancel is idempotent — calling it for an already-terminal request is a no-op.
	//
	// Cancellation is ASYNCHRONOUS: Cancel returns as soon as the cancellation intent has been accepted; the actual
	// state transition is performed in the background by the orchestrator and may not have completed by the time the
	// caller receives a response.
	//
	// Cancellation is NOT GUARANTEED: a request that has already merged, or that races to completion before the cancel
	// signal propagates through the pipeline, may still land (or end in an error). Callers must NOT assume that a
	// successful Cancel response means the request was cancelled — the actual terminal outcome (cancelled, landed, or
	// error) must be checked through the request-summary or request-history APIs.
	Cancel(ctx context.Context, in *CancelRequest, opts ...grpc.CallOption) (*CancelResponse, error)
	// GetRequestSummaryByID returns the current materialized status of one request.
	GetRequestSummaryByID(ctx context.Context, in *GetRequestSummaryByIDRequest, opts ...grpc.CallOption) (*GetRequestSummaryByIDResponse, error)
	// GetRequestSummaryByChangeURI returns current materialized statuses for an exact pinned change URI.
	GetRequestSummaryByChangeURI(ctx context.Context, in *GetRequestSummaryByChangeURIRequest, opts ...grpc.CallOption) (*GetRequestSummaryByChangeURIResponse, error)
	// List returns requests received for one queue during a bounded receipt-time range.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	// GetRequestHistoryByID returns every retained request-log event for one request.
	GetRequestHistoryByID(ctx context.Context, in *GetRequestHistoryByIDRequest, opts ...grpc.CallOption) (*GetRequestHistoryByIDResponse, error)
	// GetRequestHistoryByChangeURI returns retained request histories for an exact pinned change URI.
	GetRequestHistoryByChangeURI(ctx context.Context, in *GetRequestHistoryByChangeURIRequest, opts ...grpc.CallOption) (*GetRequestHistoryByChangeURIResponse, error)
}

type SubmitQueueGatewayServer interface {
	// Ping returns a response indicating the service is alive
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// Land lands a set of code changes into a target branch, performing the necessary validations across all other changes in the queue.
	// The processing is asynchronous and returns a LandResponse immediately. The land request is processed in the background.
	Land(context.Context, *LandRequest) (*LandResponse, error)
	// Cancel cancels an in-flight land request identified by its sqid. If the request has already been included in a batch,
	// the entire batch is cancelled. Cancel is idempotent — calling it for an already-terminal request is a no-op.
	//
	// Cancellation is ASYNCHRONOUS: Cancel returns as soon as the cancellation intent has been accepted; the actual
	// state transition is performed in the background by the orchestrator and may not have completed by the time the
	// caller receives a response.
	//
	// Cancellation is NOT GUARANTEED: a request that has already merged, or that races to completion before the cancel
	// signal propagates through the pipeline, may still land (or end in an error). Callers must NOT assume that a
	// successful Cancel response means the request was cancelled — the actual terminal outcome (cancelled, landed, or
	// error) must be checked through the request-summary or request-history APIs.
	Cancel(context.Context, *CancelRequest) (*CancelResponse, error)
	// GetRequestSummaryByID returns the current materialized status of one request.
	GetRequestSummaryByID(context.Context, *GetRequestSummaryByIDRequest) (*GetRequestSummaryByIDResponse, error)
	// GetRequestSummaryByChangeURI returns current materialized statuses for an exact pinned change URI.
	GetRequestSummaryByChangeURI(context.Context, *GetRequestSummaryByChangeURIRequest) (*GetRequestSummaryByChangeURIResponse, error)
	// List returns requests received for one queue during a bounded receipt-time range.
	List(context.Context, *ListRequest) (*ListResponse, error)
	// GetRequestHistoryByID returns every retained request-log event for one request.
	GetRequestHistoryByID(context.Context, *GetRequestHistoryByIDRequest) (*GetRequestHistoryByIDResponse, error)
	// GetRequestHistoryByChangeURI returns retained request histories for an exact pinned change URI.
	GetRequestHistoryByChangeURI(context.Context, *GetRequestHistoryByChangeURIRequest) (*GetRequestHistoryByChangeURIResponse, error)
	// contains filtered or unexported methods
}

type SubmitQueueGatewayYARPCClient interface {
	Ping(context.Context, *PingRequest, ...yarpc.CallOption) (*PingResponse, error)
	Land(context.Context, *LandRequest, ...yarpc.CallOption) (*LandResponse, error)
	Cancel(context.Context, *CancelRequest, ...yarpc.CallOption) (*CancelResponse, error)
	GetRequestSummaryByID(context.Context, *GetRequestSummaryByIDRequest, ...yarpc.CallOption) (*GetRequestSummaryByIDResponse, error)
	GetRequestSummaryByChangeURI(context.Context, *GetRequestSummaryByChangeURIRequest, ...yarpc.CallOption) (*GetRequestSummaryByChangeURIResponse, error)
	List(context.Context, *ListRequest, ...yarpc.CallOption) (*ListResponse, error)
	GetRequestHistoryByID(context.Context, *GetRequestHistoryByIDRequest, ...yarpc.CallOption) (*GetRequestHistoryByIDResponse, error)
	GetRequestHistoryByChangeURI(context.Context, *GetRequestHistoryByChangeURIRequest, ...yarpc.CallOption) (*GetRequestHistoryByChangeURIResponse, error)
}

type SubmitQueueGatewayYARPCServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	Land(context.Context, *LandRequest) (*LandResponse, error)
	Cancel(context.Context, *CancelRequest) (*CancelResponse, error)
	GetRequestSummaryByID(context.Context, *GetRequestSummaryByIDRequest) (*GetRequestSummaryByIDResponse, error)
	GetRequestSummaryByChangeURI(context.Context, *GetRequestSummaryByChangeURIRequest) (*GetRequestSummaryByChangeURIResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	GetRequestHistoryByID(context.Context, *GetRequestHistoryByIDRequest) (*GetRequestHistoryByIDResponse, error)
	GetRequestHistoryByChangeURI(context.Context, *GetRequestHistoryByChangeURIRequest) (*GetRequestHistoryByChangeURIResponse, error)
}

type UnimplementedSubmitQueueGatewayServer struct{}

type UnrecognizedQueueError struct {

	// Free text error message describing the error.
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// Name of the queue that was not recognized.
	Queue string `protobuf:"bytes,2,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

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