nexus

package
v0.55.0 Latest Latest
Warning

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

 Go to latest Published: Feb 17, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type AllowedCloudNamespacePolicySpec 

type AllowedCloudNamespacePolicySpec struct {
	// The namespace that is allowed to call into this endpoint. Calling namespace must be in same account as the endpoint.
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
}

func (*AllowedCloudNamespacePolicySpec) Descriptor 

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

func (*AllowedCloudNamespacePolicySpec) Equal 

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

func (*AllowedCloudNamespacePolicySpec) GetNamespaceId 

func (m *AllowedCloudNamespacePolicySpec) GetNamespaceId() string

func (*AllowedCloudNamespacePolicySpec) GoString 

func (this *AllowedCloudNamespacePolicySpec) GoString() string

func (*AllowedCloudNamespacePolicySpec) Marshal 

func (m *AllowedCloudNamespacePolicySpec) Marshal() (dAtA []byte, err error)

func (*AllowedCloudNamespacePolicySpec) MarshalTo 

func (m *AllowedCloudNamespacePolicySpec) MarshalTo(dAtA []byte) (int, error)

func (*AllowedCloudNamespacePolicySpec) MarshalToSizedBuffer 

func (m *AllowedCloudNamespacePolicySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AllowedCloudNamespacePolicySpec) ProtoMessage 

func (*AllowedCloudNamespacePolicySpec) ProtoMessage()

func (*AllowedCloudNamespacePolicySpec) Reset 

func (m *AllowedCloudNamespacePolicySpec) Reset()

func (*AllowedCloudNamespacePolicySpec) Size 

func (m *AllowedCloudNamespacePolicySpec) Size() (n int)

func (*AllowedCloudNamespacePolicySpec) String 

func (this *AllowedCloudNamespacePolicySpec) String() string

func (*AllowedCloudNamespacePolicySpec) Unmarshal 

func (m *AllowedCloudNamespacePolicySpec) Unmarshal(dAtA []byte) error

func (*AllowedCloudNamespacePolicySpec) XXX_DiscardUnknown 

func (m *AllowedCloudNamespacePolicySpec) XXX_DiscardUnknown()

func (*AllowedCloudNamespacePolicySpec) XXX_Marshal 

func (m *AllowedCloudNamespacePolicySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AllowedCloudNamespacePolicySpec) XXX_Merge 

func (m *AllowedCloudNamespacePolicySpec) XXX_Merge(src proto.Message)

func (*AllowedCloudNamespacePolicySpec) XXX_Size 

func (m *AllowedCloudNamespacePolicySpec) XXX_Size() int

func (*AllowedCloudNamespacePolicySpec) XXX_Unmarshal 

func (m *AllowedCloudNamespacePolicySpec) XXX_Unmarshal(b []byte) error

type Endpoint 

type Endpoint struct {
	// The id of the endpoint. This is generated by the server and is immutable.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The current version of the endpoint specification.
	// The next update operation must include this version.
	ResourceVersion string `protobuf:"bytes,2,opt,name=resource_version,json=resourceVersion,proto3" json:"resource_version,omitempty"`
	// The endpoint specification.
	Spec *EndpointSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// The current state of the endpoint.
	// For any failed state, reach out to Temporal Cloud support for remediation.
	State v11.ResourceState `protobuf:"varint,4,opt,name=state,proto3,enum=temporal.api.cloud.resource.v1.ResourceState" json:"state,omitempty"`
	// The id of any ongoing async operation that is creating, updating, or deleting the endpoint, if any.
	AsyncOperationId string `protobuf:"bytes,5,opt,name=async_operation_id,json=asyncOperationId,proto3" json:"async_operation_id,omitempty"`
	// The date and time when the endpoint was created.
	CreatedTime *types.Timestamp `protobuf:"bytes,6,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// The date and time when the endpoint was last modified.
	LastModifiedTime *types.Timestamp `protobuf:"bytes,7,opt,name=last_modified_time,json=lastModifiedTime,proto3" json:"last_modified_time,omitempty"`
	// The id of the project this endpoint belongs to.
	// temporal:dev
	ProjectId string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
}

An endpoint that receives and then routes Nexus requests

func (*Endpoint) Descriptor 

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

func (*Endpoint) Equal 

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

func (*Endpoint) GetAsyncOperationId 

func (m *Endpoint) GetAsyncOperationId() string

func (*Endpoint) GetCreatedTime 

func (m *Endpoint) GetCreatedTime() *types.Timestamp

func (*Endpoint) GetId 

func (m *Endpoint) GetId() string

func (*Endpoint) GetLastModifiedTime 

func (m *Endpoint) GetLastModifiedTime() *types.Timestamp

func (*Endpoint) GetProjectId added in v0.51.0 

func (m *Endpoint) GetProjectId() string

func (*Endpoint) GetResourceVersion 

func (m *Endpoint) GetResourceVersion() string

func (*Endpoint) GetSpec 

func (m *Endpoint) GetSpec() *EndpointSpec

func (*Endpoint) GetState 

func (m *Endpoint) GetState() v11.ResourceState

func (*Endpoint) GoString 

func (this *Endpoint) GoString() string

func (*Endpoint) Marshal 

func (m *Endpoint) Marshal() (dAtA []byte, err error)

func (*Endpoint) MarshalTo 

func (m *Endpoint) MarshalTo(dAtA []byte) (int, error)

func (*Endpoint) MarshalToSizedBuffer 

func (m *Endpoint) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) Reset 

func (m *Endpoint) Reset()

func (*Endpoint) Size 

func (m *Endpoint) Size() (n int)

func (*Endpoint) String 

func (this *Endpoint) String() string

func (*Endpoint) Unmarshal 

func (m *Endpoint) Unmarshal(dAtA []byte) error

func (*Endpoint) XXX_DiscardUnknown 

func (m *Endpoint) XXX_DiscardUnknown()

func (*Endpoint) XXX_Marshal 

func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Endpoint) XXX_Merge 

func (m *Endpoint) XXX_Merge(src proto.Message)

func (*Endpoint) XXX_Size 

func (m *Endpoint) XXX_Size() int

func (*Endpoint) XXX_Unmarshal 

func (m *Endpoint) XXX_Unmarshal(b []byte) error

type EndpointPolicySpec 

type EndpointPolicySpec struct {
	// Types that are valid to be assigned to Variant:
	//
	//	*EndpointPolicySpec_AllowedCloudNamespacePolicySpec
	Variant isEndpointPolicySpec_Variant `protobuf_oneof:"variant"`
}

func (*EndpointPolicySpec) Descriptor 

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

func (*EndpointPolicySpec) Equal 

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

func (*EndpointPolicySpec) GetAllowedCloudNamespacePolicySpec 

func (m *EndpointPolicySpec) GetAllowedCloudNamespacePolicySpec() *AllowedCloudNamespacePolicySpec

func (*EndpointPolicySpec) GetVariant added in v0.30.0 

func (m *EndpointPolicySpec) GetVariant() isEndpointPolicySpec_Variant

func (*EndpointPolicySpec) GoString 

func (this *EndpointPolicySpec) GoString() string

func (*EndpointPolicySpec) Marshal 

func (m *EndpointPolicySpec) Marshal() (dAtA []byte, err error)

func (*EndpointPolicySpec) MarshalTo 

func (m *EndpointPolicySpec) MarshalTo(dAtA []byte) (int, error)

func (*EndpointPolicySpec) MarshalToSizedBuffer 

func (m *EndpointPolicySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndpointPolicySpec) ProtoMessage 

func (*EndpointPolicySpec) ProtoMessage()

func (*EndpointPolicySpec) Reset 

func (m *EndpointPolicySpec) Reset()

func (*EndpointPolicySpec) Size 

func (m *EndpointPolicySpec) Size() (n int)

func (*EndpointPolicySpec) String 

func (this *EndpointPolicySpec) String() string

func (*EndpointPolicySpec) Unmarshal 

func (m *EndpointPolicySpec) Unmarshal(dAtA []byte) error

func (*EndpointPolicySpec) XXX_DiscardUnknown 

func (m *EndpointPolicySpec) XXX_DiscardUnknown()

func (*EndpointPolicySpec) XXX_Marshal 

func (m *EndpointPolicySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointPolicySpec) XXX_Merge 

func (m *EndpointPolicySpec) XXX_Merge(src proto.Message)

func (*EndpointPolicySpec) XXX_OneofWrappers added in v0.30.0 

func (*EndpointPolicySpec) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*EndpointPolicySpec) XXX_Size 

func (m *EndpointPolicySpec) XXX_Size() int

func (*EndpointPolicySpec) XXX_Unmarshal 

func (m *EndpointPolicySpec) XXX_Unmarshal(b []byte) error

type EndpointPolicySpec_AllowedCloudNamespacePolicySpec added in v0.30.0 

type EndpointPolicySpec_AllowedCloudNamespacePolicySpec struct {
	AllowedCloudNamespacePolicySpec *AllowedCloudNamespacePolicySpec `` /* 166-byte string literal not displayed */
}

func (*EndpointPolicySpec_AllowedCloudNamespacePolicySpec) Equal added in v0.30.0 

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

func (*EndpointPolicySpec_AllowedCloudNamespacePolicySpec) GoString added in v0.30.0 

func (this *EndpointPolicySpec_AllowedCloudNamespacePolicySpec) GoString() string

func (*EndpointPolicySpec_AllowedCloudNamespacePolicySpec) MarshalTo added in v0.30.0 

func (m *EndpointPolicySpec_AllowedCloudNamespacePolicySpec) MarshalTo(dAtA []byte) (int, error)

func (*EndpointPolicySpec_AllowedCloudNamespacePolicySpec) MarshalToSizedBuffer added in v0.30.0 

func (m *EndpointPolicySpec_AllowedCloudNamespacePolicySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndpointPolicySpec_AllowedCloudNamespacePolicySpec) Size added in v0.30.0 

func (m *EndpointPolicySpec_AllowedCloudNamespacePolicySpec) Size() (n int)

func (*EndpointPolicySpec_AllowedCloudNamespacePolicySpec) String added in v0.30.0 

func (this *EndpointPolicySpec_AllowedCloudNamespacePolicySpec) String() string

type EndpointSpec 

type EndpointSpec struct {
	// The name of the endpoint. Must be unique within an account.
	// The name must match `^[a-zA-Z][a-zA-Z0-9\-]*[a-zA-Z0-9]$`.
	// This field is mutable.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Indicates where the endpoint should forward received nexus requests to.
	TargetSpec *EndpointTargetSpec `protobuf:"bytes,2,opt,name=target_spec,json=targetSpec,proto3" json:"target_spec,omitempty"`
	// The set of policies (e.g. authorization) for the endpoint. Each request's caller
	// must match with at least one of the specs to be accepted by the endpoint.
	// This field is mutable.
	PolicySpecs []*EndpointPolicySpec `protobuf:"bytes,3,rep,name=policy_specs,json=policySpecs,proto3" json:"policy_specs,omitempty"`
	// Deprecated: Not supported after v0.4.0 api version. Use description instead.
	// temporal:versioning:max_version=v0.4.0
	DescriptionDeprecated string `protobuf:"bytes,4,opt,name=description_deprecated,json=descriptionDeprecated,proto3" json:"description_deprecated,omitempty"` // Deprecated: Do not use.
	// The markdown description of the endpoint - optional.
	// temporal:versioning:min_version=v0.4.0
	Description *v1.Payload `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
}

func (*EndpointSpec) Descriptor 

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

func (*EndpointSpec) Equal 

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

func (*EndpointSpec) GetDescription added in v0.26.0 

func (m *EndpointSpec) GetDescription() *v1.Payload

func (*EndpointSpec) GetDescriptionDeprecated deprecated added in v0.37.0 

func (m *EndpointSpec) GetDescriptionDeprecated() string

Deprecated: Do not use.

func (*EndpointSpec) GetName 

func (m *EndpointSpec) GetName() string

func (*EndpointSpec) GetPolicySpecs 

func (m *EndpointSpec) GetPolicySpecs() []*EndpointPolicySpec

func (*EndpointSpec) GetTargetSpec 

func (m *EndpointSpec) GetTargetSpec() *EndpointTargetSpec

func (*EndpointSpec) GoString 

func (this *EndpointSpec) GoString() string

func (*EndpointSpec) Marshal 

func (m *EndpointSpec) Marshal() (dAtA []byte, err error)

func (*EndpointSpec) MarshalTo 

func (m *EndpointSpec) MarshalTo(dAtA []byte) (int, error)

func (*EndpointSpec) MarshalToSizedBuffer 

func (m *EndpointSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndpointSpec) ProtoMessage 

func (*EndpointSpec) ProtoMessage()

func (*EndpointSpec) Reset 

func (m *EndpointSpec) Reset()

func (*EndpointSpec) Size 

func (m *EndpointSpec) Size() (n int)

func (*EndpointSpec) String 

func (this *EndpointSpec) String() string

func (*EndpointSpec) Unmarshal 

func (m *EndpointSpec) Unmarshal(dAtA []byte) error

func (*EndpointSpec) XXX_DiscardUnknown 

func (m *EndpointSpec) XXX_DiscardUnknown()

func (*EndpointSpec) XXX_Marshal 

func (m *EndpointSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointSpec) XXX_Merge 

func (m *EndpointSpec) XXX_Merge(src proto.Message)

func (*EndpointSpec) XXX_Size 

func (m *EndpointSpec) XXX_Size() int

func (*EndpointSpec) XXX_Unmarshal 

func (m *EndpointSpec) XXX_Unmarshal(b []byte) error

type EndpointTargetSpec 

type EndpointTargetSpec struct {
	// Types that are valid to be assigned to Variant:
	//
	//	*EndpointTargetSpec_WorkerTargetSpec
	Variant isEndpointTargetSpec_Variant `protobuf_oneof:"variant"`
}

func (*EndpointTargetSpec) Descriptor 

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

func (*EndpointTargetSpec) Equal 

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

func (*EndpointTargetSpec) GetVariant added in v0.30.0 

func (m *EndpointTargetSpec) GetVariant() isEndpointTargetSpec_Variant

func (*EndpointTargetSpec) GetWorkerTargetSpec 

func (m *EndpointTargetSpec) GetWorkerTargetSpec() *WorkerTargetSpec

func (*EndpointTargetSpec) GoString 

func (this *EndpointTargetSpec) GoString() string

func (*EndpointTargetSpec) Marshal 

func (m *EndpointTargetSpec) Marshal() (dAtA []byte, err error)

func (*EndpointTargetSpec) MarshalTo 

func (m *EndpointTargetSpec) MarshalTo(dAtA []byte) (int, error)

func (*EndpointTargetSpec) MarshalToSizedBuffer 

func (m *EndpointTargetSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndpointTargetSpec) ProtoMessage 

func (*EndpointTargetSpec) ProtoMessage()

func (*EndpointTargetSpec) Reset 

func (m *EndpointTargetSpec) Reset()

func (*EndpointTargetSpec) Size 

func (m *EndpointTargetSpec) Size() (n int)

func (*EndpointTargetSpec) String 

func (this *EndpointTargetSpec) String() string

func (*EndpointTargetSpec) Unmarshal 

func (m *EndpointTargetSpec) Unmarshal(dAtA []byte) error

func (*EndpointTargetSpec) XXX_DiscardUnknown 

func (m *EndpointTargetSpec) XXX_DiscardUnknown()

func (*EndpointTargetSpec) XXX_Marshal 

func (m *EndpointTargetSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointTargetSpec) XXX_Merge 

func (m *EndpointTargetSpec) XXX_Merge(src proto.Message)

func (*EndpointTargetSpec) XXX_OneofWrappers added in v0.30.0 

func (*EndpointTargetSpec) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*EndpointTargetSpec) XXX_Size 

func (m *EndpointTargetSpec) XXX_Size() int

func (*EndpointTargetSpec) XXX_Unmarshal 

func (m *EndpointTargetSpec) XXX_Unmarshal(b []byte) error

type EndpointTargetSpec_WorkerTargetSpec added in v0.30.0 

type EndpointTargetSpec_WorkerTargetSpec struct {
	WorkerTargetSpec *WorkerTargetSpec `protobuf:"bytes,1,opt,name=worker_target_spec,json=workerTargetSpec,proto3,oneof" json:"worker_target_spec,omitempty"`
}

func (*EndpointTargetSpec_WorkerTargetSpec) Equal added in v0.30.0 

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

func (*EndpointTargetSpec_WorkerTargetSpec) GoString added in v0.30.0 

func (this *EndpointTargetSpec_WorkerTargetSpec) GoString() string

func (*EndpointTargetSpec_WorkerTargetSpec) MarshalTo added in v0.30.0 

func (m *EndpointTargetSpec_WorkerTargetSpec) MarshalTo(dAtA []byte) (int, error)

func (*EndpointTargetSpec_WorkerTargetSpec) MarshalToSizedBuffer added in v0.30.0 

func (m *EndpointTargetSpec_WorkerTargetSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EndpointTargetSpec_WorkerTargetSpec) Size added in v0.30.0 

func (m *EndpointTargetSpec_WorkerTargetSpec) Size() (n int)

func (*EndpointTargetSpec_WorkerTargetSpec) String added in v0.30.0 

func (this *EndpointTargetSpec_WorkerTargetSpec) String() string

type WorkerTargetSpec 

type WorkerTargetSpec struct {
	// The target cloud namespace to route requests to. Namespace must be in same account as the endpoint. This field is mutable.
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// The task queue on the cloud namespace to route requests to. This field is mutable.
	TaskQueue string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
}

func (*WorkerTargetSpec) Descriptor 

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

func (*WorkerTargetSpec) Equal 

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

func (*WorkerTargetSpec) GetNamespaceId 

func (m *WorkerTargetSpec) GetNamespaceId() string

func (*WorkerTargetSpec) GetTaskQueue 

func (m *WorkerTargetSpec) GetTaskQueue() string

func (*WorkerTargetSpec) GoString 

func (this *WorkerTargetSpec) GoString() string

func (*WorkerTargetSpec) Marshal 

func (m *WorkerTargetSpec) Marshal() (dAtA []byte, err error)

func (*WorkerTargetSpec) MarshalTo 

func (m *WorkerTargetSpec) MarshalTo(dAtA []byte) (int, error)

func (*WorkerTargetSpec) MarshalToSizedBuffer 

func (m *WorkerTargetSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkerTargetSpec) ProtoMessage 

func (*WorkerTargetSpec) ProtoMessage()

func (*WorkerTargetSpec) Reset 

func (m *WorkerTargetSpec) Reset()

func (*WorkerTargetSpec) Size 

func (m *WorkerTargetSpec) Size() (n int)

func (*WorkerTargetSpec) String 

func (this *WorkerTargetSpec) String() string

func (*WorkerTargetSpec) Unmarshal 

func (m *WorkerTargetSpec) Unmarshal(dAtA []byte) error

func (*WorkerTargetSpec) XXX_DiscardUnknown 

func (m *WorkerTargetSpec) XXX_DiscardUnknown()

func (*WorkerTargetSpec) XXX_Marshal 

func (m *WorkerTargetSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerTargetSpec) XXX_Merge 

func (m *WorkerTargetSpec) XXX_Merge(src proto.Message)

func (*WorkerTargetSpec) XXX_Size 

func (m *WorkerTargetSpec) XXX_Size() int

func (*WorkerTargetSpec) XXX_Unmarshal 

func (m *WorkerTargetSpec) XXX_Unmarshal(b []byte) error

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.