nexus

package
v1.32.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 10, 2024 License: MIT Imports: 9 Imported by: 2

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_api_nexus_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CancelOperationRequest 

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
}

A request to cancel an operation.

func (*CancelOperationRequest) Descriptor deprecated 

func (*CancelOperationRequest) Descriptor() ([]byte, []int)

Deprecated: Use CancelOperationRequest.ProtoReflect.Descriptor instead.

func (*CancelOperationRequest) Equal 

func (this *CancelOperationRequest) Equal(that interface{}) bool

Equal returns whether two CancelOperationRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CancelOperationRequest) GetOperation 

func (x *CancelOperationRequest) GetOperation() string

func (*CancelOperationRequest) GetOperationId 

func (x *CancelOperationRequest) GetOperationId() string

func (*CancelOperationRequest) Marshal 

func (val *CancelOperationRequest) Marshal() ([]byte, error)

Marshal an object of type CancelOperationRequest to the protobuf v3 wire format

func (*CancelOperationRequest) ProtoMessage 

func (*CancelOperationRequest) ProtoMessage()

func (*CancelOperationRequest) ProtoReflect 

func (x *CancelOperationRequest) ProtoReflect() protoreflect.Message

func (*CancelOperationRequest) Reset 

func (x *CancelOperationRequest) Reset()

func (*CancelOperationRequest) Size 

func (val *CancelOperationRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CancelOperationRequest) String 

func (x *CancelOperationRequest) String() string

func (*CancelOperationRequest) Unmarshal 

func (val *CancelOperationRequest) Unmarshal(buf []byte) error

Unmarshal an object of type CancelOperationRequest from the protobuf v3 wire format

type CancelOperationResponse 

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

Response variant for CancelOperationRequest.

func (*CancelOperationResponse) Descriptor deprecated 

func (*CancelOperationResponse) Descriptor() ([]byte, []int)

Deprecated: Use CancelOperationResponse.ProtoReflect.Descriptor instead.

func (*CancelOperationResponse) Equal 

func (this *CancelOperationResponse) Equal(that interface{}) bool

Equal returns whether two CancelOperationResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CancelOperationResponse) Marshal 

func (val *CancelOperationResponse) Marshal() ([]byte, error)

Marshal an object of type CancelOperationResponse to the protobuf v3 wire format

func (*CancelOperationResponse) ProtoMessage 

func (*CancelOperationResponse) ProtoMessage()

func (*CancelOperationResponse) ProtoReflect 

func (x *CancelOperationResponse) ProtoReflect() protoreflect.Message

func (*CancelOperationResponse) Reset 

func (x *CancelOperationResponse) Reset()

func (*CancelOperationResponse) Size 

func (val *CancelOperationResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CancelOperationResponse) String 

func (x *CancelOperationResponse) String() string

func (*CancelOperationResponse) Unmarshal 

func (val *CancelOperationResponse) Unmarshal(buf []byte) error

Unmarshal an object of type CancelOperationResponse from the protobuf v3 wire format

type Failure 

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
}

A general purpose failure message. See: https://github.com/nexus-rpc/api/blob/main/SPEC.md#failure

func (*Failure) Descriptor deprecated 

func (*Failure) Descriptor() ([]byte, []int)

Deprecated: Use Failure.ProtoReflect.Descriptor instead.

func (*Failure) Equal 

func (this *Failure) Equal(that interface{}) bool

Equal returns whether two Failure values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*Failure) GetDetails 

func (x *Failure) GetDetails() *structpb.Value

func (*Failure) GetMessage 

func (x *Failure) GetMessage() string

func (*Failure) GetMetadata 

func (x *Failure) GetMetadata() map[string]string

func (*Failure) Marshal 

func (val *Failure) Marshal() ([]byte, error)

Marshal an object of type Failure to the protobuf v3 wire format

func (*Failure) ProtoMessage 

func (*Failure) ProtoMessage()

func (*Failure) ProtoReflect 

func (x *Failure) ProtoReflect() protoreflect.Message

func (*Failure) Reset 

func (x *Failure) Reset()

func (*Failure) Size 

func (val *Failure) Size() int

Size returns the size of the object, in bytes, once serialized

func (*Failure) String 

func (x *Failure) String() string

func (*Failure) Unmarshal 

func (val *Failure) Unmarshal(buf []byte) error

Unmarshal an object of type Failure from the protobuf v3 wire format

type HandlerError 

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
}

func (*HandlerError) Descriptor deprecated 

func (*HandlerError) Descriptor() ([]byte, []int)

Deprecated: Use HandlerError.ProtoReflect.Descriptor instead.

func (*HandlerError) Equal 

func (this *HandlerError) Equal(that interface{}) bool

Equal returns whether two HandlerError values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*HandlerError) GetErrorType 

func (x *HandlerError) GetErrorType() string

func (*HandlerError) GetFailure 

func (x *HandlerError) GetFailure() *Failure

func (*HandlerError) Marshal 

func (val *HandlerError) Marshal() ([]byte, error)

Marshal an object of type HandlerError to the protobuf v3 wire format

func (*HandlerError) ProtoMessage 

func (*HandlerError) ProtoMessage()

func (*HandlerError) ProtoReflect 

func (x *HandlerError) ProtoReflect() protoreflect.Message

func (*HandlerError) Reset 

func (x *HandlerError) Reset()

func (*HandlerError) Size 

func (val *HandlerError) Size() int

Size returns the size of the object, in bytes, once serialized

func (*HandlerError) String 

func (x *HandlerError) String() string

func (*HandlerError) Unmarshal 

func (val *HandlerError) Unmarshal(buf []byte) error

Unmarshal an object of type HandlerError from the protobuf v3 wire format

type IncomingService 

type IncomingService struct {

	// Data version for this service, incremented for every update issued via the UpdateNexusIncomingService API.
	Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// Unique server-generated service ID.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Spec for the service.
	Spec *IncomingServiceSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// The date and time when the service was created.
	// (-- api-linter: core::0142::time-field-names=disabled
	//
	//	aip.dev/not-precedent: Not following linter rules. --)
	CreatedTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// The date and time when the service was last modified.
	// Will not be set if the service has never been modified.
	// (-- api-linter: core::0142::time-field-names=disabled
	//
	//	aip.dev/not-precedent: Not following linter rules. --)
	LastModifiedTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_modified_time,json=lastModifiedTime,proto3" json:"last_modified_time,omitempty"`
	// Server exposed URL prefix for invocation of operations on this service.
	// This doesn't include the protocol, hostname or port as the server does not know how it should be accessed
	// publicly. The URL is stable in the face of service renames.
	UrlPrefix string `protobuf:"bytes,6,opt,name=url_prefix,json=urlPrefix,proto3" json:"url_prefix,omitempty"`
	// contains filtered or unexported fields
}

A cluster-global binding from a service ID to namespace, task queue, and metadata for dispatching incoming Nexus requests.

func (*IncomingService) Descriptor deprecated 

func (*IncomingService) Descriptor() ([]byte, []int)

Deprecated: Use IncomingService.ProtoReflect.Descriptor instead.

func (*IncomingService) Equal 

func (this *IncomingService) Equal(that interface{}) bool

Equal returns whether two IncomingService values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*IncomingService) GetCreatedTime added in v1.30.1 

func (x *IncomingService) GetCreatedTime() *timestamppb.Timestamp

func (*IncomingService) GetId added in v1.30.1 

func (x *IncomingService) GetId() string

func (*IncomingService) GetLastModifiedTime added in v1.30.1 

func (x *IncomingService) GetLastModifiedTime() *timestamppb.Timestamp

func (*IncomingService) GetSpec added in v1.30.1 

func (x *IncomingService) GetSpec() *IncomingServiceSpec

func (*IncomingService) GetUrlPrefix added in v1.30.1 

func (x *IncomingService) GetUrlPrefix() string

func (*IncomingService) GetVersion 

func (x *IncomingService) GetVersion() int64

func (*IncomingService) Marshal 

func (val *IncomingService) Marshal() ([]byte, error)

Marshal an object of type IncomingService to the protobuf v3 wire format

func (*IncomingService) ProtoMessage 

func (*IncomingService) ProtoMessage()

func (*IncomingService) ProtoReflect 

func (x *IncomingService) ProtoReflect() protoreflect.Message

func (*IncomingService) Reset 

func (x *IncomingService) Reset()

func (*IncomingService) Size 

func (val *IncomingService) Size() int

Size returns the size of the object, in bytes, once serialized

func (*IncomingService) String 

func (x *IncomingService) String() string

func (*IncomingService) Unmarshal 

func (val *IncomingService) Unmarshal(buf []byte) error

Unmarshal an object of type IncomingService from the protobuf v3 wire format

type IncomingServiceSpec added in v1.30.1 

type IncomingServiceSpec struct {

	// Service name, unique for this cluster. Must match `[a-zA-Z_][a-zA-Z0-9_]*`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Namespace to route requests to.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Task queue to route requests to.
	TaskQueue string `protobuf:"bytes,3,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
}

Contains mutable fields for an IncomingService.

func (*IncomingServiceSpec) Descriptor deprecated added in v1.30.1 

func (*IncomingServiceSpec) Descriptor() ([]byte, []int)

Deprecated: Use IncomingServiceSpec.ProtoReflect.Descriptor instead.

func (*IncomingServiceSpec) Equal added in v1.30.1 

func (this *IncomingServiceSpec) Equal(that interface{}) bool

Equal returns whether two IncomingServiceSpec values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*IncomingServiceSpec) GetMetadata added in v1.30.1 

func (x *IncomingServiceSpec) GetMetadata() map[string]*anypb.Any

func (*IncomingServiceSpec) GetName added in v1.30.1 

func (x *IncomingServiceSpec) GetName() string

func (*IncomingServiceSpec) GetNamespace added in v1.30.1 

func (x *IncomingServiceSpec) GetNamespace() string

func (*IncomingServiceSpec) GetTaskQueue added in v1.30.1 

func (x *IncomingServiceSpec) GetTaskQueue() string

func (*IncomingServiceSpec) Marshal added in v1.30.1 

func (val *IncomingServiceSpec) Marshal() ([]byte, error)

Marshal an object of type IncomingServiceSpec to the protobuf v3 wire format

func (*IncomingServiceSpec) ProtoMessage added in v1.30.1 

func (*IncomingServiceSpec) ProtoMessage()

func (*IncomingServiceSpec) ProtoReflect added in v1.30.1 

func (x *IncomingServiceSpec) ProtoReflect() protoreflect.Message

func (*IncomingServiceSpec) Reset added in v1.30.1 

func (x *IncomingServiceSpec) Reset()

func (*IncomingServiceSpec) Size added in v1.30.1 

func (val *IncomingServiceSpec) Size() int

Size returns the size of the object, in bytes, once serialized

func (*IncomingServiceSpec) String added in v1.30.1 

func (x *IncomingServiceSpec) String() string

func (*IncomingServiceSpec) Unmarshal added in v1.30.1 

func (val *IncomingServiceSpec) Unmarshal(buf []byte) error

Unmarshal an object of type IncomingServiceSpec from the protobuf v3 wire format

type OutgoingService added in v1.30.1 

type OutgoingService struct {

	// Data version for this service, incremented for every mutation.
	Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// Name of the service
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Spec for the service.
	Spec *OutgoingServiceSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// The date and time when the service was created.
	// (-- api-linter: core::0142::time-field-names=disabled
	//
	//	aip.dev/not-precedent: Not following linter rules. --)
	CreatedTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// The date and time when the service was last modified.
	// Will not be set if the service has never been modified.
	// (-- api-linter: core::0142::time-field-names=disabled
	//
	//	aip.dev/not-precedent: Not following linter rules. --)
	LastModifiedTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_modified_time,json=lastModifiedTime,proto3" json:"last_modified_time,omitempty"`
	// contains filtered or unexported fields
}

A per-namespace binding from service name to URL that is used by the service to invoke Nexus requests that are initiated by workflows.

func (*OutgoingService) Descriptor deprecated added in v1.30.1 

func (*OutgoingService) Descriptor() ([]byte, []int)

Deprecated: Use OutgoingService.ProtoReflect.Descriptor instead.

func (*OutgoingService) Equal added in v1.30.1 

func (this *OutgoingService) Equal(that interface{}) bool

Equal returns whether two OutgoingService values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*OutgoingService) GetCreatedTime added in v1.30.1 

func (x *OutgoingService) GetCreatedTime() *timestamppb.Timestamp

func (*OutgoingService) GetLastModifiedTime added in v1.30.1 

func (x *OutgoingService) GetLastModifiedTime() *timestamppb.Timestamp

func (*OutgoingService) GetName added in v1.30.1 

func (x *OutgoingService) GetName() string

func (*OutgoingService) GetSpec added in v1.30.1 

func (x *OutgoingService) GetSpec() *OutgoingServiceSpec

func (*OutgoingService) GetVersion added in v1.30.1 

func (x *OutgoingService) GetVersion() int64

func (*OutgoingService) Marshal added in v1.30.1 

func (val *OutgoingService) Marshal() ([]byte, error)

Marshal an object of type OutgoingService to the protobuf v3 wire format

func (*OutgoingService) ProtoMessage added in v1.30.1 

func (*OutgoingService) ProtoMessage()

func (*OutgoingService) ProtoReflect added in v1.30.1 

func (x *OutgoingService) ProtoReflect() protoreflect.Message

func (*OutgoingService) Reset added in v1.30.1 

func (x *OutgoingService) Reset()

func (*OutgoingService) Size added in v1.30.1 

func (val *OutgoingService) Size() int

Size returns the size of the object, in bytes, once serialized

func (*OutgoingService) String added in v1.30.1 

func (x *OutgoingService) String() string

func (*OutgoingService) Unmarshal added in v1.30.1 

func (val *OutgoingService) Unmarshal(buf []byte) error

Unmarshal an object of type OutgoingService from the protobuf v3 wire format

type OutgoingServiceSpec added in v1.30.1 

type OutgoingServiceSpec struct {

	// URL to invoke requests.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

Contains mutable fields for an OutgoingService.

func (*OutgoingServiceSpec) Descriptor deprecated added in v1.30.1 

func (*OutgoingServiceSpec) Descriptor() ([]byte, []int)

Deprecated: Use OutgoingServiceSpec.ProtoReflect.Descriptor instead.

func (*OutgoingServiceSpec) Equal added in v1.30.1 

func (this *OutgoingServiceSpec) Equal(that interface{}) bool

Equal returns whether two OutgoingServiceSpec values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*OutgoingServiceSpec) GetUrl added in v1.30.1 

func (x *OutgoingServiceSpec) GetUrl() string

func (*OutgoingServiceSpec) Marshal added in v1.30.1 

func (val *OutgoingServiceSpec) Marshal() ([]byte, error)

Marshal an object of type OutgoingServiceSpec to the protobuf v3 wire format

func (*OutgoingServiceSpec) ProtoMessage added in v1.30.1 

func (*OutgoingServiceSpec) ProtoMessage()

func (*OutgoingServiceSpec) ProtoReflect added in v1.30.1 

func (x *OutgoingServiceSpec) ProtoReflect() protoreflect.Message

func (*OutgoingServiceSpec) Reset added in v1.30.1 

func (x *OutgoingServiceSpec) Reset()

func (*OutgoingServiceSpec) Size added in v1.30.1 

func (val *OutgoingServiceSpec) Size() int

Size returns the size of the object, in bytes, once serialized

func (*OutgoingServiceSpec) String added in v1.30.1 

func (x *OutgoingServiceSpec) String() string

func (*OutgoingServiceSpec) Unmarshal added in v1.30.1 

func (val *OutgoingServiceSpec) Unmarshal(buf []byte) error

Unmarshal an object of type OutgoingServiceSpec from the protobuf v3 wire format

type Request 

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
}

A Nexus request.

func (*Request) Descriptor deprecated 

func (*Request) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) Equal 

func (this *Request) Equal(that interface{}) bool

Equal returns whether two Request values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*Request) GetCancelOperation 

func (x *Request) GetCancelOperation() *CancelOperationRequest

func (*Request) GetHeader 

func (x *Request) GetHeader() map[string]string

func (*Request) GetStartOperation 

func (x *Request) GetStartOperation() *StartOperationRequest

func (*Request) GetVariant 

func (m *Request) GetVariant() isRequest_Variant

func (*Request) Marshal 

func (val *Request) Marshal() ([]byte, error)

Marshal an object of type Request to the protobuf v3 wire format

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect 

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) Size 

func (val *Request) Size() int

Size returns the size of the object, in bytes, once serialized

func (*Request) String 

func (x *Request) String() string

func (*Request) Unmarshal 

func (val *Request) Unmarshal(buf []byte) error

Unmarshal an object of type Request from the protobuf v3 wire format

type Request_CancelOperation 

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

type Request_StartOperation 

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

type Response 

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
}

A response indicating that the handler has successfully processed a request.

func (*Response) Descriptor deprecated 

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) Equal 

func (this *Response) Equal(that interface{}) bool

Equal returns whether two Response values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*Response) GetCancelOperation 

func (x *Response) GetCancelOperation() *CancelOperationResponse

func (*Response) GetStartOperation 

func (x *Response) GetStartOperation() *StartOperationResponse

func (*Response) GetVariant 

func (m *Response) GetVariant() isResponse_Variant

func (*Response) Marshal 

func (val *Response) Marshal() ([]byte, error)

Marshal an object of type Response to the protobuf v3 wire format

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) Size 

func (val *Response) Size() int

Size returns the size of the object, in bytes, once serialized

func (*Response) String 

func (x *Response) String() string

func (*Response) Unmarshal 

func (val *Response) Unmarshal(buf []byte) error

Unmarshal an object of type Response from the protobuf v3 wire format

type Response_CancelOperation 

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

type Response_StartOperation 

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

type StartOperationRequest 

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
}

A request to start an operation.

func (*StartOperationRequest) Descriptor deprecated 

func (*StartOperationRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartOperationRequest.ProtoReflect.Descriptor instead.

func (*StartOperationRequest) Equal 

func (this *StartOperationRequest) Equal(that interface{}) bool

Equal returns whether two StartOperationRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StartOperationRequest) GetCallback 

func (x *StartOperationRequest) GetCallback() string

func (*StartOperationRequest) GetOperation 

func (x *StartOperationRequest) GetOperation() string

func (*StartOperationRequest) GetPayload 

func (x *StartOperationRequest) GetPayload() *v1.Payload

func (*StartOperationRequest) GetRequestId 

func (x *StartOperationRequest) GetRequestId() string

func (*StartOperationRequest) Marshal 

func (val *StartOperationRequest) Marshal() ([]byte, error)

Marshal an object of type StartOperationRequest to the protobuf v3 wire format

func (*StartOperationRequest) ProtoMessage 

func (*StartOperationRequest) ProtoMessage()

func (*StartOperationRequest) ProtoReflect 

func (x *StartOperationRequest) ProtoReflect() protoreflect.Message

func (*StartOperationRequest) Reset 

func (x *StartOperationRequest) Reset()

func (*StartOperationRequest) Size 

func (val *StartOperationRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StartOperationRequest) String 

func (x *StartOperationRequest) String() string

func (*StartOperationRequest) Unmarshal 

func (val *StartOperationRequest) Unmarshal(buf []byte) error

Unmarshal an object of type StartOperationRequest from the protobuf v3 wire format

type StartOperationResponse 

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
}

Response variant for StartOperationRequest.

func (*StartOperationResponse) Descriptor deprecated 

func (*StartOperationResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartOperationResponse.ProtoReflect.Descriptor instead.

func (*StartOperationResponse) Equal 

func (this *StartOperationResponse) Equal(that interface{}) bool

Equal returns whether two StartOperationResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StartOperationResponse) GetAsyncSuccess 

func (x *StartOperationResponse) GetAsyncSuccess() *StartOperationResponse_Async

func (*StartOperationResponse) GetOperationError 

func (x *StartOperationResponse) GetOperationError() *UnsuccessfulOperationError

func (*StartOperationResponse) GetSyncSuccess 

func (x *StartOperationResponse) GetSyncSuccess() *StartOperationResponse_Sync

func (*StartOperationResponse) GetVariant 

func (m *StartOperationResponse) GetVariant() isStartOperationResponse_Variant

func (*StartOperationResponse) Marshal 

func (val *StartOperationResponse) Marshal() ([]byte, error)

Marshal an object of type StartOperationResponse to the protobuf v3 wire format

func (*StartOperationResponse) ProtoMessage 

func (*StartOperationResponse) ProtoMessage()

func (*StartOperationResponse) ProtoReflect 

func (x *StartOperationResponse) ProtoReflect() protoreflect.Message

func (*StartOperationResponse) Reset 

func (x *StartOperationResponse) Reset()

func (*StartOperationResponse) Size 

func (val *StartOperationResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StartOperationResponse) String 

func (x *StartOperationResponse) String() string

func (*StartOperationResponse) Unmarshal 

func (val *StartOperationResponse) Unmarshal(buf []byte) error

Unmarshal an object of type StartOperationResponse from the protobuf v3 wire format

type StartOperationResponse_Async 

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
}

The operation will complete asynchronously. The returned ID can be used to reference this operation.

func (*StartOperationResponse_Async) Descriptor deprecated 

func (*StartOperationResponse_Async) Descriptor() ([]byte, []int)

Deprecated: Use StartOperationResponse_Async.ProtoReflect.Descriptor instead.

func (*StartOperationResponse_Async) GetOperationId 

func (x *StartOperationResponse_Async) GetOperationId() string

func (*StartOperationResponse_Async) ProtoMessage 

func (*StartOperationResponse_Async) ProtoMessage()

func (*StartOperationResponse_Async) ProtoReflect 

func (x *StartOperationResponse_Async) ProtoReflect() protoreflect.Message

func (*StartOperationResponse_Async) Reset 

func (x *StartOperationResponse_Async) Reset()

func (*StartOperationResponse_Async) String 

func (x *StartOperationResponse_Async) String() string

type StartOperationResponse_AsyncSuccess 

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

type StartOperationResponse_OperationError 

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 

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

An operation completed successfully.

func (*StartOperationResponse_Sync) Descriptor deprecated 

func (*StartOperationResponse_Sync) Descriptor() ([]byte, []int)

Deprecated: Use StartOperationResponse_Sync.ProtoReflect.Descriptor instead.

func (*StartOperationResponse_Sync) GetPayload 

func (x *StartOperationResponse_Sync) GetPayload() *v1.Payload

func (*StartOperationResponse_Sync) ProtoMessage 

func (*StartOperationResponse_Sync) ProtoMessage()

func (*StartOperationResponse_Sync) ProtoReflect 

func (x *StartOperationResponse_Sync) ProtoReflect() protoreflect.Message

func (*StartOperationResponse_Sync) Reset 

func (x *StartOperationResponse_Sync) Reset()

func (*StartOperationResponse_Sync) String 

func (x *StartOperationResponse_Sync) String() string

type StartOperationResponse_SyncSuccess 

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

type UnsuccessfulOperationError 

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
}

func (*UnsuccessfulOperationError) Descriptor deprecated 

func (*UnsuccessfulOperationError) Descriptor() ([]byte, []int)

Deprecated: Use UnsuccessfulOperationError.ProtoReflect.Descriptor instead.

func (*UnsuccessfulOperationError) Equal 

func (this *UnsuccessfulOperationError) Equal(that interface{}) bool

Equal returns whether two UnsuccessfulOperationError values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UnsuccessfulOperationError) GetFailure 

func (x *UnsuccessfulOperationError) GetFailure() *Failure

func (*UnsuccessfulOperationError) GetOperationState 

func (x *UnsuccessfulOperationError) GetOperationState() string

func (*UnsuccessfulOperationError) Marshal 

func (val *UnsuccessfulOperationError) Marshal() ([]byte, error)

Marshal an object of type UnsuccessfulOperationError to the protobuf v3 wire format

func (*UnsuccessfulOperationError) ProtoMessage 

func (*UnsuccessfulOperationError) ProtoMessage()

func (*UnsuccessfulOperationError) ProtoReflect 

func (x *UnsuccessfulOperationError) ProtoReflect() protoreflect.Message

func (*UnsuccessfulOperationError) Reset 

func (x *UnsuccessfulOperationError) Reset()

func (*UnsuccessfulOperationError) Size 

func (val *UnsuccessfulOperationError) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UnsuccessfulOperationError) String 

func (x *UnsuccessfulOperationError) String() string

func (*UnsuccessfulOperationError) Unmarshal 

func (val *UnsuccessfulOperationError) Unmarshal(buf []byte) error

Unmarshal an object of type UnsuccessfulOperationError from the protobuf v3 wire format

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.