Help us shape the future of Go! Take the 2026 Go Developer Survey

nexus

package
v0.45.0 Latest Latest
Warning

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

 Go to latest Published: Aug 13, 2025 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"`
}

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) 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.