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"`
	// 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 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.
	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 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 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"`
	// contains filtered or unexported fields
}

type StatusRequest struct {

	// Globally unique identifier for the request, as returned by Land in the LandResponse.
	Sqid string `protobuf:"bytes,1,opt,name=sqid,proto3" json:"sqid,omitempty"`
	// contains filtered or unexported fields
}

type StatusResponse struct {

	// Current customer-friendly status of the request (e.g. "accepted", "validating", "landed", "error").
	// Status is a free-form string because the system may introduce new statuses without breaking existing clients.
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// Last error message associated with the current status. Empty string if there is no error.
	LastError string `protobuf:"bytes,2,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
	// Free-form key-value metadata associated with the current status, for display or debugging purposes. Empty if none.
	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 separate status / request-log API.
	Cancel(ctx context.Context, in *CancelRequest, opts ...grpc.CallOption) (*CancelResponse, error)
	// Status returns the current status of a previously submitted request, identified by its sqid.
	// The status is eventually consistent with the request store and reconciled from the append-only request log.
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, 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 separate status / request-log API.
	Cancel(context.Context, *CancelRequest) (*CancelResponse, error)
	// Status returns the current status of a previously submitted request, identified by its sqid.
	// The status is eventually consistent with the request store and reconciled from the append-only request log.
	Status(context.Context, *StatusRequest) (*StatusResponse, 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)
	Status(context.Context, *StatusRequest, ...yarpc.CallOption) (*StatusResponse, error)
}

type SubmitQueueGatewayYARPCServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	Land(context.Context, *LandRequest) (*LandResponse, error)
	Cancel(context.Context, *CancelRequest) (*CancelResponse, error)
	Status(context.Context, *StatusRequest) (*StatusResponse, 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
}