nexus

type CancelOperationRequest struct {

	// Type of operation to cancel.
	Operation string `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// Operation ID as originally generated by a Handler.
	OperationId string `protobuf:"bytes,2,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

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

type Failure struct {
	Message  string            `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	Details  *structpb.Value   `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

type HandlerError struct {

	// See https://github.com/nexus-rpc/api/blob/main/SPEC.md#predefined-handler-errors.
	ErrorType string   `protobuf:"bytes,1,opt,name=error_type,json=errorType,proto3" json:"error_type,omitempty"`
	Failure   *Failure `protobuf:"bytes,2,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

type IncomingService struct {

	// Data version for this service. Must match current version on update or set to 0 to create a new service.
	Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// Service name, unique for this cluster.
	// The service name is used to address this service.
	// By default, when using Nexus over HTTP, the service name is matched against the base URL path.
	// E.g. the URL /my-service would match a service named "my-service".
	// The name can contain any characters and is escaped when matched against a URL.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Namespace to route requests to.
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Task queue to route requests to.
	TaskQueue string `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Generic service metadata that is available to the server's authorizer.
	Metadata map[string]*anypb.Any `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Request struct {

	// Headers extracted from the original request in the Temporal frontend.
	// When using Nexus over HTTP, this includes the request's HTTP headers ignoring multiple values.
	Header map[string]string `` /* 153-byte string literal not displayed */
	// Types that are assignable to Variant:
	//
	//	*Request_StartOperation
	//	*Request_CancelOperation
	Variant isRequest_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

type Request_CancelOperation struct {
	CancelOperation *CancelOperationRequest `protobuf:"bytes,3,opt,name=cancel_operation,json=cancelOperation,proto3,oneof"`
}

type Request_StartOperation struct {
	StartOperation *StartOperationRequest `protobuf:"bytes,2,opt,name=start_operation,json=startOperation,proto3,oneof"`
}

type Response struct {

	// Variant must correlate to the corresponding Request's variant.
	//
	// Types that are assignable to Variant:
	//
	//	*Response_StartOperation
	//	*Response_CancelOperation
	Variant isResponse_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

type Response_CancelOperation struct {
	CancelOperation *CancelOperationResponse `protobuf:"bytes,2,opt,name=cancel_operation,json=cancelOperation,proto3,oneof"`
}

type Response_StartOperation struct {
	StartOperation *StartOperationResponse `protobuf:"bytes,1,opt,name=start_operation,json=startOperation,proto3,oneof"`
}

type StartOperationRequest struct {

	// Type of operation to start.
	Operation string `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// A request ID that can be used as an idempotentency key.
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Callback URL to call upon completion if the started operation is async.
	Callback string `protobuf:"bytes,3,opt,name=callback,proto3" json:"callback,omitempty"`
	// Full request body from the incoming HTTP request.
	Payload *v1.Payload `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type StartOperationResponse struct {

	// Types that are assignable to Variant:
	//
	//	*StartOperationResponse_SyncSuccess
	//	*StartOperationResponse_AsyncSuccess
	//	*StartOperationResponse_OperationError
	Variant isStartOperationResponse_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

type StartOperationResponse_Async struct {
	OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// contains filtered or unexported fields
}

type StartOperationResponse_AsyncSuccess struct {
	AsyncSuccess *StartOperationResponse_Async `protobuf:"bytes,2,opt,name=async_success,json=asyncSuccess,proto3,oneof"`
}

type StartOperationResponse_OperationError struct {
	// The operation completed unsuccessfully (failed or canceled).
	OperationError *UnsuccessfulOperationError `protobuf:"bytes,3,opt,name=operation_error,json=operationError,proto3,oneof"`
}

type StartOperationResponse_Sync struct {
	Payload *v1.Payload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type StartOperationResponse_SyncSuccess struct {
	SyncSuccess *StartOperationResponse_Sync `protobuf:"bytes,1,opt,name=sync_success,json=syncSuccess,proto3,oneof"`
}

type UnsuccessfulOperationError struct {

	// See https://github.com/nexus-rpc/api/blob/main/SPEC.md#operationinfo.
	OperationState string   `protobuf:"bytes,1,opt,name=operation_state,json=operationState,proto3" json:"operation_state,omitempty"`
	Failure        *Failure `protobuf:"bytes,2,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}