Documentation
¶
Index ¶
- Variables
- type AWSPrivateLinkInfo
- func (*AWSPrivateLinkInfo) Descriptor() ([]byte, []int)
- func (this *AWSPrivateLinkInfo) Equal(that interface{}) bool
- func (m *AWSPrivateLinkInfo) GetAllowedPrincipalArns() []string
- func (m *AWSPrivateLinkInfo) GetVpcEndpointServiceNames() []string
- func (this *AWSPrivateLinkInfo) GoString() string
- func (m *AWSPrivateLinkInfo) Marshal() (dAtA []byte, err error)
- func (m *AWSPrivateLinkInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *AWSPrivateLinkInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AWSPrivateLinkInfo) ProtoMessage()
- func (m *AWSPrivateLinkInfo) Reset()
- func (m *AWSPrivateLinkInfo) Size() (n int)
- func (this *AWSPrivateLinkInfo) String() string
- func (m *AWSPrivateLinkInfo) Unmarshal(dAtA []byte) error
- func (m *AWSPrivateLinkInfo) XXX_DiscardUnknown()
- func (m *AWSPrivateLinkInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AWSPrivateLinkInfo) XXX_Merge(src proto.Message)
- func (m *AWSPrivateLinkInfo) XXX_Size() int
- func (m *AWSPrivateLinkInfo) XXX_Unmarshal(b []byte) error
- type ApiKeyAuthSpec
- func (*ApiKeyAuthSpec) Descriptor() ([]byte, []int)
- func (this *ApiKeyAuthSpec) Equal(that interface{}) bool
- func (m *ApiKeyAuthSpec) GetEnabled() bool
- func (this *ApiKeyAuthSpec) GoString() string
- func (m *ApiKeyAuthSpec) Marshal() (dAtA []byte, err error)
- func (m *ApiKeyAuthSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *ApiKeyAuthSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ApiKeyAuthSpec) ProtoMessage()
- func (m *ApiKeyAuthSpec) Reset()
- func (m *ApiKeyAuthSpec) Size() (n int)
- func (this *ApiKeyAuthSpec) String() string
- func (m *ApiKeyAuthSpec) Unmarshal(dAtA []byte) error
- func (m *ApiKeyAuthSpec) XXX_DiscardUnknown()
- func (m *ApiKeyAuthSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ApiKeyAuthSpec) XXX_Merge(src proto.Message)
- func (m *ApiKeyAuthSpec) XXX_Size() int
- func (m *ApiKeyAuthSpec) XXX_Unmarshal(b []byte) error
- type Capacity
- func (*Capacity) Descriptor() ([]byte, []int)
- func (this *Capacity) Equal(that interface{}) bool
- func (m *Capacity) GetCurrentMode() isCapacity_CurrentMode
- func (m *Capacity) GetLatestRequest() *Capacity_Request
- func (m *Capacity) GetOnDemand() *Capacity_OnDemand
- func (m *Capacity) GetProvisioned() *Capacity_Provisioned
- func (this *Capacity) GoString() string
- func (m *Capacity) Marshal() (dAtA []byte, err error)
- func (m *Capacity) MarshalTo(dAtA []byte) (int, error)
- func (m *Capacity) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Capacity) ProtoMessage()
- func (m *Capacity) Reset()
- func (m *Capacity) Size() (n int)
- func (this *Capacity) String() string
- func (m *Capacity) Unmarshal(dAtA []byte) error
- func (m *Capacity) XXX_DiscardUnknown()
- func (m *Capacity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Capacity) XXX_Merge(src proto.Message)
- func (*Capacity) XXX_OneofWrappers() []interface{}
- func (m *Capacity) XXX_Size() int
- func (m *Capacity) XXX_Unmarshal(b []byte) error
- type CapacitySpec
- func (*CapacitySpec) Descriptor() ([]byte, []int)
- func (this *CapacitySpec) Equal(that interface{}) bool
- func (m *CapacitySpec) GetOnDemand() *CapacitySpec_OnDemand
- func (m *CapacitySpec) GetProvisioned() *CapacitySpec_Provisioned
- func (m *CapacitySpec) GetSpec() isCapacitySpec_Spec
- func (this *CapacitySpec) GoString() string
- func (m *CapacitySpec) Marshal() (dAtA []byte, err error)
- func (m *CapacitySpec) MarshalTo(dAtA []byte) (int, error)
- func (m *CapacitySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CapacitySpec) ProtoMessage()
- func (m *CapacitySpec) Reset()
- func (m *CapacitySpec) Size() (n int)
- func (this *CapacitySpec) String() string
- func (m *CapacitySpec) Unmarshal(dAtA []byte) error
- func (m *CapacitySpec) XXX_DiscardUnknown()
- func (m *CapacitySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CapacitySpec) XXX_Merge(src proto.Message)
- func (*CapacitySpec) XXX_OneofWrappers() []interface{}
- func (m *CapacitySpec) XXX_Size() int
- func (m *CapacitySpec) XXX_Unmarshal(b []byte) error
- type CapacitySpec_OnDemand
- func (*CapacitySpec_OnDemand) Descriptor() ([]byte, []int)
- func (this *CapacitySpec_OnDemand) Equal(that interface{}) bool
- func (this *CapacitySpec_OnDemand) GoString() string
- func (m *CapacitySpec_OnDemand) Marshal() (dAtA []byte, err error)
- func (m *CapacitySpec_OnDemand) MarshalTo(dAtA []byte) (int, error)
- func (m *CapacitySpec_OnDemand) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CapacitySpec_OnDemand) ProtoMessage()
- func (m *CapacitySpec_OnDemand) Reset()
- func (m *CapacitySpec_OnDemand) Size() (n int)
- func (this *CapacitySpec_OnDemand) String() string
- func (m *CapacitySpec_OnDemand) Unmarshal(dAtA []byte) error
- func (m *CapacitySpec_OnDemand) XXX_DiscardUnknown()
- func (m *CapacitySpec_OnDemand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CapacitySpec_OnDemand) XXX_Merge(src proto.Message)
- func (m *CapacitySpec_OnDemand) XXX_Size() int
- func (m *CapacitySpec_OnDemand) XXX_Unmarshal(b []byte) error
- type CapacitySpec_OnDemand_
- func (this *CapacitySpec_OnDemand_) Equal(that interface{}) bool
- func (this *CapacitySpec_OnDemand_) GoString() string
- func (m *CapacitySpec_OnDemand_) MarshalTo(dAtA []byte) (int, error)
- func (m *CapacitySpec_OnDemand_) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *CapacitySpec_OnDemand_) Size() (n int)
- func (this *CapacitySpec_OnDemand_) String() string
- type CapacitySpec_Provisioned
- func (*CapacitySpec_Provisioned) Descriptor() ([]byte, []int)
- func (this *CapacitySpec_Provisioned) Equal(that interface{}) bool
- func (m *CapacitySpec_Provisioned) GetValue() float64
- func (this *CapacitySpec_Provisioned) GoString() string
- func (m *CapacitySpec_Provisioned) Marshal() (dAtA []byte, err error)
- func (m *CapacitySpec_Provisioned) MarshalTo(dAtA []byte) (int, error)
- func (m *CapacitySpec_Provisioned) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CapacitySpec_Provisioned) ProtoMessage()
- func (m *CapacitySpec_Provisioned) Reset()
- func (m *CapacitySpec_Provisioned) Size() (n int)
- func (this *CapacitySpec_Provisioned) String() string
- func (m *CapacitySpec_Provisioned) Unmarshal(dAtA []byte) error
- func (m *CapacitySpec_Provisioned) XXX_DiscardUnknown()
- func (m *CapacitySpec_Provisioned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CapacitySpec_Provisioned) XXX_Merge(src proto.Message)
- func (m *CapacitySpec_Provisioned) XXX_Size() int
- func (m *CapacitySpec_Provisioned) XXX_Unmarshal(b []byte) error
- type CapacitySpec_Provisioned_
- func (this *CapacitySpec_Provisioned_) Equal(that interface{}) bool
- func (this *CapacitySpec_Provisioned_) GoString() string
- func (m *CapacitySpec_Provisioned_) MarshalTo(dAtA []byte) (int, error)
- func (m *CapacitySpec_Provisioned_) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *CapacitySpec_Provisioned_) Size() (n int)
- func (this *CapacitySpec_Provisioned_) String() string
- type Capacity_OnDemand
- func (*Capacity_OnDemand) Descriptor() ([]byte, []int)
- func (this *Capacity_OnDemand) Equal(that interface{}) bool
- func (this *Capacity_OnDemand) GoString() string
- func (m *Capacity_OnDemand) Marshal() (dAtA []byte, err error)
- func (m *Capacity_OnDemand) MarshalTo(dAtA []byte) (int, error)
- func (m *Capacity_OnDemand) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Capacity_OnDemand) ProtoMessage()
- func (m *Capacity_OnDemand) Reset()
- func (m *Capacity_OnDemand) Size() (n int)
- func (this *Capacity_OnDemand) String() string
- func (m *Capacity_OnDemand) Unmarshal(dAtA []byte) error
- func (m *Capacity_OnDemand) XXX_DiscardUnknown()
- func (m *Capacity_OnDemand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Capacity_OnDemand) XXX_Merge(src proto.Message)
- func (m *Capacity_OnDemand) XXX_Size() int
- func (m *Capacity_OnDemand) XXX_Unmarshal(b []byte) error
- type Capacity_OnDemand_
- func (this *Capacity_OnDemand_) Equal(that interface{}) bool
- func (this *Capacity_OnDemand_) GoString() string
- func (m *Capacity_OnDemand_) MarshalTo(dAtA []byte) (int, error)
- func (m *Capacity_OnDemand_) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Capacity_OnDemand_) Size() (n int)
- func (this *Capacity_OnDemand_) String() string
- type Capacity_Provisioned
- func (*Capacity_Provisioned) Descriptor() ([]byte, []int)
- func (this *Capacity_Provisioned) Equal(that interface{}) bool
- func (m *Capacity_Provisioned) GetCurrentValue() float64
- func (this *Capacity_Provisioned) GoString() string
- func (m *Capacity_Provisioned) Marshal() (dAtA []byte, err error)
- func (m *Capacity_Provisioned) MarshalTo(dAtA []byte) (int, error)
- func (m *Capacity_Provisioned) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Capacity_Provisioned) ProtoMessage()
- func (m *Capacity_Provisioned) Reset()
- func (m *Capacity_Provisioned) Size() (n int)
- func (this *Capacity_Provisioned) String() string
- func (m *Capacity_Provisioned) Unmarshal(dAtA []byte) error
- func (m *Capacity_Provisioned) XXX_DiscardUnknown()
- func (m *Capacity_Provisioned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Capacity_Provisioned) XXX_Merge(src proto.Message)
- func (m *Capacity_Provisioned) XXX_Size() int
- func (m *Capacity_Provisioned) XXX_Unmarshal(b []byte) error
- type Capacity_Provisioned_
- func (this *Capacity_Provisioned_) Equal(that interface{}) bool
- func (this *Capacity_Provisioned_) GoString() string
- func (m *Capacity_Provisioned_) MarshalTo(dAtA []byte) (int, error)
- func (m *Capacity_Provisioned_) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Capacity_Provisioned_) Size() (n int)
- func (this *Capacity_Provisioned_) String() string
- type Capacity_Request
- func (*Capacity_Request) Descriptor() ([]byte, []int)
- func (this *Capacity_Request) Equal(that interface{}) bool
- func (m *Capacity_Request) GetAsyncOperationId() string
- func (m *Capacity_Request) GetEndTime() *types.Timestamp
- func (m *Capacity_Request) GetSpec() *CapacitySpec
- func (m *Capacity_Request) GetStartTime() *types.Timestamp
- func (m *Capacity_Request) GetState() Capacity_Request_State
- func (this *Capacity_Request) GoString() string
- func (m *Capacity_Request) Marshal() (dAtA []byte, err error)
- func (m *Capacity_Request) MarshalTo(dAtA []byte) (int, error)
- func (m *Capacity_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Capacity_Request) ProtoMessage()
- func (m *Capacity_Request) Reset()
- func (m *Capacity_Request) Size() (n int)
- func (this *Capacity_Request) String() string
- func (m *Capacity_Request) Unmarshal(dAtA []byte) error
- func (m *Capacity_Request) XXX_DiscardUnknown()
- func (m *Capacity_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Capacity_Request) XXX_Merge(src proto.Message)
- func (m *Capacity_Request) XXX_Size() int
- func (m *Capacity_Request) XXX_Unmarshal(b []byte) error
- type Capacity_Request_State
- type CertificateFilterSpec
- func (*CertificateFilterSpec) Descriptor() ([]byte, []int)
- func (this *CertificateFilterSpec) Equal(that interface{}) bool
- func (m *CertificateFilterSpec) GetCommonName() string
- func (m *CertificateFilterSpec) GetOrganization() string
- func (m *CertificateFilterSpec) GetOrganizationalUnit() string
- func (m *CertificateFilterSpec) GetSubjectAlternativeName() string
- func (this *CertificateFilterSpec) GoString() string
- func (m *CertificateFilterSpec) Marshal() (dAtA []byte, err error)
- func (m *CertificateFilterSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *CertificateFilterSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CertificateFilterSpec) ProtoMessage()
- func (m *CertificateFilterSpec) Reset()
- func (m *CertificateFilterSpec) Size() (n int)
- func (this *CertificateFilterSpec) String() string
- func (m *CertificateFilterSpec) Unmarshal(dAtA []byte) error
- func (m *CertificateFilterSpec) XXX_DiscardUnknown()
- func (m *CertificateFilterSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CertificateFilterSpec) XXX_Merge(src proto.Message)
- func (m *CertificateFilterSpec) XXX_Size() int
- func (m *CertificateFilterSpec) XXX_Unmarshal(b []byte) error
- type CodecServerSpec
- func (*CodecServerSpec) Descriptor() ([]byte, []int)
- func (this *CodecServerSpec) Equal(that interface{}) bool
- func (m *CodecServerSpec) GetCustomErrorMessage() *CodecServerSpec_CustomErrorMessage
- func (m *CodecServerSpec) GetEndpoint() string
- func (m *CodecServerSpec) GetIncludeCrossOriginCredentials() bool
- func (m *CodecServerSpec) GetPassAccessToken() bool
- func (this *CodecServerSpec) GoString() string
- func (m *CodecServerSpec) Marshal() (dAtA []byte, err error)
- func (m *CodecServerSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *CodecServerSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CodecServerSpec) ProtoMessage()
- func (m *CodecServerSpec) Reset()
- func (m *CodecServerSpec) Size() (n int)
- func (this *CodecServerSpec) String() string
- func (m *CodecServerSpec) Unmarshal(dAtA []byte) error
- func (m *CodecServerSpec) XXX_DiscardUnknown()
- func (m *CodecServerSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CodecServerSpec) XXX_Merge(src proto.Message)
- func (m *CodecServerSpec) XXX_Size() int
- func (m *CodecServerSpec) XXX_Unmarshal(b []byte) error
- type CodecServerSpec_CustomErrorMessage
- func (*CodecServerSpec_CustomErrorMessage) Descriptor() ([]byte, []int)
- func (this *CodecServerSpec_CustomErrorMessage) Equal(that interface{}) bool
- func (m *CodecServerSpec_CustomErrorMessage) GetDefault() *CodecServerSpec_CustomErrorMessage_ErrorMessage
- func (this *CodecServerSpec_CustomErrorMessage) GoString() string
- func (m *CodecServerSpec_CustomErrorMessage) Marshal() (dAtA []byte, err error)
- func (m *CodecServerSpec_CustomErrorMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *CodecServerSpec_CustomErrorMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CodecServerSpec_CustomErrorMessage) ProtoMessage()
- func (m *CodecServerSpec_CustomErrorMessage) Reset()
- func (m *CodecServerSpec_CustomErrorMessage) Size() (n int)
- func (this *CodecServerSpec_CustomErrorMessage) String() string
- func (m *CodecServerSpec_CustomErrorMessage) Unmarshal(dAtA []byte) error
- func (m *CodecServerSpec_CustomErrorMessage) XXX_DiscardUnknown()
- func (m *CodecServerSpec_CustomErrorMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CodecServerSpec_CustomErrorMessage) XXX_Merge(src proto.Message)
- func (m *CodecServerSpec_CustomErrorMessage) XXX_Size() int
- func (m *CodecServerSpec_CustomErrorMessage) XXX_Unmarshal(b []byte) error
- type CodecServerSpec_CustomErrorMessage_ErrorMessage
- func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) Descriptor() ([]byte, []int)
- func (this *CodecServerSpec_CustomErrorMessage_ErrorMessage) Equal(that interface{}) bool
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) GetLink() string
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) GetMessage() string
- func (this *CodecServerSpec_CustomErrorMessage_ErrorMessage) GoString() string
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) Marshal() (dAtA []byte, err error)
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) ProtoMessage()
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) Reset()
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) Size() (n int)
- func (this *CodecServerSpec_CustomErrorMessage_ErrorMessage) String() string
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) Unmarshal(dAtA []byte) error
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_DiscardUnknown()
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Merge(src proto.Message)
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Size() int
- func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Unmarshal(b []byte) error
- type Endpoints
- func (*Endpoints) Descriptor() ([]byte, []int)
- func (this *Endpoints) Equal(that interface{}) bool
- func (m *Endpoints) GetGrpcAddress() string
- func (m *Endpoints) GetMtlsGrpcAddress() string
- func (m *Endpoints) GetWebAddress() string
- func (this *Endpoints) GoString() string
- func (m *Endpoints) Marshal() (dAtA []byte, err error)
- func (m *Endpoints) MarshalTo(dAtA []byte) (int, error)
- func (m *Endpoints) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Endpoints) ProtoMessage()
- func (m *Endpoints) Reset()
- func (m *Endpoints) Size() (n int)
- func (this *Endpoints) String() string
- func (m *Endpoints) Unmarshal(dAtA []byte) error
- func (m *Endpoints) XXX_DiscardUnknown()
- func (m *Endpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Endpoints) XXX_Merge(src proto.Message)
- func (m *Endpoints) XXX_Size() int
- func (m *Endpoints) XXX_Unmarshal(b []byte) error
- type ExportSink
- func (*ExportSink) Descriptor() ([]byte, []int)
- func (this *ExportSink) Equal(that interface{}) bool
- func (m *ExportSink) GetErrorMessage() string
- func (m *ExportSink) GetHealth() ExportSink_Health
- func (m *ExportSink) GetLastHealthCheckTime() *types.Timestamp
- func (m *ExportSink) GetLatestDataExportTime() *types.Timestamp
- func (m *ExportSink) GetName() string
- func (m *ExportSink) GetResourceVersion() string
- func (m *ExportSink) GetSpec() *ExportSinkSpec
- func (m *ExportSink) GetState() v1.ResourceState
- func (this *ExportSink) GoString() string
- func (m *ExportSink) Marshal() (dAtA []byte, err error)
- func (m *ExportSink) MarshalTo(dAtA []byte) (int, error)
- func (m *ExportSink) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExportSink) ProtoMessage()
- func (m *ExportSink) Reset()
- func (m *ExportSink) Size() (n int)
- func (this *ExportSink) String() string
- func (m *ExportSink) Unmarshal(dAtA []byte) error
- func (m *ExportSink) XXX_DiscardUnknown()
- func (m *ExportSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExportSink) XXX_Merge(src proto.Message)
- func (m *ExportSink) XXX_Size() int
- func (m *ExportSink) XXX_Unmarshal(b []byte) error
- type ExportSinkSpec
- func (*ExportSinkSpec) Descriptor() ([]byte, []int)
- func (this *ExportSinkSpec) Equal(that interface{}) bool
- func (m *ExportSinkSpec) GetEnabled() bool
- func (m *ExportSinkSpec) GetGcs() *v12.GCSSpec
- func (m *ExportSinkSpec) GetName() string
- func (m *ExportSinkSpec) GetS3() *v12.S3Spec
- func (this *ExportSinkSpec) GoString() string
- func (m *ExportSinkSpec) Marshal() (dAtA []byte, err error)
- func (m *ExportSinkSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *ExportSinkSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExportSinkSpec) ProtoMessage()
- func (m *ExportSinkSpec) Reset()
- func (m *ExportSinkSpec) Size() (n int)
- func (this *ExportSinkSpec) String() string
- func (m *ExportSinkSpec) Unmarshal(dAtA []byte) error
- func (m *ExportSinkSpec) XXX_DiscardUnknown()
- func (m *ExportSinkSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExportSinkSpec) XXX_Merge(src proto.Message)
- func (m *ExportSinkSpec) XXX_Size() int
- func (m *ExportSinkSpec) XXX_Unmarshal(b []byte) error
- type ExportSink_Health
- type HighAvailabilitySpec
- func (*HighAvailabilitySpec) Descriptor() ([]byte, []int)
- func (this *HighAvailabilitySpec) Equal(that interface{}) bool
- func (m *HighAvailabilitySpec) GetDisableManagedFailover() bool
- func (m *HighAvailabilitySpec) GetPreferredPrimaryReplicaId() string
- func (this *HighAvailabilitySpec) GoString() string
- func (m *HighAvailabilitySpec) Marshal() (dAtA []byte, err error)
- func (m *HighAvailabilitySpec) MarshalTo(dAtA []byte) (int, error)
- func (m *HighAvailabilitySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HighAvailabilitySpec) ProtoMessage()
- func (m *HighAvailabilitySpec) Reset()
- func (m *HighAvailabilitySpec) Size() (n int)
- func (this *HighAvailabilitySpec) String() string
- func (m *HighAvailabilitySpec) Unmarshal(dAtA []byte) error
- func (m *HighAvailabilitySpec) XXX_DiscardUnknown()
- func (m *HighAvailabilitySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HighAvailabilitySpec) XXX_Merge(src proto.Message)
- func (m *HighAvailabilitySpec) XXX_Size() int
- func (m *HighAvailabilitySpec) XXX_Unmarshal(b []byte) error
- type LifecycleSpec
- func (*LifecycleSpec) Descriptor() ([]byte, []int)
- func (this *LifecycleSpec) Equal(that interface{}) bool
- func (m *LifecycleSpec) GetEnableDeleteProtection() bool
- func (this *LifecycleSpec) GoString() string
- func (m *LifecycleSpec) Marshal() (dAtA []byte, err error)
- func (m *LifecycleSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *LifecycleSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LifecycleSpec) ProtoMessage()
- func (m *LifecycleSpec) Reset()
- func (m *LifecycleSpec) Size() (n int)
- func (this *LifecycleSpec) String() string
- func (m *LifecycleSpec) Unmarshal(dAtA []byte) error
- func (m *LifecycleSpec) XXX_DiscardUnknown()
- func (m *LifecycleSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LifecycleSpec) XXX_Merge(src proto.Message)
- func (m *LifecycleSpec) XXX_Size() int
- func (m *LifecycleSpec) XXX_Unmarshal(b []byte) error
- type Limits
- func (*Limits) Descriptor() ([]byte, []int)
- func (this *Limits) Equal(that interface{}) bool
- func (m *Limits) GetActionsPerSecondLimit() int32
- func (this *Limits) GoString() string
- func (m *Limits) Marshal() (dAtA []byte, err error)
- func (m *Limits) MarshalTo(dAtA []byte) (int, error)
- func (m *Limits) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Limits) ProtoMessage()
- func (m *Limits) Reset()
- func (m *Limits) Size() (n int)
- func (this *Limits) String() string
- func (m *Limits) Unmarshal(dAtA []byte) error
- func (m *Limits) XXX_DiscardUnknown()
- func (m *Limits) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Limits) XXX_Merge(src proto.Message)
- func (m *Limits) XXX_Size() int
- func (m *Limits) XXX_Unmarshal(b []byte) error
- type Migration
- func (*Migration) Descriptor() ([]byte, []int)
- func (this *Migration) Equal(that interface{}) bool
- func (m *Migration) GetFailureMessage() string
- func (m *Migration) GetMigrationId() string
- func (m *Migration) GetReplicas() []*MigrationReplica
- func (m *Migration) GetReplicatedWorkflows() int64deprecated
- func (m *Migration) GetReplicatedWorkflowsRemaining() int64deprecated
- func (m *Migration) GetReplicationEstimate() *ReplicationEstimate
- func (m *Migration) GetSpec() *MigrationSpec
- func (m *Migration) GetState() Migration_State
- func (this *Migration) GoString() string
- func (m *Migration) Marshal() (dAtA []byte, err error)
- func (m *Migration) MarshalTo(dAtA []byte) (int, error)
- func (m *Migration) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Migration) ProtoMessage()
- func (m *Migration) Reset()
- func (m *Migration) Size() (n int)
- func (this *Migration) String() string
- func (m *Migration) Unmarshal(dAtA []byte) error
- func (m *Migration) XXX_DiscardUnknown()
- func (m *Migration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Migration) XXX_Merge(src proto.Message)
- func (m *Migration) XXX_Size() int
- func (m *Migration) XXX_Unmarshal(b []byte) error
- type MigrationReplica
- func (*MigrationReplica) Descriptor() ([]byte, []int)
- func (this *MigrationReplica) Equal(that interface{}) bool
- func (m *MigrationReplica) GetId() string
- func (m *MigrationReplica) GetState() MigrationReplica_State
- func (this *MigrationReplica) GoString() string
- func (m *MigrationReplica) Marshal() (dAtA []byte, err error)
- func (m *MigrationReplica) MarshalTo(dAtA []byte) (int, error)
- func (m *MigrationReplica) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MigrationReplica) ProtoMessage()
- func (m *MigrationReplica) Reset()
- func (m *MigrationReplica) Size() (n int)
- func (this *MigrationReplica) String() string
- func (m *MigrationReplica) Unmarshal(dAtA []byte) error
- func (m *MigrationReplica) XXX_DiscardUnknown()
- func (m *MigrationReplica) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MigrationReplica) XXX_Merge(src proto.Message)
- func (m *MigrationReplica) XXX_Size() int
- func (m *MigrationReplica) XXX_Unmarshal(b []byte) error
- type MigrationReplica_State
- type MigrationSpec
- func (*MigrationSpec) Descriptor() ([]byte, []int)
- func (this *MigrationSpec) Equal(that interface{}) bool
- func (m *MigrationSpec) GetMigrationEndpointId() string
- func (m *MigrationSpec) GetSpec() isMigrationSpec_Spec
- func (m *MigrationSpec) GetToCloudSpec() *MigrationToCloudSpec
- func (m *MigrationSpec) GetToSelfHostedSpec() *MigrationToSelfHostedSpec
- func (this *MigrationSpec) GoString() string
- func (m *MigrationSpec) Marshal() (dAtA []byte, err error)
- func (m *MigrationSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *MigrationSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MigrationSpec) ProtoMessage()
- func (m *MigrationSpec) Reset()
- func (m *MigrationSpec) Size() (n int)
- func (this *MigrationSpec) String() string
- func (m *MigrationSpec) Unmarshal(dAtA []byte) error
- func (m *MigrationSpec) XXX_DiscardUnknown()
- func (m *MigrationSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MigrationSpec) XXX_Merge(src proto.Message)
- func (*MigrationSpec) XXX_OneofWrappers() []interface{}
- func (m *MigrationSpec) XXX_Size() int
- func (m *MigrationSpec) XXX_Unmarshal(b []byte) error
- type MigrationSpec_ToCloudSpec
- func (this *MigrationSpec_ToCloudSpec) Equal(that interface{}) bool
- func (this *MigrationSpec_ToCloudSpec) GoString() string
- func (m *MigrationSpec_ToCloudSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *MigrationSpec_ToCloudSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *MigrationSpec_ToCloudSpec) Size() (n int)
- func (this *MigrationSpec_ToCloudSpec) String() string
- type MigrationSpec_ToSelfHostedSpec
- func (this *MigrationSpec_ToSelfHostedSpec) Equal(that interface{}) bool
- func (this *MigrationSpec_ToSelfHostedSpec) GoString() string
- func (m *MigrationSpec_ToSelfHostedSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *MigrationSpec_ToSelfHostedSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *MigrationSpec_ToSelfHostedSpec) Size() (n int)
- func (this *MigrationSpec_ToSelfHostedSpec) String() string
- type MigrationToCloudSpec
- func (*MigrationToCloudSpec) Descriptor() ([]byte, []int)
- func (this *MigrationToCloudSpec) Equal(that interface{}) bool
- func (m *MigrationToCloudSpec) GetSourceNamespace() string
- func (m *MigrationToCloudSpec) GetTargetNamespace() string
- func (this *MigrationToCloudSpec) GoString() string
- func (m *MigrationToCloudSpec) Marshal() (dAtA []byte, err error)
- func (m *MigrationToCloudSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *MigrationToCloudSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MigrationToCloudSpec) ProtoMessage()
- func (m *MigrationToCloudSpec) Reset()
- func (m *MigrationToCloudSpec) Size() (n int)
- func (this *MigrationToCloudSpec) String() string
- func (m *MigrationToCloudSpec) Unmarshal(dAtA []byte) error
- func (m *MigrationToCloudSpec) XXX_DiscardUnknown()
- func (m *MigrationToCloudSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MigrationToCloudSpec) XXX_Merge(src proto.Message)
- func (m *MigrationToCloudSpec) XXX_Size() int
- func (m *MigrationToCloudSpec) XXX_Unmarshal(b []byte) error
- type MigrationToSelfHostedSpec
- func (*MigrationToSelfHostedSpec) Descriptor() ([]byte, []int)
- func (this *MigrationToSelfHostedSpec) Equal(that interface{}) bool
- func (m *MigrationToSelfHostedSpec) GetSourceNamespace() string
- func (m *MigrationToSelfHostedSpec) GetTargetNamespace() string
- func (this *MigrationToSelfHostedSpec) GoString() string
- func (m *MigrationToSelfHostedSpec) Marshal() (dAtA []byte, err error)
- func (m *MigrationToSelfHostedSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *MigrationToSelfHostedSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MigrationToSelfHostedSpec) ProtoMessage()
- func (m *MigrationToSelfHostedSpec) Reset()
- func (m *MigrationToSelfHostedSpec) Size() (n int)
- func (this *MigrationToSelfHostedSpec) String() string
- func (m *MigrationToSelfHostedSpec) Unmarshal(dAtA []byte) error
- func (m *MigrationToSelfHostedSpec) XXX_DiscardUnknown()
- func (m *MigrationToSelfHostedSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MigrationToSelfHostedSpec) XXX_Merge(src proto.Message)
- func (m *MigrationToSelfHostedSpec) XXX_Size() int
- func (m *MigrationToSelfHostedSpec) XXX_Unmarshal(b []byte) error
- type Migration_State
- type MtlsAuthSpec
- func (*MtlsAuthSpec) Descriptor() ([]byte, []int)
- func (this *MtlsAuthSpec) Equal(that interface{}) bool
- func (m *MtlsAuthSpec) GetAcceptedClientCa() []byte
- func (m *MtlsAuthSpec) GetAcceptedClientCaDeprecated() stringdeprecated
- func (m *MtlsAuthSpec) GetCertificateFilters() []*CertificateFilterSpec
- func (m *MtlsAuthSpec) GetEnabled() bool
- func (this *MtlsAuthSpec) GoString() string
- func (m *MtlsAuthSpec) Marshal() (dAtA []byte, err error)
- func (m *MtlsAuthSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *MtlsAuthSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MtlsAuthSpec) ProtoMessage()
- func (m *MtlsAuthSpec) Reset()
- func (m *MtlsAuthSpec) Size() (n int)
- func (this *MtlsAuthSpec) String() string
- func (m *MtlsAuthSpec) Unmarshal(dAtA []byte) error
- func (m *MtlsAuthSpec) XXX_DiscardUnknown()
- func (m *MtlsAuthSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MtlsAuthSpec) XXX_Merge(src proto.Message)
- func (m *MtlsAuthSpec) XXX_Size() int
- func (m *MtlsAuthSpec) XXX_Unmarshal(b []byte) error
- type Namespace
- func (*Namespace) Descriptor() ([]byte, []int)
- func (this *Namespace) Equal(that interface{}) bool
- func (m *Namespace) GetActiveRegion() string
- func (m *Namespace) GetAsyncOperationId() string
- func (m *Namespace) GetCapacity() *Capacity
- func (m *Namespace) GetConnectivityRules() []*v11.ConnectivityRule
- func (m *Namespace) GetCreatedTime() *types.Timestamp
- func (m *Namespace) GetEndpoints() *Endpoints
- func (m *Namespace) GetLastModifiedTime() *types.Timestamp
- func (m *Namespace) GetLimits() *Limits
- func (m *Namespace) GetNamespace() string
- func (m *Namespace) GetPrivateConnectivities() []*PrivateConnectivity
- func (m *Namespace) GetProjectId() string
- func (m *Namespace) GetRegionStatus() map[string]*NamespaceRegionStatusdeprecated
- func (m *Namespace) GetReplicas() []*Replica
- func (m *Namespace) GetResourceVersion() string
- func (m *Namespace) GetSpec() *NamespaceSpec
- func (m *Namespace) GetState() v1.ResourceState
- func (m *Namespace) GetStateDeprecated() stringdeprecated
- func (m *Namespace) GetTags() map[string]string
- func (this *Namespace) GoString() string
- func (m *Namespace) Marshal() (dAtA []byte, err error)
- func (m *Namespace) MarshalTo(dAtA []byte) (int, error)
- func (m *Namespace) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Namespace) ProtoMessage()
- func (m *Namespace) Reset()
- func (m *Namespace) Size() (n int)
- func (this *Namespace) String() string
- func (m *Namespace) Unmarshal(dAtA []byte) error
- func (m *Namespace) XXX_DiscardUnknown()
- func (m *Namespace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Namespace) XXX_Merge(src proto.Message)
- func (m *Namespace) XXX_Size() int
- func (m *Namespace) XXX_Unmarshal(b []byte) error
- type NamespaceCapacityInfo
- func (*NamespaceCapacityInfo) Descriptor() ([]byte, []int)
- func (this *NamespaceCapacityInfo) Equal(that interface{}) bool
- func (m *NamespaceCapacityInfo) GetCurrentCapacity() *Capacity
- func (m *NamespaceCapacityInfo) GetHasLegacyLimits() bool
- func (m *NamespaceCapacityInfo) GetModeOptions() *NamespaceCapacityInfo_CapacityModeOptions
- func (m *NamespaceCapacityInfo) GetNamespace() string
- func (m *NamespaceCapacityInfo) GetStats() *NamespaceCapacityInfo_Stats
- func (this *NamespaceCapacityInfo) GoString() string
- func (m *NamespaceCapacityInfo) Marshal() (dAtA []byte, err error)
- func (m *NamespaceCapacityInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *NamespaceCapacityInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NamespaceCapacityInfo) ProtoMessage()
- func (m *NamespaceCapacityInfo) Reset()
- func (m *NamespaceCapacityInfo) Size() (n int)
- func (this *NamespaceCapacityInfo) String() string
- func (m *NamespaceCapacityInfo) Unmarshal(dAtA []byte) error
- func (m *NamespaceCapacityInfo) XXX_DiscardUnknown()
- func (m *NamespaceCapacityInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NamespaceCapacityInfo) XXX_Merge(src proto.Message)
- func (m *NamespaceCapacityInfo) XXX_Size() int
- func (m *NamespaceCapacityInfo) XXX_Unmarshal(b []byte) error
- type NamespaceCapacityInfo_CapacityModeOptions
- func (*NamespaceCapacityInfo_CapacityModeOptions) Descriptor() ([]byte, []int)
- func (this *NamespaceCapacityInfo_CapacityModeOptions) Equal(that interface{}) bool
- func (m *NamespaceCapacityInfo_CapacityModeOptions) GetOnDemand() *NamespaceCapacityInfo_CapacityModeOptions_OnDemand
- func (m *NamespaceCapacityInfo_CapacityModeOptions) GetProvisioned() *NamespaceCapacityInfo_CapacityModeOptions_Provisioned
- func (this *NamespaceCapacityInfo_CapacityModeOptions) GoString() string
- func (m *NamespaceCapacityInfo_CapacityModeOptions) Marshal() (dAtA []byte, err error)
- func (m *NamespaceCapacityInfo_CapacityModeOptions) MarshalTo(dAtA []byte) (int, error)
- func (m *NamespaceCapacityInfo_CapacityModeOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NamespaceCapacityInfo_CapacityModeOptions) ProtoMessage()
- func (m *NamespaceCapacityInfo_CapacityModeOptions) Reset()
- func (m *NamespaceCapacityInfo_CapacityModeOptions) Size() (n int)
- func (this *NamespaceCapacityInfo_CapacityModeOptions) String() string
- func (m *NamespaceCapacityInfo_CapacityModeOptions) Unmarshal(dAtA []byte) error
- func (m *NamespaceCapacityInfo_CapacityModeOptions) XXX_DiscardUnknown()
- func (m *NamespaceCapacityInfo_CapacityModeOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NamespaceCapacityInfo_CapacityModeOptions) XXX_Merge(src proto.Message)
- func (m *NamespaceCapacityInfo_CapacityModeOptions) XXX_Size() int
- func (m *NamespaceCapacityInfo_CapacityModeOptions) XXX_Unmarshal(b []byte) error
- type NamespaceCapacityInfo_CapacityModeOptions_OnDemand
- func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Descriptor() ([]byte, []int)
- func (this *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Equal(that interface{}) bool
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) GetApsLimit() float64
- func (this *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) GoString() string
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Marshal() (dAtA []byte, err error)
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) MarshalTo(dAtA []byte) (int, error)
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) ProtoMessage()
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Reset()
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Size() (n int)
- func (this *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) String() string
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Unmarshal(dAtA []byte) error
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_DiscardUnknown()
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Merge(src proto.Message)
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Size() int
- func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Unmarshal(b []byte) error
- type NamespaceCapacityInfo_CapacityModeOptions_Provisioned
- func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Descriptor() ([]byte, []int)
- func (this *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Equal(that interface{}) bool
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) GetMaxAvailableTruValue() float64
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) GetValidTruValues() []float64
- func (this *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) GoString() string
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Marshal() (dAtA []byte, err error)
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) MarshalTo(dAtA []byte) (int, error)
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) ProtoMessage()
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Reset()
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Size() (n int)
- func (this *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) String() string
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Unmarshal(dAtA []byte) error
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_DiscardUnknown()
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Merge(src proto.Message)
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Size() int
- func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Unmarshal(b []byte) error
- type NamespaceCapacityInfo_Stats
- func (*NamespaceCapacityInfo_Stats) Descriptor() ([]byte, []int)
- func (this *NamespaceCapacityInfo_Stats) Equal(that interface{}) bool
- func (m *NamespaceCapacityInfo_Stats) GetAps() *NamespaceCapacityInfo_Stats_Summary
- func (this *NamespaceCapacityInfo_Stats) GoString() string
- func (m *NamespaceCapacityInfo_Stats) Marshal() (dAtA []byte, err error)
- func (m *NamespaceCapacityInfo_Stats) MarshalTo(dAtA []byte) (int, error)
- func (m *NamespaceCapacityInfo_Stats) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NamespaceCapacityInfo_Stats) ProtoMessage()
- func (m *NamespaceCapacityInfo_Stats) Reset()
- func (m *NamespaceCapacityInfo_Stats) Size() (n int)
- func (this *NamespaceCapacityInfo_Stats) String() string
- func (m *NamespaceCapacityInfo_Stats) Unmarshal(dAtA []byte) error
- func (m *NamespaceCapacityInfo_Stats) XXX_DiscardUnknown()
- func (m *NamespaceCapacityInfo_Stats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NamespaceCapacityInfo_Stats) XXX_Merge(src proto.Message)
- func (m *NamespaceCapacityInfo_Stats) XXX_Size() int
- func (m *NamespaceCapacityInfo_Stats) XXX_Unmarshal(b []byte) error
- type NamespaceCapacityInfo_Stats_Summary
- func (*NamespaceCapacityInfo_Stats_Summary) Descriptor() ([]byte, []int)
- func (this *NamespaceCapacityInfo_Stats_Summary) Equal(that interface{}) bool
- func (m *NamespaceCapacityInfo_Stats_Summary) GetMean() float64
- func (m *NamespaceCapacityInfo_Stats_Summary) GetP90() float64
- func (m *NamespaceCapacityInfo_Stats_Summary) GetP99() float64
- func (this *NamespaceCapacityInfo_Stats_Summary) GoString() string
- func (m *NamespaceCapacityInfo_Stats_Summary) Marshal() (dAtA []byte, err error)
- func (m *NamespaceCapacityInfo_Stats_Summary) MarshalTo(dAtA []byte) (int, error)
- func (m *NamespaceCapacityInfo_Stats_Summary) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NamespaceCapacityInfo_Stats_Summary) ProtoMessage()
- func (m *NamespaceCapacityInfo_Stats_Summary) Reset()
- func (m *NamespaceCapacityInfo_Stats_Summary) Size() (n int)
- func (this *NamespaceCapacityInfo_Stats_Summary) String() string
- func (m *NamespaceCapacityInfo_Stats_Summary) Unmarshal(dAtA []byte) error
- func (m *NamespaceCapacityInfo_Stats_Summary) XXX_DiscardUnknown()
- func (m *NamespaceCapacityInfo_Stats_Summary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NamespaceCapacityInfo_Stats_Summary) XXX_Merge(src proto.Message)
- func (m *NamespaceCapacityInfo_Stats_Summary) XXX_Size() int
- func (m *NamespaceCapacityInfo_Stats_Summary) XXX_Unmarshal(b []byte) error
- type NamespaceRegionStatus
- func (*NamespaceRegionStatus) Descriptor() ([]byte, []int)
- func (this *NamespaceRegionStatus) Equal(that interface{}) bool
- func (m *NamespaceRegionStatus) GetAsyncOperationId() string
- func (m *NamespaceRegionStatus) GetState() NamespaceRegionStatus_State
- func (m *NamespaceRegionStatus) GetStateDeprecated() stringdeprecated
- func (this *NamespaceRegionStatus) GoString() string
- func (m *NamespaceRegionStatus) Marshal() (dAtA []byte, err error)
- func (m *NamespaceRegionStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *NamespaceRegionStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NamespaceRegionStatus) ProtoMessage()
- func (m *NamespaceRegionStatus) Reset()
- func (m *NamespaceRegionStatus) Size() (n int)
- func (this *NamespaceRegionStatus) String() string
- func (m *NamespaceRegionStatus) Unmarshal(dAtA []byte) error
- func (m *NamespaceRegionStatus) XXX_DiscardUnknown()
- func (m *NamespaceRegionStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NamespaceRegionStatus) XXX_Merge(src proto.Message)
- func (m *NamespaceRegionStatus) XXX_Size() int
- func (m *NamespaceRegionStatus) XXX_Unmarshal(b []byte) error
- type NamespaceRegionStatus_State
- type NamespaceSpec
- func (*NamespaceSpec) Descriptor() ([]byte, []int)
- func (this *NamespaceSpec) Equal(that interface{}) bool
- func (m *NamespaceSpec) GetApiKeyAuth() *ApiKeyAuthSpec
- func (m *NamespaceSpec) GetCapacitySpec() *CapacitySpec
- func (m *NamespaceSpec) GetCodecServer() *CodecServerSpec
- func (m *NamespaceSpec) GetConnectivityRuleIds() []string
- func (m *NamespaceSpec) GetCustomSearchAttributes() map[string]stringdeprecated
- func (m *NamespaceSpec) GetHighAvailability() *HighAvailabilitySpec
- func (m *NamespaceSpec) GetLifecycle() *LifecycleSpec
- func (m *NamespaceSpec) GetMtlsAuth() *MtlsAuthSpec
- func (m *NamespaceSpec) GetName() string
- func (m *NamespaceSpec) GetRegions() []stringdeprecated
- func (m *NamespaceSpec) GetReplicas() []*ReplicaSpec
- func (m *NamespaceSpec) GetRetentionDays() int32
- func (m *NamespaceSpec) GetSearchAttributes() map[string]NamespaceSpec_SearchAttributeType
- func (this *NamespaceSpec) GoString() string
- func (m *NamespaceSpec) Marshal() (dAtA []byte, err error)
- func (m *NamespaceSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *NamespaceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NamespaceSpec) ProtoMessage()
- func (m *NamespaceSpec) Reset()
- func (m *NamespaceSpec) Size() (n int)
- func (this *NamespaceSpec) String() string
- func (m *NamespaceSpec) Unmarshal(dAtA []byte) error
- func (m *NamespaceSpec) XXX_DiscardUnknown()
- func (m *NamespaceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NamespaceSpec) XXX_Merge(src proto.Message)
- func (m *NamespaceSpec) XXX_Size() int
- func (m *NamespaceSpec) XXX_Unmarshal(b []byte) error
- type NamespaceSpec_SearchAttributeType
- type PrivateConnectivity
- func (*PrivateConnectivity) Descriptor() ([]byte, []int)
- func (this *PrivateConnectivity) Equal(that interface{}) bool
- func (m *PrivateConnectivity) GetAwsPrivateLink() *AWSPrivateLinkInfo
- func (m *PrivateConnectivity) GetRegion() string
- func (this *PrivateConnectivity) GoString() string
- func (m *PrivateConnectivity) Marshal() (dAtA []byte, err error)
- func (m *PrivateConnectivity) MarshalTo(dAtA []byte) (int, error)
- func (m *PrivateConnectivity) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PrivateConnectivity) ProtoMessage()
- func (m *PrivateConnectivity) Reset()
- func (m *PrivateConnectivity) Size() (n int)
- func (this *PrivateConnectivity) String() string
- func (m *PrivateConnectivity) Unmarshal(dAtA []byte) error
- func (m *PrivateConnectivity) XXX_DiscardUnknown()
- func (m *PrivateConnectivity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PrivateConnectivity) XXX_Merge(src proto.Message)
- func (m *PrivateConnectivity) XXX_Size() int
- func (m *PrivateConnectivity) XXX_Unmarshal(b []byte) error
- type Replica
- func (*Replica) Descriptor() ([]byte, []int)
- func (this *Replica) Equal(that interface{}) bool
- func (m *Replica) GetId() string
- func (m *Replica) GetIsPrimary() bool
- func (m *Replica) GetRegion() string
- func (m *Replica) GetState() Replica_ReplicaState
- func (this *Replica) GoString() string
- func (m *Replica) Marshal() (dAtA []byte, err error)
- func (m *Replica) MarshalTo(dAtA []byte) (int, error)
- func (m *Replica) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Replica) ProtoMessage()
- func (m *Replica) Reset()
- func (m *Replica) Size() (n int)
- func (this *Replica) String() string
- func (m *Replica) Unmarshal(dAtA []byte) error
- func (m *Replica) XXX_DiscardUnknown()
- func (m *Replica) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Replica) XXX_Merge(src proto.Message)
- func (m *Replica) XXX_Size() int
- func (m *Replica) XXX_Unmarshal(b []byte) error
- type ReplicaSpec
- func (*ReplicaSpec) Descriptor() ([]byte, []int)
- func (this *ReplicaSpec) Equal(that interface{}) bool
- func (m *ReplicaSpec) GetRegion() string
- func (this *ReplicaSpec) GoString() string
- func (m *ReplicaSpec) Marshal() (dAtA []byte, err error)
- func (m *ReplicaSpec) MarshalTo(dAtA []byte) (int, error)
- func (m *ReplicaSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReplicaSpec) ProtoMessage()
- func (m *ReplicaSpec) Reset()
- func (m *ReplicaSpec) Size() (n int)
- func (this *ReplicaSpec) String() string
- func (m *ReplicaSpec) Unmarshal(dAtA []byte) error
- func (m *ReplicaSpec) XXX_DiscardUnknown()
- func (m *ReplicaSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReplicaSpec) XXX_Merge(src proto.Message)
- func (m *ReplicaSpec) XXX_Size() int
- func (m *ReplicaSpec) XXX_Unmarshal(b []byte) error
- type Replica_ReplicaState
- type ReplicationEstimate
- func (*ReplicationEstimate) Descriptor() ([]byte, []int)
- func (this *ReplicationEstimate) Equal(that interface{}) bool
- func (m *ReplicationEstimate) GetRate() float64
- func (m *ReplicationEstimate) GetRemainingCount() int64
- func (m *ReplicationEstimate) GetReplicatedCount() int64
- func (m *ReplicationEstimate) GetTimeRemainingSeconds() int64
- func (this *ReplicationEstimate) GoString() string
- func (m *ReplicationEstimate) Marshal() (dAtA []byte, err error)
- func (m *ReplicationEstimate) MarshalTo(dAtA []byte) (int, error)
- func (m *ReplicationEstimate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReplicationEstimate) ProtoMessage()
- func (m *ReplicationEstimate) Reset()
- func (m *ReplicationEstimate) Size() (n int)
- func (this *ReplicationEstimate) String() string
- func (m *ReplicationEstimate) Unmarshal(dAtA []byte) error
- func (m *ReplicationEstimate) XXX_DiscardUnknown()
- func (m *ReplicationEstimate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReplicationEstimate) XXX_Merge(src proto.Message)
- func (m *ReplicationEstimate) XXX_Size() int
- func (m *ReplicationEstimate) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthMessage = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMessage = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group") )
var Capacity_Request_State_name = map[int32]string{
0: "StateCapacityRequestUnspecified",
1: "StateCapacityRequestCompleted",
2: "StateCapacityRequestInProgress",
3: "StateCapacityRequestFailed",
}
var Capacity_Request_State_value = map[string]int32{
"StateCapacityRequestUnspecified": 0,
"StateCapacityRequestCompleted": 1,
"StateCapacityRequestInProgress": 2,
"StateCapacityRequestFailed": 3,
}
var ExportSink_Health_name = map[int32]string{
0: "HealthUnspecified",
1: "HealthOk",
2: "HealthErrorInternal",
3: "HealthErrorUserConfiguration",
}
var ExportSink_Health_value = map[string]int32{
"HealthUnspecified": 0,
"HealthOk": 1,
"HealthErrorInternal": 2,
"HealthErrorUserConfiguration": 3,
}
var MigrationReplica_State_name = map[int32]string{
0: "StateReplicaUnspecified",
1: "StateReplicaActive",
2: "StateReplicaPassiveOutOfSync",
3: "StateReplicaPassiveInSync",
4: "StateReplicaAbandoned",
}
var MigrationReplica_State_value = map[string]int32{
"StateReplicaUnspecified": 0,
"StateReplicaActive": 1,
"StateReplicaPassiveOutOfSync": 2,
"StateReplicaPassiveInSync": 3,
"StateReplicaAbandoned": 4,
}
var Migration_State_name = map[int32]string{
0: "StateMigrationUnspecified",
1: "StateMigrationMigrationStarted",
2: "StateMigrationReplicationInProgress",
3: "StateMigrationWaitingForHandover",
4: "StateMigrationHandoverInProgress",
5: "StateMigrationReadyForConfirmation",
6: "StateMigrationComplete",
7: "StateMigrationFailed",
8: "StateMigrationAbortInProgress",
9: "StateMigrationAborted",
10: "StateMigrationConfirmInProgress",
}
var Migration_State_value = map[string]int32{
"StateMigrationUnspecified": 0,
"StateMigrationMigrationStarted": 1,
"StateMigrationReplicationInProgress": 2,
"StateMigrationWaitingForHandover": 3,
"StateMigrationHandoverInProgress": 4,
"StateMigrationReadyForConfirmation": 5,
"StateMigrationComplete": 6,
"StateMigrationFailed": 7,
"StateMigrationAbortInProgress": 8,
"StateMigrationAborted": 9,
"StateMigrationConfirmInProgress": 10,
}
var NamespaceRegionStatus_State_name = map[int32]string{
0: "StateUnspecified",
1: "StateAdding",
2: "StateActive",
3: "StatePassive",
4: "StateRemoving",
5: "StateFailed",
}
var NamespaceRegionStatus_State_value = map[string]int32{
"StateUnspecified": 0,
"StateAdding": 1,
"StateActive": 2,
"StatePassive": 3,
"StateRemoving": 4,
"StateFailed": 5,
}
var NamespaceSpec_SearchAttributeType_name = map[int32]string{
0: "SearchAttributeTypeUnspecified",
1: "SearchAttributeTypeText",
2: "SearchAttributeTypeKeyword",
3: "SearchAttributeTypeInt",
4: "SearchAttributeTypeDouble",
5: "SearchAttributeTypeBool",
6: "SearchAttributeTypeDatetime",
7: "SearchAttributeTypeKeywordList",
}
var NamespaceSpec_SearchAttributeType_value = map[string]int32{
"SearchAttributeTypeUnspecified": 0,
"SearchAttributeTypeText": 1,
"SearchAttributeTypeKeyword": 2,
"SearchAttributeTypeInt": 3,
"SearchAttributeTypeDouble": 4,
"SearchAttributeTypeBool": 5,
"SearchAttributeTypeDatetime": 6,
"SearchAttributeTypeKeywordList": 7,
}
var Replica_ReplicaState_name = map[int32]string{
0: "ReplicaStateUnspecified",
1: "ReplicaStateAdding",
2: "ReplicaStateActive",
3: "ReplicaStateRemoving",
5: "ReplicaStateFailed",
}
var Replica_ReplicaState_value = map[string]int32{
"ReplicaStateUnspecified": 0,
"ReplicaStateAdding": 1,
"ReplicaStateActive": 2,
"ReplicaStateRemoving": 3,
"ReplicaStateFailed": 5,
}
Functions ¶
This section is empty.
Types ¶
type AWSPrivateLinkInfo ¶
type AWSPrivateLinkInfo struct {
// The list of principal arns that are allowed to access the namespace on the private link.
AllowedPrincipalArns []string `protobuf:"bytes,1,rep,name=allowed_principal_arns,json=allowedPrincipalArns,proto3" json:"allowed_principal_arns,omitempty"`
// The list of vpc endpoint service names that are associated with the namespace.
VpcEndpointServiceNames []string `` /* 134-byte string literal not displayed */
}
func (*AWSPrivateLinkInfo) Descriptor ¶
func (*AWSPrivateLinkInfo) Descriptor() ([]byte, []int)
func (*AWSPrivateLinkInfo) Equal ¶
func (this *AWSPrivateLinkInfo) Equal(that interface{}) bool
func (*AWSPrivateLinkInfo) GetAllowedPrincipalArns ¶
func (m *AWSPrivateLinkInfo) GetAllowedPrincipalArns() []string
func (*AWSPrivateLinkInfo) GetVpcEndpointServiceNames ¶
func (m *AWSPrivateLinkInfo) GetVpcEndpointServiceNames() []string
func (*AWSPrivateLinkInfo) GoString ¶
func (this *AWSPrivateLinkInfo) GoString() string
func (*AWSPrivateLinkInfo) Marshal ¶
func (m *AWSPrivateLinkInfo) Marshal() (dAtA []byte, err error)
func (*AWSPrivateLinkInfo) MarshalTo ¶
func (m *AWSPrivateLinkInfo) MarshalTo(dAtA []byte) (int, error)
func (*AWSPrivateLinkInfo) MarshalToSizedBuffer ¶
func (m *AWSPrivateLinkInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AWSPrivateLinkInfo) ProtoMessage ¶
func (*AWSPrivateLinkInfo) ProtoMessage()
func (*AWSPrivateLinkInfo) Reset ¶
func (m *AWSPrivateLinkInfo) Reset()
func (*AWSPrivateLinkInfo) Size ¶
func (m *AWSPrivateLinkInfo) Size() (n int)
func (*AWSPrivateLinkInfo) String ¶
func (this *AWSPrivateLinkInfo) String() string
func (*AWSPrivateLinkInfo) Unmarshal ¶
func (m *AWSPrivateLinkInfo) Unmarshal(dAtA []byte) error
func (*AWSPrivateLinkInfo) XXX_DiscardUnknown ¶
func (m *AWSPrivateLinkInfo) XXX_DiscardUnknown()
func (*AWSPrivateLinkInfo) XXX_Marshal ¶
func (m *AWSPrivateLinkInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AWSPrivateLinkInfo) XXX_Merge ¶
func (m *AWSPrivateLinkInfo) XXX_Merge(src proto.Message)
func (*AWSPrivateLinkInfo) XXX_Size ¶
func (m *AWSPrivateLinkInfo) XXX_Size() int
func (*AWSPrivateLinkInfo) XXX_Unmarshal ¶
func (m *AWSPrivateLinkInfo) XXX_Unmarshal(b []byte) error
type ApiKeyAuthSpec ¶
type ApiKeyAuthSpec struct {
// Flag to enable API key auth (default: disabled).
// Note: disabling API key auth will cause existing API key connections to fail.
Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
}
func (*ApiKeyAuthSpec) Descriptor ¶
func (*ApiKeyAuthSpec) Descriptor() ([]byte, []int)
func (*ApiKeyAuthSpec) Equal ¶
func (this *ApiKeyAuthSpec) Equal(that interface{}) bool
func (*ApiKeyAuthSpec) GetEnabled ¶
func (m *ApiKeyAuthSpec) GetEnabled() bool
func (*ApiKeyAuthSpec) GoString ¶
func (this *ApiKeyAuthSpec) GoString() string
func (*ApiKeyAuthSpec) Marshal ¶
func (m *ApiKeyAuthSpec) Marshal() (dAtA []byte, err error)
func (*ApiKeyAuthSpec) MarshalToSizedBuffer ¶
func (m *ApiKeyAuthSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ApiKeyAuthSpec) ProtoMessage ¶
func (*ApiKeyAuthSpec) ProtoMessage()
func (*ApiKeyAuthSpec) Reset ¶
func (m *ApiKeyAuthSpec) Reset()
func (*ApiKeyAuthSpec) Size ¶
func (m *ApiKeyAuthSpec) Size() (n int)
func (*ApiKeyAuthSpec) String ¶
func (this *ApiKeyAuthSpec) String() string
func (*ApiKeyAuthSpec) Unmarshal ¶
func (m *ApiKeyAuthSpec) Unmarshal(dAtA []byte) error
func (*ApiKeyAuthSpec) XXX_DiscardUnknown ¶
func (m *ApiKeyAuthSpec) XXX_DiscardUnknown()
func (*ApiKeyAuthSpec) XXX_Marshal ¶
func (m *ApiKeyAuthSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ApiKeyAuthSpec) XXX_Merge ¶
func (m *ApiKeyAuthSpec) XXX_Merge(src proto.Message)
func (*ApiKeyAuthSpec) XXX_Size ¶
func (m *ApiKeyAuthSpec) XXX_Size() int
func (*ApiKeyAuthSpec) XXX_Unmarshal ¶
func (m *ApiKeyAuthSpec) XXX_Unmarshal(b []byte) error
type Capacity ¶ added in v0.44.0
type Capacity struct {
// Types that are valid to be assigned to CurrentMode:
//
// *Capacity_OnDemand_
// *Capacity_Provisioned_
CurrentMode isCapacity_CurrentMode `protobuf_oneof:"current_mode"`
// The latest capacity request, if any.
LatestRequest *Capacity_Request `protobuf:"bytes,3,opt,name=latest_request,json=latestRequest,proto3" json:"latest_request,omitempty"`
}
func (*Capacity) Descriptor ¶ added in v0.44.0
func (*Capacity) GetCurrentMode ¶ added in v0.44.0
func (m *Capacity) GetCurrentMode() isCapacity_CurrentMode
func (*Capacity) GetLatestRequest ¶ added in v0.44.0
func (m *Capacity) GetLatestRequest() *Capacity_Request
func (*Capacity) GetOnDemand ¶ added in v0.44.0
func (m *Capacity) GetOnDemand() *Capacity_OnDemand
func (*Capacity) GetProvisioned ¶ added in v0.44.0
func (m *Capacity) GetProvisioned() *Capacity_Provisioned
func (*Capacity) MarshalToSizedBuffer ¶ added in v0.44.0
func (*Capacity) ProtoMessage ¶ added in v0.44.0
func (*Capacity) ProtoMessage()
func (*Capacity) XXX_DiscardUnknown ¶ added in v0.44.0
func (m *Capacity) XXX_DiscardUnknown()
func (*Capacity) XXX_Marshal ¶ added in v0.44.0
func (*Capacity) XXX_OneofWrappers ¶ added in v0.44.0
func (*Capacity) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Capacity) XXX_Unmarshal ¶ added in v0.44.0
type CapacitySpec ¶ added in v0.44.0
type CapacitySpec struct {
// Types that are valid to be assigned to Spec:
//
// *CapacitySpec_OnDemand_
// *CapacitySpec_Provisioned_
Spec isCapacitySpec_Spec `protobuf_oneof:"spec"`
}
func (*CapacitySpec) Descriptor ¶ added in v0.44.0
func (*CapacitySpec) Descriptor() ([]byte, []int)
func (*CapacitySpec) Equal ¶ added in v0.44.0
func (this *CapacitySpec) Equal(that interface{}) bool
func (*CapacitySpec) GetOnDemand ¶ added in v0.44.0
func (m *CapacitySpec) GetOnDemand() *CapacitySpec_OnDemand
func (*CapacitySpec) GetProvisioned ¶ added in v0.44.0
func (m *CapacitySpec) GetProvisioned() *CapacitySpec_Provisioned
func (*CapacitySpec) GetSpec ¶ added in v0.44.0
func (m *CapacitySpec) GetSpec() isCapacitySpec_Spec
func (*CapacitySpec) GoString ¶ added in v0.44.0
func (this *CapacitySpec) GoString() string
func (*CapacitySpec) Marshal ¶ added in v0.44.0
func (m *CapacitySpec) Marshal() (dAtA []byte, err error)
func (*CapacitySpec) MarshalTo ¶ added in v0.44.0
func (m *CapacitySpec) MarshalTo(dAtA []byte) (int, error)
func (*CapacitySpec) MarshalToSizedBuffer ¶ added in v0.44.0
func (m *CapacitySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CapacitySpec) ProtoMessage ¶ added in v0.44.0
func (*CapacitySpec) ProtoMessage()
func (*CapacitySpec) Reset ¶ added in v0.44.0
func (m *CapacitySpec) Reset()
func (*CapacitySpec) Size ¶ added in v0.44.0
func (m *CapacitySpec) Size() (n int)
func (*CapacitySpec) String ¶ added in v0.44.0
func (this *CapacitySpec) String() string
func (*CapacitySpec) Unmarshal ¶ added in v0.44.0
func (m *CapacitySpec) Unmarshal(dAtA []byte) error
func (*CapacitySpec) XXX_DiscardUnknown ¶ added in v0.44.0
func (m *CapacitySpec) XXX_DiscardUnknown()
func (*CapacitySpec) XXX_Marshal ¶ added in v0.44.0
func (m *CapacitySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CapacitySpec) XXX_Merge ¶ added in v0.44.0
func (m *CapacitySpec) XXX_Merge(src proto.Message)
func (*CapacitySpec) XXX_OneofWrappers ¶ added in v0.44.0
func (*CapacitySpec) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*CapacitySpec) XXX_Size ¶ added in v0.44.0
func (m *CapacitySpec) XXX_Size() int
func (*CapacitySpec) XXX_Unmarshal ¶ added in v0.44.0
func (m *CapacitySpec) XXX_Unmarshal(b []byte) error
type CapacitySpec_OnDemand ¶ added in v0.44.0
type CapacitySpec_OnDemand struct {
}
func (*CapacitySpec_OnDemand) Descriptor ¶ added in v0.44.0
func (*CapacitySpec_OnDemand) Descriptor() ([]byte, []int)
func (*CapacitySpec_OnDemand) Equal ¶ added in v0.44.0
func (this *CapacitySpec_OnDemand) Equal(that interface{}) bool
func (*CapacitySpec_OnDemand) GoString ¶ added in v0.44.0
func (this *CapacitySpec_OnDemand) GoString() string
func (*CapacitySpec_OnDemand) Marshal ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) Marshal() (dAtA []byte, err error)
func (*CapacitySpec_OnDemand) MarshalTo ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) MarshalTo(dAtA []byte) (int, error)
func (*CapacitySpec_OnDemand) MarshalToSizedBuffer ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CapacitySpec_OnDemand) ProtoMessage ¶ added in v0.44.0
func (*CapacitySpec_OnDemand) ProtoMessage()
func (*CapacitySpec_OnDemand) Reset ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) Reset()
func (*CapacitySpec_OnDemand) Size ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) Size() (n int)
func (*CapacitySpec_OnDemand) String ¶ added in v0.44.0
func (this *CapacitySpec_OnDemand) String() string
func (*CapacitySpec_OnDemand) Unmarshal ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) Unmarshal(dAtA []byte) error
func (*CapacitySpec_OnDemand) XXX_DiscardUnknown ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) XXX_DiscardUnknown()
func (*CapacitySpec_OnDemand) XXX_Marshal ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CapacitySpec_OnDemand) XXX_Merge ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) XXX_Merge(src proto.Message)
func (*CapacitySpec_OnDemand) XXX_Size ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) XXX_Size() int
func (*CapacitySpec_OnDemand) XXX_Unmarshal ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand) XXX_Unmarshal(b []byte) error
type CapacitySpec_OnDemand_ ¶ added in v0.44.0
type CapacitySpec_OnDemand_ struct {
OnDemand *CapacitySpec_OnDemand `protobuf:"bytes,1,opt,name=on_demand,json=onDemand,proto3,oneof" json:"on_demand,omitempty"`
}
func (*CapacitySpec_OnDemand_) Equal ¶ added in v0.44.0
func (this *CapacitySpec_OnDemand_) Equal(that interface{}) bool
func (*CapacitySpec_OnDemand_) GoString ¶ added in v0.44.0
func (this *CapacitySpec_OnDemand_) GoString() string
func (*CapacitySpec_OnDemand_) MarshalTo ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand_) MarshalTo(dAtA []byte) (int, error)
func (*CapacitySpec_OnDemand_) MarshalToSizedBuffer ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand_) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CapacitySpec_OnDemand_) Size ¶ added in v0.44.0
func (m *CapacitySpec_OnDemand_) Size() (n int)
func (*CapacitySpec_OnDemand_) String ¶ added in v0.44.0
func (this *CapacitySpec_OnDemand_) String() string
type CapacitySpec_Provisioned ¶ added in v0.44.0
type CapacitySpec_Provisioned struct {
// the unit of the provisioned capacity (Temporal Resource Units)
Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
}
func (*CapacitySpec_Provisioned) Descriptor ¶ added in v0.44.0
func (*CapacitySpec_Provisioned) Descriptor() ([]byte, []int)
func (*CapacitySpec_Provisioned) Equal ¶ added in v0.44.0
func (this *CapacitySpec_Provisioned) Equal(that interface{}) bool
func (*CapacitySpec_Provisioned) GetValue ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) GetValue() float64
func (*CapacitySpec_Provisioned) GoString ¶ added in v0.44.0
func (this *CapacitySpec_Provisioned) GoString() string
func (*CapacitySpec_Provisioned) Marshal ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) Marshal() (dAtA []byte, err error)
func (*CapacitySpec_Provisioned) MarshalTo ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) MarshalTo(dAtA []byte) (int, error)
func (*CapacitySpec_Provisioned) MarshalToSizedBuffer ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CapacitySpec_Provisioned) ProtoMessage ¶ added in v0.44.0
func (*CapacitySpec_Provisioned) ProtoMessage()
func (*CapacitySpec_Provisioned) Reset ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) Reset()
func (*CapacitySpec_Provisioned) Size ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) Size() (n int)
func (*CapacitySpec_Provisioned) String ¶ added in v0.44.0
func (this *CapacitySpec_Provisioned) String() string
func (*CapacitySpec_Provisioned) Unmarshal ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) Unmarshal(dAtA []byte) error
func (*CapacitySpec_Provisioned) XXX_DiscardUnknown ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) XXX_DiscardUnknown()
func (*CapacitySpec_Provisioned) XXX_Marshal ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CapacitySpec_Provisioned) XXX_Merge ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) XXX_Merge(src proto.Message)
func (*CapacitySpec_Provisioned) XXX_Size ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) XXX_Size() int
func (*CapacitySpec_Provisioned) XXX_Unmarshal ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned) XXX_Unmarshal(b []byte) error
type CapacitySpec_Provisioned_ ¶ added in v0.44.0
type CapacitySpec_Provisioned_ struct {
Provisioned *CapacitySpec_Provisioned `protobuf:"bytes,2,opt,name=provisioned,proto3,oneof" json:"provisioned,omitempty"`
}
func (*CapacitySpec_Provisioned_) Equal ¶ added in v0.44.0
func (this *CapacitySpec_Provisioned_) Equal(that interface{}) bool
func (*CapacitySpec_Provisioned_) GoString ¶ added in v0.44.0
func (this *CapacitySpec_Provisioned_) GoString() string
func (*CapacitySpec_Provisioned_) MarshalTo ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned_) MarshalTo(dAtA []byte) (int, error)
func (*CapacitySpec_Provisioned_) MarshalToSizedBuffer ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned_) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CapacitySpec_Provisioned_) Size ¶ added in v0.44.0
func (m *CapacitySpec_Provisioned_) Size() (n int)
func (*CapacitySpec_Provisioned_) String ¶ added in v0.44.0
func (this *CapacitySpec_Provisioned_) String() string
type Capacity_OnDemand ¶ added in v0.44.0
type Capacity_OnDemand struct {
}
func (*Capacity_OnDemand) Descriptor ¶ added in v0.44.0
func (*Capacity_OnDemand) Descriptor() ([]byte, []int)
func (*Capacity_OnDemand) Equal ¶ added in v0.44.0
func (this *Capacity_OnDemand) Equal(that interface{}) bool
func (*Capacity_OnDemand) GoString ¶ added in v0.44.0
func (this *Capacity_OnDemand) GoString() string
func (*Capacity_OnDemand) Marshal ¶ added in v0.44.0
func (m *Capacity_OnDemand) Marshal() (dAtA []byte, err error)
func (*Capacity_OnDemand) MarshalTo ¶ added in v0.44.0
func (m *Capacity_OnDemand) MarshalTo(dAtA []byte) (int, error)
func (*Capacity_OnDemand) MarshalToSizedBuffer ¶ added in v0.44.0
func (m *Capacity_OnDemand) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Capacity_OnDemand) ProtoMessage ¶ added in v0.44.0
func (*Capacity_OnDemand) ProtoMessage()
func (*Capacity_OnDemand) Reset ¶ added in v0.44.0
func (m *Capacity_OnDemand) Reset()
func (*Capacity_OnDemand) Size ¶ added in v0.44.0
func (m *Capacity_OnDemand) Size() (n int)
func (*Capacity_OnDemand) String ¶ added in v0.44.0
func (this *Capacity_OnDemand) String() string
func (*Capacity_OnDemand) Unmarshal ¶ added in v0.44.0
func (m *Capacity_OnDemand) Unmarshal(dAtA []byte) error
func (*Capacity_OnDemand) XXX_DiscardUnknown ¶ added in v0.44.0
func (m *Capacity_OnDemand) XXX_DiscardUnknown()
func (*Capacity_OnDemand) XXX_Marshal ¶ added in v0.44.0
func (m *Capacity_OnDemand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Capacity_OnDemand) XXX_Merge ¶ added in v0.44.0
func (m *Capacity_OnDemand) XXX_Merge(src proto.Message)
func (*Capacity_OnDemand) XXX_Size ¶ added in v0.44.0
func (m *Capacity_OnDemand) XXX_Size() int
func (*Capacity_OnDemand) XXX_Unmarshal ¶ added in v0.44.0
func (m *Capacity_OnDemand) XXX_Unmarshal(b []byte) error
type Capacity_OnDemand_ ¶ added in v0.44.0
type Capacity_OnDemand_ struct {
OnDemand *Capacity_OnDemand `protobuf:"bytes,1,opt,name=on_demand,json=onDemand,proto3,oneof" json:"on_demand,omitempty"`
}
func (*Capacity_OnDemand_) Equal ¶ added in v0.44.0
func (this *Capacity_OnDemand_) Equal(that interface{}) bool
func (*Capacity_OnDemand_) GoString ¶ added in v0.44.0
func (this *Capacity_OnDemand_) GoString() string
func (*Capacity_OnDemand_) MarshalTo ¶ added in v0.44.0
func (m *Capacity_OnDemand_) MarshalTo(dAtA []byte) (int, error)
func (*Capacity_OnDemand_) MarshalToSizedBuffer ¶ added in v0.44.0
func (m *Capacity_OnDemand_) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Capacity_OnDemand_) Size ¶ added in v0.44.0
func (m *Capacity_OnDemand_) Size() (n int)
func (*Capacity_OnDemand_) String ¶ added in v0.44.0
func (this *Capacity_OnDemand_) String() string
type Capacity_Provisioned ¶ added in v0.44.0
type Capacity_Provisioned struct {
// the current unit of the provisioned capacity (Temporal Resource Units)
CurrentValue float64 `protobuf:"fixed64,1,opt,name=current_value,json=currentValue,proto3" json:"current_value,omitempty"`
}
func (*Capacity_Provisioned) Descriptor ¶ added in v0.44.0
func (*Capacity_Provisioned) Descriptor() ([]byte, []int)
func (*Capacity_Provisioned) Equal ¶ added in v0.44.0
func (this *Capacity_Provisioned) Equal(that interface{}) bool
func (*Capacity_Provisioned) GetCurrentValue ¶ added in v0.44.0
func (m *Capacity_Provisioned) GetCurrentValue() float64
func (*Capacity_Provisioned) GoString ¶ added in v0.44.0
func (this *Capacity_Provisioned) GoString() string
func (*Capacity_Provisioned) Marshal ¶ added in v0.44.0
func (m *Capacity_Provisioned) Marshal() (dAtA []byte, err error)
func (*Capacity_Provisioned) MarshalTo ¶ added in v0.44.0
func (m *Capacity_Provisioned) MarshalTo(dAtA []byte) (int, error)
func (*Capacity_Provisioned) MarshalToSizedBuffer ¶ added in v0.44.0
func (m *Capacity_Provisioned) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Capacity_Provisioned) ProtoMessage ¶ added in v0.44.0
func (*Capacity_Provisioned) ProtoMessage()
func (*Capacity_Provisioned) Reset ¶ added in v0.44.0
func (m *Capacity_Provisioned) Reset()
func (*Capacity_Provisioned) Size ¶ added in v0.44.0
func (m *Capacity_Provisioned) Size() (n int)
func (*Capacity_Provisioned) String ¶ added in v0.44.0
func (this *Capacity_Provisioned) String() string
func (*Capacity_Provisioned) Unmarshal ¶ added in v0.44.0
func (m *Capacity_Provisioned) Unmarshal(dAtA []byte) error
func (*Capacity_Provisioned) XXX_DiscardUnknown ¶ added in v0.44.0
func (m *Capacity_Provisioned) XXX_DiscardUnknown()
func (*Capacity_Provisioned) XXX_Marshal ¶ added in v0.44.0
func (m *Capacity_Provisioned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Capacity_Provisioned) XXX_Merge ¶ added in v0.44.0
func (m *Capacity_Provisioned) XXX_Merge(src proto.Message)
func (*Capacity_Provisioned) XXX_Size ¶ added in v0.44.0
func (m *Capacity_Provisioned) XXX_Size() int
func (*Capacity_Provisioned) XXX_Unmarshal ¶ added in v0.44.0
func (m *Capacity_Provisioned) XXX_Unmarshal(b []byte) error
type Capacity_Provisioned_ ¶ added in v0.44.0
type Capacity_Provisioned_ struct {
Provisioned *Capacity_Provisioned `protobuf:"bytes,2,opt,name=provisioned,proto3,oneof" json:"provisioned,omitempty"`
}
func (*Capacity_Provisioned_) Equal ¶ added in v0.44.0
func (this *Capacity_Provisioned_) Equal(that interface{}) bool
func (*Capacity_Provisioned_) GoString ¶ added in v0.44.0
func (this *Capacity_Provisioned_) GoString() string
func (*Capacity_Provisioned_) MarshalTo ¶ added in v0.44.0
func (m *Capacity_Provisioned_) MarshalTo(dAtA []byte) (int, error)
func (*Capacity_Provisioned_) MarshalToSizedBuffer ¶ added in v0.44.0
func (m *Capacity_Provisioned_) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Capacity_Provisioned_) Size ¶ added in v0.44.0
func (m *Capacity_Provisioned_) Size() (n int)
func (*Capacity_Provisioned_) String ¶ added in v0.44.0
func (this *Capacity_Provisioned_) String() string
type Capacity_Request ¶ added in v0.44.0
type Capacity_Request struct {
// the current state of the capacity request (e.g. in-progress, completed, failed)
State Capacity_Request_State `protobuf:"varint,1,opt,name=state,proto3,enum=temporal.api.cloud.namespace.v1.Capacity_Request_State" json:"state,omitempty"`
// The date and time when the capacity request was created.
StartTime *types.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
// The date and time when the capacity request was completed or failed.
EndTime *types.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// The id of the async operation that is creating/updating/deleting the capacity, if any.
AsyncOperationId string `protobuf:"bytes,4,opt,name=async_operation_id,json=asyncOperationId,proto3" json:"async_operation_id,omitempty"`
// The requested capacity specification.
Spec *CapacitySpec `protobuf:"bytes,5,opt,name=spec,proto3" json:"spec,omitempty"`
}
func (*Capacity_Request) Descriptor ¶ added in v0.44.0
func (*Capacity_Request) Descriptor() ([]byte, []int)
func (*Capacity_Request) Equal ¶ added in v0.44.0
func (this *Capacity_Request) Equal(that interface{}) bool
func (*Capacity_Request) GetAsyncOperationId ¶ added in v0.44.0
func (m *Capacity_Request) GetAsyncOperationId() string
func (*Capacity_Request) GetEndTime ¶ added in v0.44.0
func (m *Capacity_Request) GetEndTime() *types.Timestamp
func (*Capacity_Request) GetSpec ¶ added in v0.44.0
func (m *Capacity_Request) GetSpec() *CapacitySpec
func (*Capacity_Request) GetStartTime ¶ added in v0.44.0
func (m *Capacity_Request) GetStartTime() *types.Timestamp
func (*Capacity_Request) GetState ¶ added in v0.44.0
func (m *Capacity_Request) GetState() Capacity_Request_State
func (*Capacity_Request) GoString ¶ added in v0.44.0
func (this *Capacity_Request) GoString() string
func (*Capacity_Request) Marshal ¶ added in v0.44.0
func (m *Capacity_Request) Marshal() (dAtA []byte, err error)
func (*Capacity_Request) MarshalTo ¶ added in v0.44.0
func (m *Capacity_Request) MarshalTo(dAtA []byte) (int, error)
func (*Capacity_Request) MarshalToSizedBuffer ¶ added in v0.44.0
func (m *Capacity_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Capacity_Request) ProtoMessage ¶ added in v0.44.0
func (*Capacity_Request) ProtoMessage()
func (*Capacity_Request) Reset ¶ added in v0.44.0
func (m *Capacity_Request) Reset()
func (*Capacity_Request) Size ¶ added in v0.44.0
func (m *Capacity_Request) Size() (n int)
func (*Capacity_Request) String ¶ added in v0.44.0
func (this *Capacity_Request) String() string
func (*Capacity_Request) Unmarshal ¶ added in v0.44.0
func (m *Capacity_Request) Unmarshal(dAtA []byte) error
func (*Capacity_Request) XXX_DiscardUnknown ¶ added in v0.44.0
func (m *Capacity_Request) XXX_DiscardUnknown()
func (*Capacity_Request) XXX_Marshal ¶ added in v0.44.0
func (m *Capacity_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Capacity_Request) XXX_Merge ¶ added in v0.44.0
func (m *Capacity_Request) XXX_Merge(src proto.Message)
func (*Capacity_Request) XXX_Size ¶ added in v0.44.0
func (m *Capacity_Request) XXX_Size() int
func (*Capacity_Request) XXX_Unmarshal ¶ added in v0.44.0
func (m *Capacity_Request) XXX_Unmarshal(b []byte) error
type Capacity_Request_State ¶ added in v0.44.0
type Capacity_Request_State int32
const ( STATE_CAPACITY_REQUEST_UNSPECIFIED Capacity_Request_State = 0 STATE_CAPACITY_REQUEST_COMPLETED Capacity_Request_State = 1 STATE_CAPACITY_REQUEST_IN_PROGRESS Capacity_Request_State = 2 STATE_CAPACITY_REQUEST_FAILED Capacity_Request_State = 3 )
func (Capacity_Request_State) EnumDescriptor ¶ added in v0.44.0
func (Capacity_Request_State) EnumDescriptor() ([]byte, []int)
func (Capacity_Request_State) String ¶ added in v0.44.0
func (x Capacity_Request_State) String() string
type CertificateFilterSpec ¶
type CertificateFilterSpec struct {
// The common_name in the certificate.
// Optional, default is empty.
CommonName string `protobuf:"bytes,1,opt,name=common_name,json=commonName,proto3" json:"common_name,omitempty"`
// The organization in the certificate.
// Optional, default is empty.
Organization string `protobuf:"bytes,2,opt,name=organization,proto3" json:"organization,omitempty"`
// The organizational_unit in the certificate.
// Optional, default is empty.
OrganizationalUnit string `protobuf:"bytes,3,opt,name=organizational_unit,json=organizationalUnit,proto3" json:"organizational_unit,omitempty"`
// The subject_alternative_name in the certificate.
// Optional, default is empty.
SubjectAlternativeName string `` /* 129-byte string literal not displayed */
}
func (*CertificateFilterSpec) Descriptor ¶
func (*CertificateFilterSpec) Descriptor() ([]byte, []int)
func (*CertificateFilterSpec) Equal ¶
func (this *CertificateFilterSpec) Equal(that interface{}) bool
func (*CertificateFilterSpec) GetCommonName ¶
func (m *CertificateFilterSpec) GetCommonName() string
func (*CertificateFilterSpec) GetOrganization ¶
func (m *CertificateFilterSpec) GetOrganization() string
func (*CertificateFilterSpec) GetOrganizationalUnit ¶
func (m *CertificateFilterSpec) GetOrganizationalUnit() string
func (*CertificateFilterSpec) GetSubjectAlternativeName ¶
func (m *CertificateFilterSpec) GetSubjectAlternativeName() string
func (*CertificateFilterSpec) GoString ¶
func (this *CertificateFilterSpec) GoString() string
func (*CertificateFilterSpec) Marshal ¶
func (m *CertificateFilterSpec) Marshal() (dAtA []byte, err error)
func (*CertificateFilterSpec) MarshalTo ¶
func (m *CertificateFilterSpec) MarshalTo(dAtA []byte) (int, error)
func (*CertificateFilterSpec) MarshalToSizedBuffer ¶
func (m *CertificateFilterSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CertificateFilterSpec) ProtoMessage ¶
func (*CertificateFilterSpec) ProtoMessage()
func (*CertificateFilterSpec) Reset ¶
func (m *CertificateFilterSpec) Reset()
func (*CertificateFilterSpec) Size ¶
func (m *CertificateFilterSpec) Size() (n int)
func (*CertificateFilterSpec) String ¶
func (this *CertificateFilterSpec) String() string
func (*CertificateFilterSpec) Unmarshal ¶
func (m *CertificateFilterSpec) Unmarshal(dAtA []byte) error
func (*CertificateFilterSpec) XXX_DiscardUnknown ¶
func (m *CertificateFilterSpec) XXX_DiscardUnknown()
func (*CertificateFilterSpec) XXX_Marshal ¶
func (m *CertificateFilterSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CertificateFilterSpec) XXX_Merge ¶
func (m *CertificateFilterSpec) XXX_Merge(src proto.Message)
func (*CertificateFilterSpec) XXX_Size ¶
func (m *CertificateFilterSpec) XXX_Size() int
func (*CertificateFilterSpec) XXX_Unmarshal ¶
func (m *CertificateFilterSpec) XXX_Unmarshal(b []byte) error
type CodecServerSpec ¶
type CodecServerSpec struct {
// The codec server endpoint.
Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
// Whether to pass the user access token with your endpoint.
PassAccessToken bool `protobuf:"varint,2,opt,name=pass_access_token,json=passAccessToken,proto3" json:"pass_access_token,omitempty"`
// Whether to include cross-origin credentials.
IncludeCrossOriginCredentials bool `` /* 153-byte string literal not displayed */
// A custom error message to display for remote codec server errors.
// temporal:versioning:min_version=v0.5.1
CustomErrorMessage *CodecServerSpec_CustomErrorMessage `protobuf:"bytes,4,opt,name=custom_error_message,json=customErrorMessage,proto3" json:"custom_error_message,omitempty"`
}
func (*CodecServerSpec) Descriptor ¶
func (*CodecServerSpec) Descriptor() ([]byte, []int)
func (*CodecServerSpec) Equal ¶
func (this *CodecServerSpec) Equal(that interface{}) bool
func (*CodecServerSpec) GetCustomErrorMessage ¶ added in v0.41.0
func (m *CodecServerSpec) GetCustomErrorMessage() *CodecServerSpec_CustomErrorMessage
func (*CodecServerSpec) GetEndpoint ¶
func (m *CodecServerSpec) GetEndpoint() string
func (*CodecServerSpec) GetIncludeCrossOriginCredentials ¶
func (m *CodecServerSpec) GetIncludeCrossOriginCredentials() bool
func (*CodecServerSpec) GetPassAccessToken ¶
func (m *CodecServerSpec) GetPassAccessToken() bool
func (*CodecServerSpec) GoString ¶
func (this *CodecServerSpec) GoString() string
func (*CodecServerSpec) Marshal ¶
func (m *CodecServerSpec) Marshal() (dAtA []byte, err error)
func (*CodecServerSpec) MarshalToSizedBuffer ¶
func (m *CodecServerSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CodecServerSpec) ProtoMessage ¶
func (*CodecServerSpec) ProtoMessage()
func (*CodecServerSpec) Reset ¶
func (m *CodecServerSpec) Reset()
func (*CodecServerSpec) Size ¶
func (m *CodecServerSpec) Size() (n int)
func (*CodecServerSpec) String ¶
func (this *CodecServerSpec) String() string
func (*CodecServerSpec) Unmarshal ¶
func (m *CodecServerSpec) Unmarshal(dAtA []byte) error
func (*CodecServerSpec) XXX_DiscardUnknown ¶
func (m *CodecServerSpec) XXX_DiscardUnknown()
func (*CodecServerSpec) XXX_Marshal ¶
func (m *CodecServerSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CodecServerSpec) XXX_Merge ¶
func (m *CodecServerSpec) XXX_Merge(src proto.Message)
func (*CodecServerSpec) XXX_Size ¶
func (m *CodecServerSpec) XXX_Size() int
func (*CodecServerSpec) XXX_Unmarshal ¶
func (m *CodecServerSpec) XXX_Unmarshal(b []byte) error
type CodecServerSpec_CustomErrorMessage ¶ added in v0.41.0
type CodecServerSpec_CustomErrorMessage struct {
// The error message to display by default for any remote codec server errors.
Default *CodecServerSpec_CustomErrorMessage_ErrorMessage `protobuf:"bytes,1,opt,name=default,proto3" json:"default,omitempty"`
}
func (*CodecServerSpec_CustomErrorMessage) Descriptor ¶ added in v0.41.0
func (*CodecServerSpec_CustomErrorMessage) Descriptor() ([]byte, []int)
func (*CodecServerSpec_CustomErrorMessage) Equal ¶ added in v0.41.0
func (this *CodecServerSpec_CustomErrorMessage) Equal(that interface{}) bool
func (*CodecServerSpec_CustomErrorMessage) GetDefault ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) GetDefault() *CodecServerSpec_CustomErrorMessage_ErrorMessage
func (*CodecServerSpec_CustomErrorMessage) GoString ¶ added in v0.41.0
func (this *CodecServerSpec_CustomErrorMessage) GoString() string
func (*CodecServerSpec_CustomErrorMessage) Marshal ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) Marshal() (dAtA []byte, err error)
func (*CodecServerSpec_CustomErrorMessage) MarshalTo ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) MarshalTo(dAtA []byte) (int, error)
func (*CodecServerSpec_CustomErrorMessage) MarshalToSizedBuffer ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CodecServerSpec_CustomErrorMessage) ProtoMessage ¶ added in v0.41.0
func (*CodecServerSpec_CustomErrorMessage) ProtoMessage()
func (*CodecServerSpec_CustomErrorMessage) Reset ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) Reset()
func (*CodecServerSpec_CustomErrorMessage) Size ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) Size() (n int)
func (*CodecServerSpec_CustomErrorMessage) String ¶ added in v0.41.0
func (this *CodecServerSpec_CustomErrorMessage) String() string
func (*CodecServerSpec_CustomErrorMessage) Unmarshal ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) Unmarshal(dAtA []byte) error
func (*CodecServerSpec_CustomErrorMessage) XXX_DiscardUnknown ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) XXX_DiscardUnknown()
func (*CodecServerSpec_CustomErrorMessage) XXX_Marshal ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CodecServerSpec_CustomErrorMessage) XXX_Merge ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) XXX_Merge(src proto.Message)
func (*CodecServerSpec_CustomErrorMessage) XXX_Size ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) XXX_Size() int
func (*CodecServerSpec_CustomErrorMessage) XXX_Unmarshal ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage) XXX_Unmarshal(b []byte) error
type CodecServerSpec_CustomErrorMessage_ErrorMessage ¶ added in v0.41.0
type CodecServerSpec_CustomErrorMessage_ErrorMessage struct {
// A message to display.
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// A link that is displayed along side the configured message.
Link string `protobuf:"bytes,2,opt,name=link,proto3" json:"link,omitempty"`
}
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) Descriptor ¶ added in v0.41.0
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) Descriptor() ([]byte, []int)
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) Equal ¶ added in v0.41.0
func (this *CodecServerSpec_CustomErrorMessage_ErrorMessage) Equal(that interface{}) bool
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) GetLink ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) GetLink() string
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) GetMessage ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) GetMessage() string
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) GoString ¶ added in v0.41.0
func (this *CodecServerSpec_CustomErrorMessage_ErrorMessage) GoString() string
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) Marshal ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) Marshal() (dAtA []byte, err error)
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) MarshalTo ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) MarshalTo(dAtA []byte) (int, error)
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) MarshalToSizedBuffer ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) ProtoMessage ¶ added in v0.41.0
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) ProtoMessage()
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) Reset ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) Reset()
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) Size ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) Size() (n int)
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) String ¶ added in v0.41.0
func (this *CodecServerSpec_CustomErrorMessage_ErrorMessage) String() string
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) Unmarshal ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) Unmarshal(dAtA []byte) error
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_DiscardUnknown ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_DiscardUnknown()
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Marshal ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Merge ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Merge(src proto.Message)
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Size ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Size() int
func (*CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Unmarshal ¶ added in v0.41.0
func (m *CodecServerSpec_CustomErrorMessage_ErrorMessage) XXX_Unmarshal(b []byte) error
type Endpoints ¶
type Endpoints struct {
// The web UI address.
WebAddress string `protobuf:"bytes,1,opt,name=web_address,json=webAddress,proto3" json:"web_address,omitempty"`
// The gRPC address for mTLS client connections (may be empty if mTLS is disabled).
MtlsGrpcAddress string `protobuf:"bytes,2,opt,name=mtls_grpc_address,json=mtlsGrpcAddress,proto3" json:"mtls_grpc_address,omitempty"`
// The gRPC address for API key client connections (may be empty if API keys are disabled).
GrpcAddress string `protobuf:"bytes,3,opt,name=grpc_address,json=grpcAddress,proto3" json:"grpc_address,omitempty"`
}
func (*Endpoints) Descriptor ¶
func (*Endpoints) GetGrpcAddress ¶
func (*Endpoints) GetMtlsGrpcAddress ¶
func (*Endpoints) GetWebAddress ¶
func (*Endpoints) MarshalToSizedBuffer ¶
func (*Endpoints) ProtoMessage ¶
func (*Endpoints) ProtoMessage()
func (*Endpoints) XXX_DiscardUnknown ¶
func (m *Endpoints) XXX_DiscardUnknown()
func (*Endpoints) XXX_Marshal ¶
func (*Endpoints) XXX_Unmarshal ¶
type ExportSink ¶ added in v0.34.0
type ExportSink struct {
// The unique name of the export sink, once set it can't be changed
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The version of the export sink resource.
ResourceVersion string `protobuf:"bytes,2,opt,name=resource_version,json=resourceVersion,proto3" json:"resource_version,omitempty"`
// The current state of the export sink.
State v1.ResourceState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.cloud.resource.v1.ResourceState" json:"state,omitempty"`
// The specification details of the export sink.
Spec *ExportSinkSpec `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
// The health status of the export sink.
Health ExportSink_Health `protobuf:"varint,5,opt,name=health,proto3,enum=temporal.api.cloud.namespace.v1.ExportSink_Health" json:"health,omitempty"`
// An error message describing any issues with the export sink, if applicable.
ErrorMessage string `protobuf:"bytes,6,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
// The timestamp of the latest successful data export.
LatestDataExportTime *types.Timestamp `protobuf:"bytes,7,opt,name=latest_data_export_time,json=latestDataExportTime,proto3" json:"latest_data_export_time,omitempty"`
// The timestamp of the last health check performed on the export sink.
LastHealthCheckTime *types.Timestamp `protobuf:"bytes,8,opt,name=last_health_check_time,json=lastHealthCheckTime,proto3" json:"last_health_check_time,omitempty"`
}
func (*ExportSink) Descriptor ¶ added in v0.34.0
func (*ExportSink) Descriptor() ([]byte, []int)
func (*ExportSink) Equal ¶ added in v0.34.0
func (this *ExportSink) Equal(that interface{}) bool
func (*ExportSink) GetErrorMessage ¶ added in v0.34.0
func (m *ExportSink) GetErrorMessage() string
func (*ExportSink) GetHealth ¶ added in v0.34.0
func (m *ExportSink) GetHealth() ExportSink_Health
func (*ExportSink) GetLastHealthCheckTime ¶ added in v0.34.0
func (m *ExportSink) GetLastHealthCheckTime() *types.Timestamp
func (*ExportSink) GetLatestDataExportTime ¶ added in v0.34.0
func (m *ExportSink) GetLatestDataExportTime() *types.Timestamp
func (*ExportSink) GetName ¶ added in v0.34.0
func (m *ExportSink) GetName() string
func (*ExportSink) GetResourceVersion ¶ added in v0.34.0
func (m *ExportSink) GetResourceVersion() string
func (*ExportSink) GetSpec ¶ added in v0.34.0
func (m *ExportSink) GetSpec() *ExportSinkSpec
func (*ExportSink) GetState ¶ added in v0.34.0
func (m *ExportSink) GetState() v1.ResourceState
func (*ExportSink) GoString ¶ added in v0.34.0
func (this *ExportSink) GoString() string
func (*ExportSink) Marshal ¶ added in v0.34.0
func (m *ExportSink) Marshal() (dAtA []byte, err error)
func (*ExportSink) MarshalTo ¶ added in v0.34.0
func (m *ExportSink) MarshalTo(dAtA []byte) (int, error)
func (*ExportSink) MarshalToSizedBuffer ¶ added in v0.34.0
func (m *ExportSink) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExportSink) ProtoMessage ¶ added in v0.34.0
func (*ExportSink) ProtoMessage()
func (*ExportSink) Reset ¶ added in v0.34.0
func (m *ExportSink) Reset()
func (*ExportSink) Size ¶ added in v0.34.0
func (m *ExportSink) Size() (n int)
func (*ExportSink) String ¶ added in v0.34.0
func (this *ExportSink) String() string
func (*ExportSink) Unmarshal ¶ added in v0.34.0
func (m *ExportSink) Unmarshal(dAtA []byte) error
func (*ExportSink) XXX_DiscardUnknown ¶ added in v0.34.0
func (m *ExportSink) XXX_DiscardUnknown()
func (*ExportSink) XXX_Marshal ¶ added in v0.34.0
func (m *ExportSink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExportSink) XXX_Merge ¶ added in v0.34.0
func (m *ExportSink) XXX_Merge(src proto.Message)
func (*ExportSink) XXX_Size ¶ added in v0.34.0
func (m *ExportSink) XXX_Size() int
func (*ExportSink) XXX_Unmarshal ¶ added in v0.34.0
func (m *ExportSink) XXX_Unmarshal(b []byte) error
type ExportSinkSpec ¶ added in v0.34.0
type ExportSinkSpec struct {
// The unique name of the export sink.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// A flag indicating whether the export sink is enabled or not.
Enabled bool `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
// The S3 configuration details when destination_type is S3.
S3 *v12.S3Spec `protobuf:"bytes,3,opt,name=s3,proto3" json:"s3,omitempty"`
// This is a feature under development. We will allow GCS sink support for GCP Namespaces.
// The GCS configuration details when destination_type is GCS.
Gcs *v12.GCSSpec `protobuf:"bytes,4,opt,name=gcs,proto3" json:"gcs,omitempty"`
}
func (*ExportSinkSpec) Descriptor ¶ added in v0.34.0
func (*ExportSinkSpec) Descriptor() ([]byte, []int)
func (*ExportSinkSpec) Equal ¶ added in v0.34.0
func (this *ExportSinkSpec) Equal(that interface{}) bool
func (*ExportSinkSpec) GetEnabled ¶ added in v0.34.0
func (m *ExportSinkSpec) GetEnabled() bool
func (*ExportSinkSpec) GetGcs ¶ added in v0.34.0
func (m *ExportSinkSpec) GetGcs() *v12.GCSSpec
func (*ExportSinkSpec) GetName ¶ added in v0.34.0
func (m *ExportSinkSpec) GetName() string
func (*ExportSinkSpec) GetS3 ¶ added in v0.34.0
func (m *ExportSinkSpec) GetS3() *v12.S3Spec
func (*ExportSinkSpec) GoString ¶ added in v0.34.0
func (this *ExportSinkSpec) GoString() string
func (*ExportSinkSpec) Marshal ¶ added in v0.34.0
func (m *ExportSinkSpec) Marshal() (dAtA []byte, err error)
func (*ExportSinkSpec) MarshalTo ¶ added in v0.34.0
func (m *ExportSinkSpec) MarshalTo(dAtA []byte) (int, error)
func (*ExportSinkSpec) MarshalToSizedBuffer ¶ added in v0.34.0
func (m *ExportSinkSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExportSinkSpec) ProtoMessage ¶ added in v0.34.0
func (*ExportSinkSpec) ProtoMessage()
func (*ExportSinkSpec) Reset ¶ added in v0.34.0
func (m *ExportSinkSpec) Reset()
func (*ExportSinkSpec) Size ¶ added in v0.34.0
func (m *ExportSinkSpec) Size() (n int)
func (*ExportSinkSpec) String ¶ added in v0.34.0
func (this *ExportSinkSpec) String() string
func (*ExportSinkSpec) Unmarshal ¶ added in v0.34.0
func (m *ExportSinkSpec) Unmarshal(dAtA []byte) error
func (*ExportSinkSpec) XXX_DiscardUnknown ¶ added in v0.34.0
func (m *ExportSinkSpec) XXX_DiscardUnknown()
func (*ExportSinkSpec) XXX_Marshal ¶ added in v0.34.0
func (m *ExportSinkSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExportSinkSpec) XXX_Merge ¶ added in v0.34.0
func (m *ExportSinkSpec) XXX_Merge(src proto.Message)
func (*ExportSinkSpec) XXX_Size ¶ added in v0.34.0
func (m *ExportSinkSpec) XXX_Size() int
func (*ExportSinkSpec) XXX_Unmarshal ¶ added in v0.34.0
func (m *ExportSinkSpec) XXX_Unmarshal(b []byte) error
type ExportSink_Health ¶ added in v0.34.0
type ExportSink_Health int32
const ( HEALTH_UNSPECIFIED ExportSink_Health = 0 HEALTH_OK ExportSink_Health = 1 HEALTH_ERROR_INTERNAL ExportSink_Health = 2 HEALTH_ERROR_USER_CONFIGURATION ExportSink_Health = 3 )
func (ExportSink_Health) EnumDescriptor ¶ added in v0.34.0
func (ExportSink_Health) EnumDescriptor() ([]byte, []int)
func (ExportSink_Health) String ¶ added in v0.34.0
func (x ExportSink_Health) String() string
type HighAvailabilitySpec ¶ added in v0.39.0
type HighAvailabilitySpec struct {
// Flag to disable managed failover for the namespace.
DisableManagedFailover bool `` /* 130-byte string literal not displayed */
// The desired replica to be primary.
// The actual primary replica may differ from the preferred primary when a managed failover happens.
// Optional.
// When this field is not specified, the first replica in the replicas list will be the preferred replica.
// Only specify this field after replicas are created and replica IDs are generated.
// temporal:versioning:min_version=development
// temporal:dev
PreferredPrimaryReplicaId string `` /* 140-byte string literal not displayed */
}
func (*HighAvailabilitySpec) Descriptor ¶ added in v0.39.0
func (*HighAvailabilitySpec) Descriptor() ([]byte, []int)
func (*HighAvailabilitySpec) Equal ¶ added in v0.39.0
func (this *HighAvailabilitySpec) Equal(that interface{}) bool
func (*HighAvailabilitySpec) GetDisableManagedFailover ¶ added in v0.39.0
func (m *HighAvailabilitySpec) GetDisableManagedFailover() bool
func (*HighAvailabilitySpec) GetPreferredPrimaryReplicaId ¶ added in v0.55.0
func (m *HighAvailabilitySpec) GetPreferredPrimaryReplicaId() string
func (*HighAvailabilitySpec) GoString ¶ added in v0.39.0
func (this *HighAvailabilitySpec) GoString() string
func (*HighAvailabilitySpec) Marshal ¶ added in v0.39.0
func (m *HighAvailabilitySpec) Marshal() (dAtA []byte, err error)
func (*HighAvailabilitySpec) MarshalTo ¶ added in v0.39.0
func (m *HighAvailabilitySpec) MarshalTo(dAtA []byte) (int, error)
func (*HighAvailabilitySpec) MarshalToSizedBuffer ¶ added in v0.39.0
func (m *HighAvailabilitySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HighAvailabilitySpec) ProtoMessage ¶ added in v0.39.0
func (*HighAvailabilitySpec) ProtoMessage()
func (*HighAvailabilitySpec) Reset ¶ added in v0.39.0
func (m *HighAvailabilitySpec) Reset()
func (*HighAvailabilitySpec) Size ¶ added in v0.39.0
func (m *HighAvailabilitySpec) Size() (n int)
func (*HighAvailabilitySpec) String ¶ added in v0.39.0
func (this *HighAvailabilitySpec) String() string
func (*HighAvailabilitySpec) Unmarshal ¶ added in v0.39.0
func (m *HighAvailabilitySpec) Unmarshal(dAtA []byte) error
func (*HighAvailabilitySpec) XXX_DiscardUnknown ¶ added in v0.39.0
func (m *HighAvailabilitySpec) XXX_DiscardUnknown()
func (*HighAvailabilitySpec) XXX_Marshal ¶ added in v0.39.0
func (m *HighAvailabilitySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HighAvailabilitySpec) XXX_Merge ¶ added in v0.39.0
func (m *HighAvailabilitySpec) XXX_Merge(src proto.Message)
func (*HighAvailabilitySpec) XXX_Size ¶ added in v0.39.0
func (m *HighAvailabilitySpec) XXX_Size() int
func (*HighAvailabilitySpec) XXX_Unmarshal ¶ added in v0.39.0
func (m *HighAvailabilitySpec) XXX_Unmarshal(b []byte) error
type LifecycleSpec ¶ added in v0.38.0
type LifecycleSpec struct {
// Flag to enable delete protection for the namespace.
EnableDeleteProtection bool `` /* 130-byte string literal not displayed */
}
func (*LifecycleSpec) Descriptor ¶ added in v0.38.0
func (*LifecycleSpec) Descriptor() ([]byte, []int)
func (*LifecycleSpec) Equal ¶ added in v0.38.0
func (this *LifecycleSpec) Equal(that interface{}) bool
func (*LifecycleSpec) GetEnableDeleteProtection ¶ added in v0.38.0
func (m *LifecycleSpec) GetEnableDeleteProtection() bool
func (*LifecycleSpec) GoString ¶ added in v0.38.0
func (this *LifecycleSpec) GoString() string
func (*LifecycleSpec) Marshal ¶ added in v0.38.0
func (m *LifecycleSpec) Marshal() (dAtA []byte, err error)
func (*LifecycleSpec) MarshalTo ¶ added in v0.38.0
func (m *LifecycleSpec) MarshalTo(dAtA []byte) (int, error)
func (*LifecycleSpec) MarshalToSizedBuffer ¶ added in v0.38.0
func (m *LifecycleSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LifecycleSpec) ProtoMessage ¶ added in v0.38.0
func (*LifecycleSpec) ProtoMessage()
func (*LifecycleSpec) Reset ¶ added in v0.38.0
func (m *LifecycleSpec) Reset()
func (*LifecycleSpec) Size ¶ added in v0.38.0
func (m *LifecycleSpec) Size() (n int)
func (*LifecycleSpec) String ¶ added in v0.38.0
func (this *LifecycleSpec) String() string
func (*LifecycleSpec) Unmarshal ¶ added in v0.38.0
func (m *LifecycleSpec) Unmarshal(dAtA []byte) error
func (*LifecycleSpec) XXX_DiscardUnknown ¶ added in v0.38.0
func (m *LifecycleSpec) XXX_DiscardUnknown()
func (*LifecycleSpec) XXX_Marshal ¶ added in v0.38.0
func (m *LifecycleSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LifecycleSpec) XXX_Merge ¶ added in v0.38.0
func (m *LifecycleSpec) XXX_Merge(src proto.Message)
func (*LifecycleSpec) XXX_Size ¶ added in v0.38.0
func (m *LifecycleSpec) XXX_Size() int
func (*LifecycleSpec) XXX_Unmarshal ¶ added in v0.38.0
func (m *LifecycleSpec) XXX_Unmarshal(b []byte) error
type Limits ¶
type Limits struct {
// The number of actions per second (APS) that is currently allowed for the namespace.
// The namespace may be throttled if its APS exceeds the limit.
ActionsPerSecondLimit int32 `` /* 129-byte string literal not displayed */
}
Note: Consider adding new limit to external metrics instead of adding to the following Limits objects
func (*Limits) Descriptor ¶
func (*Limits) GetActionsPerSecondLimit ¶
func (*Limits) MarshalToSizedBuffer ¶
func (*Limits) ProtoMessage ¶
func (*Limits) ProtoMessage()
func (*Limits) XXX_DiscardUnknown ¶
func (m *Limits) XXX_DiscardUnknown()
func (*Limits) XXX_Marshal ¶
func (*Limits) XXX_Unmarshal ¶
type Migration ¶ added in v0.38.0
type Migration struct {
// The unique id of this migration.
MigrationId string `protobuf:"bytes,1,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"`
// The MigrationSpec provided in the StartMigrationRequest.
Spec *MigrationSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
// The state of the migration.
State Migration_State `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.cloud.namespace.v1.Migration_State" json:"state,omitempty"`
// The source and destination replicas involved in the migration.
Replicas []*MigrationReplica `protobuf:"bytes,4,rep,name=replicas,proto3" json:"replicas,omitempty"`
// The number of workflows replicated.
// Deprecated: Use replication_estimate.replicated_count instead.
ReplicatedWorkflows int64 `protobuf:"varint,5,opt,name=replicated_workflows,json=replicatedWorkflows,proto3" json:"replicated_workflows,omitempty"` // Deprecated: Do not use.
// The number of workflows remaining.
// Deprecated: Use replication_estimate.remaining_count instead.
ReplicatedWorkflowsRemaining int64 `` // Deprecated: Do not use.
/* 148-byte string literal not displayed */
// An error message if the migration failed.
FailureMessage string `protobuf:"bytes,7,opt,name=failure_message,json=failureMessage,proto3" json:"failure_message,omitempty"`
// Detailed replication progress and estimates
ReplicationEstimate *ReplicationEstimate `protobuf:"bytes,8,opt,name=replication_estimate,json=replicationEstimate,proto3" json:"replication_estimate,omitempty"`
}
temporal:dev
func (*Migration) Descriptor ¶ added in v0.38.0
func (*Migration) GetFailureMessage ¶ added in v0.38.0
func (*Migration) GetMigrationId ¶ added in v0.38.0
func (*Migration) GetReplicas ¶ added in v0.38.0
func (m *Migration) GetReplicas() []*MigrationReplica
func (*Migration) GetReplicatedWorkflows
deprecated
added in
v0.38.0
func (*Migration) GetReplicatedWorkflowsRemaining
deprecated
added in
v0.38.0
func (*Migration) GetReplicationEstimate ¶ added in v0.51.0
func (m *Migration) GetReplicationEstimate() *ReplicationEstimate
func (*Migration) GetSpec ¶ added in v0.38.0
func (m *Migration) GetSpec() *MigrationSpec
func (*Migration) GetState ¶ added in v0.38.0
func (m *Migration) GetState() Migration_State
func (*Migration) MarshalToSizedBuffer ¶ added in v0.38.0
func (*Migration) ProtoMessage ¶ added in v0.38.0
func (*Migration) ProtoMessage()
func (*Migration) XXX_DiscardUnknown ¶ added in v0.38.0
func (m *Migration) XXX_DiscardUnknown()
func (*Migration) XXX_Marshal ¶ added in v0.38.0
func (*Migration) XXX_Unmarshal ¶ added in v0.38.0
type MigrationReplica ¶ added in v0.38.0
type MigrationReplica struct {
// The id of this replica. Indicates whether the replica is on the source
// or destination side of the migration.
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// The state of this replica.
State MigrationReplica_State `protobuf:"varint,2,opt,name=state,proto3,enum=temporal.api.cloud.namespace.v1.MigrationReplica_State" json:"state,omitempty"`
}
temporal:dev
func (*MigrationReplica) Descriptor ¶ added in v0.38.0
func (*MigrationReplica) Descriptor() ([]byte, []int)
func (*MigrationReplica) Equal ¶ added in v0.38.0
func (this *MigrationReplica) Equal(that interface{}) bool
func (*MigrationReplica) GetId ¶ added in v0.38.0
func (m *MigrationReplica) GetId() string
func (*MigrationReplica) GetState ¶ added in v0.38.0
func (m *MigrationReplica) GetState() MigrationReplica_State
func (*MigrationReplica) GoString ¶ added in v0.38.0
func (this *MigrationReplica) GoString() string
func (*MigrationReplica) Marshal ¶ added in v0.38.0
func (m *MigrationReplica) Marshal() (dAtA []byte, err error)
func (*MigrationReplica) MarshalTo ¶ added in v0.38.0
func (m *MigrationReplica) MarshalTo(dAtA []byte) (int, error)
func (*MigrationReplica) MarshalToSizedBuffer ¶ added in v0.38.0
func (m *MigrationReplica) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrationReplica) ProtoMessage ¶ added in v0.38.0
func (*MigrationReplica) ProtoMessage()
func (*MigrationReplica) Reset ¶ added in v0.38.0
func (m *MigrationReplica) Reset()
func (*MigrationReplica) Size ¶ added in v0.38.0
func (m *MigrationReplica) Size() (n int)
func (*MigrationReplica) String ¶ added in v0.38.0
func (this *MigrationReplica) String() string
func (*MigrationReplica) Unmarshal ¶ added in v0.38.0
func (m *MigrationReplica) Unmarshal(dAtA []byte) error
func (*MigrationReplica) XXX_DiscardUnknown ¶ added in v0.38.0
func (m *MigrationReplica) XXX_DiscardUnknown()
func (*MigrationReplica) XXX_Marshal ¶ added in v0.38.0
func (m *MigrationReplica) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MigrationReplica) XXX_Merge ¶ added in v0.38.0
func (m *MigrationReplica) XXX_Merge(src proto.Message)
func (*MigrationReplica) XXX_Size ¶ added in v0.38.0
func (m *MigrationReplica) XXX_Size() int
func (*MigrationReplica) XXX_Unmarshal ¶ added in v0.38.0
func (m *MigrationReplica) XXX_Unmarshal(b []byte) error
type MigrationReplica_State ¶ added in v0.38.0
type MigrationReplica_State int32
const ( STATE_REPLICA_UNSPECIFIED MigrationReplica_State = 0 STATE_REPLICA_ACTIVE MigrationReplica_State = 1 STATE_REPLICA_PASSIVE_OUT_OF_SYNC MigrationReplica_State = 2 STATE_REPLICA_PASSIVE_IN_SYNC MigrationReplica_State = 3 // If aborted migration, or if replication failed. STATE_REPLICA_ABANDONED MigrationReplica_State = 4 )
func (MigrationReplica_State) EnumDescriptor ¶ added in v0.38.0
func (MigrationReplica_State) EnumDescriptor() ([]byte, []int)
func (MigrationReplica_State) String ¶ added in v0.38.0
func (x MigrationReplica_State) String() string
type MigrationSpec ¶ added in v0.38.0
type MigrationSpec struct {
// The id of the migration endpoint used for connecting
// the self-hosted Temporal cluster to Temporal cloud.
MigrationEndpointId string `protobuf:"bytes,1,opt,name=migration_endpoint_id,json=migrationEndpointId,proto3" json:"migration_endpoint_id,omitempty"`
// Types that are valid to be assigned to Spec:
//
// *MigrationSpec_ToCloudSpec
// *MigrationSpec_ToSelfHostedSpec
Spec isMigrationSpec_Spec `protobuf_oneof:"spec"`
}
temporal:dev
func (*MigrationSpec) Descriptor ¶ added in v0.38.0
func (*MigrationSpec) Descriptor() ([]byte, []int)
func (*MigrationSpec) Equal ¶ added in v0.38.0
func (this *MigrationSpec) Equal(that interface{}) bool
func (*MigrationSpec) GetMigrationEndpointId ¶ added in v0.38.0
func (m *MigrationSpec) GetMigrationEndpointId() string
func (*MigrationSpec) GetSpec ¶ added in v0.38.0
func (m *MigrationSpec) GetSpec() isMigrationSpec_Spec
func (*MigrationSpec) GetToCloudSpec ¶ added in v0.38.0
func (m *MigrationSpec) GetToCloudSpec() *MigrationToCloudSpec
func (*MigrationSpec) GetToSelfHostedSpec ¶ added in v0.51.0
func (m *MigrationSpec) GetToSelfHostedSpec() *MigrationToSelfHostedSpec
func (*MigrationSpec) GoString ¶ added in v0.38.0
func (this *MigrationSpec) GoString() string
func (*MigrationSpec) Marshal ¶ added in v0.38.0
func (m *MigrationSpec) Marshal() (dAtA []byte, err error)
func (*MigrationSpec) MarshalTo ¶ added in v0.38.0
func (m *MigrationSpec) MarshalTo(dAtA []byte) (int, error)
func (*MigrationSpec) MarshalToSizedBuffer ¶ added in v0.38.0
func (m *MigrationSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrationSpec) ProtoMessage ¶ added in v0.38.0
func (*MigrationSpec) ProtoMessage()
func (*MigrationSpec) Reset ¶ added in v0.38.0
func (m *MigrationSpec) Reset()
func (*MigrationSpec) Size ¶ added in v0.38.0
func (m *MigrationSpec) Size() (n int)
func (*MigrationSpec) String ¶ added in v0.38.0
func (this *MigrationSpec) String() string
func (*MigrationSpec) Unmarshal ¶ added in v0.38.0
func (m *MigrationSpec) Unmarshal(dAtA []byte) error
func (*MigrationSpec) XXX_DiscardUnknown ¶ added in v0.38.0
func (m *MigrationSpec) XXX_DiscardUnknown()
func (*MigrationSpec) XXX_Marshal ¶ added in v0.38.0
func (m *MigrationSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MigrationSpec) XXX_Merge ¶ added in v0.38.0
func (m *MigrationSpec) XXX_Merge(src proto.Message)
func (*MigrationSpec) XXX_OneofWrappers ¶ added in v0.38.0
func (*MigrationSpec) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*MigrationSpec) XXX_Size ¶ added in v0.38.0
func (m *MigrationSpec) XXX_Size() int
func (*MigrationSpec) XXX_Unmarshal ¶ added in v0.38.0
func (m *MigrationSpec) XXX_Unmarshal(b []byte) error
type MigrationSpec_ToCloudSpec ¶ added in v0.38.0
type MigrationSpec_ToCloudSpec struct {
ToCloudSpec *MigrationToCloudSpec `protobuf:"bytes,2,opt,name=to_cloud_spec,json=toCloudSpec,proto3,oneof" json:"to_cloud_spec,omitempty"`
}
func (*MigrationSpec_ToCloudSpec) Equal ¶ added in v0.38.0
func (this *MigrationSpec_ToCloudSpec) Equal(that interface{}) bool
func (*MigrationSpec_ToCloudSpec) GoString ¶ added in v0.38.0
func (this *MigrationSpec_ToCloudSpec) GoString() string
func (*MigrationSpec_ToCloudSpec) MarshalTo ¶ added in v0.38.0
func (m *MigrationSpec_ToCloudSpec) MarshalTo(dAtA []byte) (int, error)
func (*MigrationSpec_ToCloudSpec) MarshalToSizedBuffer ¶ added in v0.38.0
func (m *MigrationSpec_ToCloudSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrationSpec_ToCloudSpec) Size ¶ added in v0.38.0
func (m *MigrationSpec_ToCloudSpec) Size() (n int)
func (*MigrationSpec_ToCloudSpec) String ¶ added in v0.38.0
func (this *MigrationSpec_ToCloudSpec) String() string
type MigrationSpec_ToSelfHostedSpec ¶ added in v0.51.0
type MigrationSpec_ToSelfHostedSpec struct {
ToSelfHostedSpec *MigrationToSelfHostedSpec `protobuf:"bytes,3,opt,name=to_self_hosted_spec,json=toSelfHostedSpec,proto3,oneof" json:"to_self_hosted_spec,omitempty"`
}
func (*MigrationSpec_ToSelfHostedSpec) Equal ¶ added in v0.51.0
func (this *MigrationSpec_ToSelfHostedSpec) Equal(that interface{}) bool
func (*MigrationSpec_ToSelfHostedSpec) GoString ¶ added in v0.51.0
func (this *MigrationSpec_ToSelfHostedSpec) GoString() string
func (*MigrationSpec_ToSelfHostedSpec) MarshalTo ¶ added in v0.51.0
func (m *MigrationSpec_ToSelfHostedSpec) MarshalTo(dAtA []byte) (int, error)
func (*MigrationSpec_ToSelfHostedSpec) MarshalToSizedBuffer ¶ added in v0.51.0
func (m *MigrationSpec_ToSelfHostedSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrationSpec_ToSelfHostedSpec) Size ¶ added in v0.51.0
func (m *MigrationSpec_ToSelfHostedSpec) Size() (n int)
func (*MigrationSpec_ToSelfHostedSpec) String ¶ added in v0.51.0
func (this *MigrationSpec_ToSelfHostedSpec) String() string
type MigrationToCloudSpec ¶ added in v0.38.0
type MigrationToCloudSpec struct {
// The source namespace name for the migration.
SourceNamespace string `protobuf:"bytes,1,opt,name=source_namespace,json=sourceNamespace,proto3" json:"source_namespace,omitempty"`
// The target namespace name for the migration.
TargetNamespace string `protobuf:"bytes,2,opt,name=target_namespace,json=targetNamespace,proto3" json:"target_namespace,omitempty"`
}
temporal:dev
func (*MigrationToCloudSpec) Descriptor ¶ added in v0.38.0
func (*MigrationToCloudSpec) Descriptor() ([]byte, []int)
func (*MigrationToCloudSpec) Equal ¶ added in v0.38.0
func (this *MigrationToCloudSpec) Equal(that interface{}) bool
func (*MigrationToCloudSpec) GetSourceNamespace ¶ added in v0.38.0
func (m *MigrationToCloudSpec) GetSourceNamespace() string
func (*MigrationToCloudSpec) GetTargetNamespace ¶ added in v0.41.0
func (m *MigrationToCloudSpec) GetTargetNamespace() string
func (*MigrationToCloudSpec) GoString ¶ added in v0.38.0
func (this *MigrationToCloudSpec) GoString() string
func (*MigrationToCloudSpec) Marshal ¶ added in v0.38.0
func (m *MigrationToCloudSpec) Marshal() (dAtA []byte, err error)
func (*MigrationToCloudSpec) MarshalTo ¶ added in v0.38.0
func (m *MigrationToCloudSpec) MarshalTo(dAtA []byte) (int, error)
func (*MigrationToCloudSpec) MarshalToSizedBuffer ¶ added in v0.38.0
func (m *MigrationToCloudSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrationToCloudSpec) ProtoMessage ¶ added in v0.38.0
func (*MigrationToCloudSpec) ProtoMessage()
func (*MigrationToCloudSpec) Reset ¶ added in v0.38.0
func (m *MigrationToCloudSpec) Reset()
func (*MigrationToCloudSpec) Size ¶ added in v0.38.0
func (m *MigrationToCloudSpec) Size() (n int)
func (*MigrationToCloudSpec) String ¶ added in v0.38.0
func (this *MigrationToCloudSpec) String() string
func (*MigrationToCloudSpec) Unmarshal ¶ added in v0.38.0
func (m *MigrationToCloudSpec) Unmarshal(dAtA []byte) error
func (*MigrationToCloudSpec) XXX_DiscardUnknown ¶ added in v0.38.0
func (m *MigrationToCloudSpec) XXX_DiscardUnknown()
func (*MigrationToCloudSpec) XXX_Marshal ¶ added in v0.38.0
func (m *MigrationToCloudSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MigrationToCloudSpec) XXX_Merge ¶ added in v0.38.0
func (m *MigrationToCloudSpec) XXX_Merge(src proto.Message)
func (*MigrationToCloudSpec) XXX_Size ¶ added in v0.38.0
func (m *MigrationToCloudSpec) XXX_Size() int
func (*MigrationToCloudSpec) XXX_Unmarshal ¶ added in v0.38.0
func (m *MigrationToCloudSpec) XXX_Unmarshal(b []byte) error
type MigrationToSelfHostedSpec ¶ added in v0.51.0
type MigrationToSelfHostedSpec struct {
// The source namespace name for the migration.
SourceNamespace string `protobuf:"bytes,1,opt,name=source_namespace,json=sourceNamespace,proto3" json:"source_namespace,omitempty"`
// The target namespace name for the migration.
TargetNamespace string `protobuf:"bytes,2,opt,name=target_namespace,json=targetNamespace,proto3" json:"target_namespace,omitempty"`
}
temporal:dev
func (*MigrationToSelfHostedSpec) Descriptor ¶ added in v0.51.0
func (*MigrationToSelfHostedSpec) Descriptor() ([]byte, []int)
func (*MigrationToSelfHostedSpec) Equal ¶ added in v0.51.0
func (this *MigrationToSelfHostedSpec) Equal(that interface{}) bool
func (*MigrationToSelfHostedSpec) GetSourceNamespace ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) GetSourceNamespace() string
func (*MigrationToSelfHostedSpec) GetTargetNamespace ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) GetTargetNamespace() string
func (*MigrationToSelfHostedSpec) GoString ¶ added in v0.51.0
func (this *MigrationToSelfHostedSpec) GoString() string
func (*MigrationToSelfHostedSpec) Marshal ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) Marshal() (dAtA []byte, err error)
func (*MigrationToSelfHostedSpec) MarshalTo ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) MarshalTo(dAtA []byte) (int, error)
func (*MigrationToSelfHostedSpec) MarshalToSizedBuffer ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MigrationToSelfHostedSpec) ProtoMessage ¶ added in v0.51.0
func (*MigrationToSelfHostedSpec) ProtoMessage()
func (*MigrationToSelfHostedSpec) Reset ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) Reset()
func (*MigrationToSelfHostedSpec) Size ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) Size() (n int)
func (*MigrationToSelfHostedSpec) String ¶ added in v0.51.0
func (this *MigrationToSelfHostedSpec) String() string
func (*MigrationToSelfHostedSpec) Unmarshal ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) Unmarshal(dAtA []byte) error
func (*MigrationToSelfHostedSpec) XXX_DiscardUnknown ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) XXX_DiscardUnknown()
func (*MigrationToSelfHostedSpec) XXX_Marshal ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MigrationToSelfHostedSpec) XXX_Merge ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) XXX_Merge(src proto.Message)
func (*MigrationToSelfHostedSpec) XXX_Size ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) XXX_Size() int
func (*MigrationToSelfHostedSpec) XXX_Unmarshal ¶ added in v0.51.0
func (m *MigrationToSelfHostedSpec) XXX_Unmarshal(b []byte) error
type Migration_State ¶ added in v0.38.0
type Migration_State int32
const ( STATE_MIGRATION_UNSPECIFIED Migration_State = 0 STATE_MIGRATION_MIGRATION_STARTED Migration_State = 1 STATE_MIGRATION_REPLICATION_IN_PROGRESS Migration_State = 2 STATE_MIGRATION_WAITING_FOR_HANDOVER Migration_State = 3 STATE_MIGRATION_HANDOVER_IN_PROGRESS Migration_State = 4 STATE_MIGRATION_READY_FOR_CONFIRMATION Migration_State = 5 STATE_MIGRATION_COMPLETE Migration_State = 6 STATE_MIGRATION_FAILED Migration_State = 7 STATE_MIGRATION_ABORT_IN_PROGRESS Migration_State = 8 STATE_MIGRATION_ABORTED Migration_State = 9 STATE_MIGRATION_CONFIRM_IN_PROGRESS Migration_State = 10 )
func (Migration_State) EnumDescriptor ¶ added in v0.38.0
func (Migration_State) EnumDescriptor() ([]byte, []int)
func (Migration_State) String ¶ added in v0.38.0
func (x Migration_State) String() string
type MtlsAuthSpec ¶
type MtlsAuthSpec struct {
// The base64 encoded ca cert(s) in PEM format that the clients can use for authentication and authorization.
// This must only be one value, but the CA can have a chain.
//
// (-- api-linter: core::0140::base64=disabled --)
// Deprecated: Use accepted_client_ca instead. Will be ignored when accepted_client_ca is set.
// temporal:versioning:max_version=v0.2.0
AcceptedClientCaDeprecated string `` // Deprecated: Do not use.
/* 143-byte string literal not displayed */
// The ca cert(s) in PEM format that the clients can use for authentication and authorization.
// This must only be one value, but the CA can have a chain.
// temporal:versioning:min_version=v0.2.0
// temporal:codegen:ignore
AcceptedClientCa []byte `protobuf:"bytes,4,opt,name=accepted_client_ca,json=acceptedClientCa,proto3" json:"accepted_client_ca,omitempty"`
// Certificate filters which, if specified, only allow connections from client certificates whose distinguished name properties match at least one of the filters.
// This allows limiting access to specific end-entity certificates.
// Optional, default is empty.
CertificateFilters []*CertificateFilterSpec `protobuf:"bytes,2,rep,name=certificate_filters,json=certificateFilters,proto3" json:"certificate_filters,omitempty"`
// Flag to enable mTLS auth (default: disabled).
// Note: disabling mTLS auth will cause existing mTLS connections to fail.
// temporal:versioning:min_version=v0.2.0
Enabled bool `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
}
func (*MtlsAuthSpec) Descriptor ¶
func (*MtlsAuthSpec) Descriptor() ([]byte, []int)
func (*MtlsAuthSpec) Equal ¶
func (this *MtlsAuthSpec) Equal(that interface{}) bool
func (*MtlsAuthSpec) GetAcceptedClientCa ¶
func (m *MtlsAuthSpec) GetAcceptedClientCa() []byte
func (*MtlsAuthSpec) GetAcceptedClientCaDeprecated
deprecated
added in
v0.34.0
func (m *MtlsAuthSpec) GetAcceptedClientCaDeprecated() string
Deprecated: Do not use.
func (*MtlsAuthSpec) GetCertificateFilters ¶
func (m *MtlsAuthSpec) GetCertificateFilters() []*CertificateFilterSpec
func (*MtlsAuthSpec) GetEnabled ¶
func (m *MtlsAuthSpec) GetEnabled() bool
func (*MtlsAuthSpec) GoString ¶
func (this *MtlsAuthSpec) GoString() string
func (*MtlsAuthSpec) Marshal ¶
func (m *MtlsAuthSpec) Marshal() (dAtA []byte, err error)
func (*MtlsAuthSpec) MarshalToSizedBuffer ¶
func (m *MtlsAuthSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MtlsAuthSpec) ProtoMessage ¶
func (*MtlsAuthSpec) ProtoMessage()
func (*MtlsAuthSpec) Reset ¶
func (m *MtlsAuthSpec) Reset()
func (*MtlsAuthSpec) Size ¶
func (m *MtlsAuthSpec) Size() (n int)
func (*MtlsAuthSpec) String ¶
func (this *MtlsAuthSpec) String() string
func (*MtlsAuthSpec) Unmarshal ¶
func (m *MtlsAuthSpec) Unmarshal(dAtA []byte) error
func (*MtlsAuthSpec) XXX_DiscardUnknown ¶
func (m *MtlsAuthSpec) XXX_DiscardUnknown()
func (*MtlsAuthSpec) XXX_Marshal ¶
func (m *MtlsAuthSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MtlsAuthSpec) XXX_Merge ¶
func (m *MtlsAuthSpec) XXX_Merge(src proto.Message)
func (*MtlsAuthSpec) XXX_Size ¶
func (m *MtlsAuthSpec) XXX_Size() int
func (*MtlsAuthSpec) XXX_Unmarshal ¶
func (m *MtlsAuthSpec) XXX_Unmarshal(b []byte) error
type Namespace ¶
type Namespace struct {
// The namespace identifier.
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
// The current version of the namespace specification.
// The next update operation will have to include this version.
ResourceVersion string `protobuf:"bytes,2,opt,name=resource_version,json=resourceVersion,proto3" json:"resource_version,omitempty"`
// The namespace specification.
Spec *NamespaceSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
// The current state of the namespace.
// Deprecated: Use state instead.
// temporal:versioning:max_version=v0.3.0
StateDeprecated string `protobuf:"bytes,4,opt,name=state_deprecated,json=stateDeprecated,proto3" json:"state_deprecated,omitempty"` // Deprecated: Do not use.
// The current state of the namespace.
// For any failed state, reach out to Temporal Cloud support for remediation.
// temporal:versioning:min_version=v0.3.0
// temporal:enums:replaces=state_deprecated
State v1.ResourceState `protobuf:"varint,13,opt,name=state,proto3,enum=temporal.api.cloud.resource.v1.ResourceState" json:"state,omitempty"`
// The id of the async operation that is creating/updating/deleting the namespace, if any.
AsyncOperationId string `protobuf:"bytes,5,opt,name=async_operation_id,json=asyncOperationId,proto3" json:"async_operation_id,omitempty"`
// The endpoints for the namespace.
Endpoints *Endpoints `protobuf:"bytes,6,opt,name=endpoints,proto3" json:"endpoints,omitempty"`
// The currently active region for the namespace.
ActiveRegion string `protobuf:"bytes,7,opt,name=active_region,json=activeRegion,proto3" json:"active_region,omitempty"`
// The limits set on the namespace currently.
Limits *Limits `protobuf:"bytes,8,opt,name=limits,proto3" json:"limits,omitempty"`
// The private connectivities for the namespace, if any.
PrivateConnectivities []*PrivateConnectivity `protobuf:"bytes,9,rep,name=private_connectivities,json=privateConnectivities,proto3" json:"private_connectivities,omitempty"`
// The date and time when the namespace was created.
CreatedTime *types.Timestamp `protobuf:"bytes,10,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
// The date and time when the namespace was last modified.
// Will not be set if the namespace has never been modified.
LastModifiedTime *types.Timestamp `protobuf:"bytes,11,opt,name=last_modified_time,json=lastModifiedTime,proto3" json:"last_modified_time,omitempty"`
// The status of each region where the namespace is available.
// The id of the region is the key and the status is the value of the map.
// deprecated: Use replicas field instead.
RegionStatus map[string]*NamespaceRegionStatus `` // Deprecated: Do not use.
/* 186-byte string literal not displayed */
// connectivity_rules that set on this namespace
ConnectivityRules []*v11.ConnectivityRule `protobuf:"bytes,14,rep,name=connectivity_rules,json=connectivityRules,proto3" json:"connectivity_rules,omitempty"`
// The tags for the namespace.
Tags map[string]string `` /* 150-byte string literal not displayed */
// The capacity of the namespace.
Capacity *Capacity `protobuf:"bytes,16,opt,name=capacity,proto3" json:"capacity,omitempty"`
// temporal:dev
ProjectId string `protobuf:"bytes,17,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
// The status of each replica where the namespace is available.
// temporal:dev
Replicas []*Replica `protobuf:"bytes,18,rep,name=replicas,proto3" json:"replicas,omitempty"`
}
func (*Namespace) Descriptor ¶
func (*Namespace) GetActiveRegion ¶
func (*Namespace) GetAsyncOperationId ¶
func (*Namespace) GetCapacity ¶ added in v0.44.0
func (*Namespace) GetConnectivityRules ¶ added in v0.43.0
func (m *Namespace) GetConnectivityRules() []*v11.ConnectivityRule
func (*Namespace) GetCreatedTime ¶
func (*Namespace) GetEndpoints ¶
func (*Namespace) GetLastModifiedTime ¶
func (*Namespace) GetNamespace ¶
func (*Namespace) GetPrivateConnectivities ¶
func (m *Namespace) GetPrivateConnectivities() []*PrivateConnectivity
func (*Namespace) GetProjectId ¶ added in v0.55.0
func (*Namespace) GetRegionStatus
deprecated
func (m *Namespace) GetRegionStatus() map[string]*NamespaceRegionStatus
Deprecated: Do not use.
func (*Namespace) GetReplicas ¶ added in v0.55.0
func (*Namespace) GetResourceVersion ¶
func (*Namespace) GetSpec ¶
func (m *Namespace) GetSpec() *NamespaceSpec
func (*Namespace) GetState ¶
func (m *Namespace) GetState() v1.ResourceState
func (*Namespace) GetStateDeprecated
deprecated
added in
v0.34.0
func (*Namespace) MarshalToSizedBuffer ¶
func (*Namespace) ProtoMessage ¶
func (*Namespace) ProtoMessage()
func (*Namespace) XXX_DiscardUnknown ¶
func (m *Namespace) XXX_DiscardUnknown()
func (*Namespace) XXX_Marshal ¶
func (*Namespace) XXX_Unmarshal ¶
type NamespaceCapacityInfo ¶ added in v0.55.0
type NamespaceCapacityInfo struct {
// The namespace identifier.
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
// Whether the namespace's APS limit was set by Temporal Support.
// When true, adjusting the namespace's capacity will reset this limit.
HasLegacyLimits bool `protobuf:"varint,2,opt,name=has_legacy_limits,json=hasLegacyLimits,proto3" json:"has_legacy_limits,omitempty"`
// The current capacity of the namespace.
// Includes the current mode (on-demand or provisioned) and latest request status.
CurrentCapacity *Capacity `protobuf:"bytes,3,opt,name=current_capacity,json=currentCapacity,proto3" json:"current_capacity,omitempty"`
// Available capacity mode options for this namespace.
// Contains configuration limits for both provisioned and on-demand modes.
ModeOptions *NamespaceCapacityInfo_CapacityModeOptions `protobuf:"bytes,4,opt,name=mode_options,json=modeOptions,proto3" json:"mode_options,omitempty"`
// Usage statistics for the namespace over the last 7 days.
// Used to calculate On-Demand capacity limits, also useful for capacity planning.
Stats *NamespaceCapacityInfo_Stats `protobuf:"bytes,5,opt,name=stats,proto3" json:"stats,omitempty"`
}
NamespaceCapacityInfo contains detailed capacity information for a namespace. This message uses nested types following the pattern established by Capacity and CapacitySpec. temporal:dev
func (*NamespaceCapacityInfo) Descriptor ¶ added in v0.55.0
func (*NamespaceCapacityInfo) Descriptor() ([]byte, []int)
func (*NamespaceCapacityInfo) Equal ¶ added in v0.55.0
func (this *NamespaceCapacityInfo) Equal(that interface{}) bool
func (*NamespaceCapacityInfo) GetCurrentCapacity ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) GetCurrentCapacity() *Capacity
func (*NamespaceCapacityInfo) GetHasLegacyLimits ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) GetHasLegacyLimits() bool
func (*NamespaceCapacityInfo) GetModeOptions ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) GetModeOptions() *NamespaceCapacityInfo_CapacityModeOptions
func (*NamespaceCapacityInfo) GetNamespace ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) GetNamespace() string
func (*NamespaceCapacityInfo) GetStats ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) GetStats() *NamespaceCapacityInfo_Stats
func (*NamespaceCapacityInfo) GoString ¶ added in v0.55.0
func (this *NamespaceCapacityInfo) GoString() string
func (*NamespaceCapacityInfo) Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) Marshal() (dAtA []byte, err error)
func (*NamespaceCapacityInfo) MarshalTo ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo) MarshalToSizedBuffer ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo) ProtoMessage ¶ added in v0.55.0
func (*NamespaceCapacityInfo) ProtoMessage()
func (*NamespaceCapacityInfo) Reset ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) Reset()
func (*NamespaceCapacityInfo) Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) Size() (n int)
func (*NamespaceCapacityInfo) String ¶ added in v0.55.0
func (this *NamespaceCapacityInfo) String() string
func (*NamespaceCapacityInfo) Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) Unmarshal(dAtA []byte) error
func (*NamespaceCapacityInfo) XXX_DiscardUnknown ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) XXX_DiscardUnknown()
func (*NamespaceCapacityInfo) XXX_Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NamespaceCapacityInfo) XXX_Merge ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) XXX_Merge(src proto.Message)
func (*NamespaceCapacityInfo) XXX_Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) XXX_Size() int
func (*NamespaceCapacityInfo) XXX_Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo) XXX_Unmarshal(b []byte) error
type NamespaceCapacityInfo_CapacityModeOptions ¶ added in v0.55.0
type NamespaceCapacityInfo_CapacityModeOptions struct {
// Provisioned capacity options and entitlements.
Provisioned *NamespaceCapacityInfo_CapacityModeOptions_Provisioned `protobuf:"bytes,1,opt,name=provisioned,proto3" json:"provisioned,omitempty"`
// On-Demand capacity information.
OnDemand *NamespaceCapacityInfo_CapacityModeOptions_OnDemand `protobuf:"bytes,2,opt,name=on_demand,json=onDemand,proto3" json:"on_demand,omitempty"`
}
func (*NamespaceCapacityInfo_CapacityModeOptions) Descriptor ¶ added in v0.55.0
func (*NamespaceCapacityInfo_CapacityModeOptions) Descriptor() ([]byte, []int)
func (*NamespaceCapacityInfo_CapacityModeOptions) Equal ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_CapacityModeOptions) Equal(that interface{}) bool
func (*NamespaceCapacityInfo_CapacityModeOptions) GetOnDemand ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) GetOnDemand() *NamespaceCapacityInfo_CapacityModeOptions_OnDemand
func (*NamespaceCapacityInfo_CapacityModeOptions) GetProvisioned ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) GetProvisioned() *NamespaceCapacityInfo_CapacityModeOptions_Provisioned
func (*NamespaceCapacityInfo_CapacityModeOptions) GoString ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_CapacityModeOptions) GoString() string
func (*NamespaceCapacityInfo_CapacityModeOptions) Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) Marshal() (dAtA []byte, err error)
func (*NamespaceCapacityInfo_CapacityModeOptions) MarshalTo ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo_CapacityModeOptions) MarshalToSizedBuffer ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo_CapacityModeOptions) ProtoMessage ¶ added in v0.55.0
func (*NamespaceCapacityInfo_CapacityModeOptions) ProtoMessage()
func (*NamespaceCapacityInfo_CapacityModeOptions) Reset ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) Reset()
func (*NamespaceCapacityInfo_CapacityModeOptions) Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) Size() (n int)
func (*NamespaceCapacityInfo_CapacityModeOptions) String ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_CapacityModeOptions) String() string
func (*NamespaceCapacityInfo_CapacityModeOptions) Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) Unmarshal(dAtA []byte) error
func (*NamespaceCapacityInfo_CapacityModeOptions) XXX_DiscardUnknown ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) XXX_DiscardUnknown()
func (*NamespaceCapacityInfo_CapacityModeOptions) XXX_Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NamespaceCapacityInfo_CapacityModeOptions) XXX_Merge ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) XXX_Merge(src proto.Message)
func (*NamespaceCapacityInfo_CapacityModeOptions) XXX_Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) XXX_Size() int
func (*NamespaceCapacityInfo_CapacityModeOptions) XXX_Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions) XXX_Unmarshal(b []byte) error
type NamespaceCapacityInfo_CapacityModeOptions_OnDemand ¶ added in v0.55.0
type NamespaceCapacityInfo_CapacityModeOptions_OnDemand struct {
// The APS limit that would apply to this namespace in on-demand mode.
// See: https://docs.temporal.io/cloud/limits#actions-per-second
ApsLimit float64 `protobuf:"fixed64,1,opt,name=aps_limit,json=apsLimit,proto3" json:"aps_limit,omitempty"`
}
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Descriptor ¶ added in v0.55.0
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Descriptor() ([]byte, []int)
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Equal ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Equal(that interface{}) bool
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) GetApsLimit ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) GetApsLimit() float64
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) GoString ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) GoString() string
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Marshal() (dAtA []byte, err error)
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) MarshalTo ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) MarshalToSizedBuffer ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) ProtoMessage ¶ added in v0.55.0
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) ProtoMessage()
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Reset ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Reset()
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Size() (n int)
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) String ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) String() string
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) Unmarshal(dAtA []byte) error
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_DiscardUnknown ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_DiscardUnknown()
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Merge ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Merge(src proto.Message)
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Size() int
func (*NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_OnDemand) XXX_Unmarshal(b []byte) error
type NamespaceCapacityInfo_CapacityModeOptions_Provisioned ¶ added in v0.55.0
type NamespaceCapacityInfo_CapacityModeOptions_Provisioned struct {
// The valid TRU (Temporal Resource Unit) values that can be set.
// These are the discrete capacity tiers available for selection.
ValidTruValues []float64 `protobuf:"fixed64,1,rep,packed,name=valid_tru_values,json=validTruValues,proto3" json:"valid_tru_values,omitempty"`
// The maximum TRU value that can currently be set for this namespace.
// This may be lower than the highest value in valid_tru_values due to
// inventory constraints.
MaxAvailableTruValue float64 `` /* 127-byte string literal not displayed */
}
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Descriptor ¶ added in v0.55.0
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Descriptor() ([]byte, []int)
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Equal ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Equal(that interface{}) bool
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) GetMaxAvailableTruValue ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) GetMaxAvailableTruValue() float64
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) GetValidTruValues ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) GetValidTruValues() []float64
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) GoString ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) GoString() string
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Marshal() (dAtA []byte, err error)
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) MarshalTo ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) MarshalToSizedBuffer ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) ProtoMessage ¶ added in v0.55.0
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) ProtoMessage()
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Reset ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Reset()
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Size() (n int)
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) String ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) String() string
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) Unmarshal(dAtA []byte) error
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_DiscardUnknown ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_DiscardUnknown()
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Merge ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Merge(src proto.Message)
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Size() int
func (*NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_CapacityModeOptions_Provisioned) XXX_Unmarshal(b []byte) error
type NamespaceCapacityInfo_Stats ¶ added in v0.55.0
type NamespaceCapacityInfo_Stats struct {
// Actions-per-second measurements summarized over the last 7 days.
Aps *NamespaceCapacityInfo_Stats_Summary `protobuf:"bytes,1,opt,name=aps,proto3" json:"aps,omitempty"`
}
func (*NamespaceCapacityInfo_Stats) Descriptor ¶ added in v0.55.0
func (*NamespaceCapacityInfo_Stats) Descriptor() ([]byte, []int)
func (*NamespaceCapacityInfo_Stats) Equal ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_Stats) Equal(that interface{}) bool
func (*NamespaceCapacityInfo_Stats) GetAps ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) GetAps() *NamespaceCapacityInfo_Stats_Summary
func (*NamespaceCapacityInfo_Stats) GoString ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_Stats) GoString() string
func (*NamespaceCapacityInfo_Stats) Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) Marshal() (dAtA []byte, err error)
func (*NamespaceCapacityInfo_Stats) MarshalTo ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo_Stats) MarshalToSizedBuffer ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo_Stats) ProtoMessage ¶ added in v0.55.0
func (*NamespaceCapacityInfo_Stats) ProtoMessage()
func (*NamespaceCapacityInfo_Stats) Reset ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) Reset()
func (*NamespaceCapacityInfo_Stats) Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) Size() (n int)
func (*NamespaceCapacityInfo_Stats) String ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_Stats) String() string
func (*NamespaceCapacityInfo_Stats) Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) Unmarshal(dAtA []byte) error
func (*NamespaceCapacityInfo_Stats) XXX_DiscardUnknown ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) XXX_DiscardUnknown()
func (*NamespaceCapacityInfo_Stats) XXX_Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NamespaceCapacityInfo_Stats) XXX_Merge ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) XXX_Merge(src proto.Message)
func (*NamespaceCapacityInfo_Stats) XXX_Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) XXX_Size() int
func (*NamespaceCapacityInfo_Stats) XXX_Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats) XXX_Unmarshal(b []byte) error
type NamespaceCapacityInfo_Stats_Summary ¶ added in v0.55.0
type NamespaceCapacityInfo_Stats_Summary struct {
Mean float64 `protobuf:"fixed64,1,opt,name=mean,proto3" json:"mean,omitempty"`
P90 float64 `protobuf:"fixed64,2,opt,name=p90,proto3" json:"p90,omitempty"`
P99 float64 `protobuf:"fixed64,3,opt,name=p99,proto3" json:"p99,omitempty"`
}
func (*NamespaceCapacityInfo_Stats_Summary) Descriptor ¶ added in v0.55.0
func (*NamespaceCapacityInfo_Stats_Summary) Descriptor() ([]byte, []int)
func (*NamespaceCapacityInfo_Stats_Summary) Equal ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_Stats_Summary) Equal(that interface{}) bool
func (*NamespaceCapacityInfo_Stats_Summary) GetMean ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) GetMean() float64
func (*NamespaceCapacityInfo_Stats_Summary) GetP90 ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) GetP90() float64
func (*NamespaceCapacityInfo_Stats_Summary) GetP99 ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) GetP99() float64
func (*NamespaceCapacityInfo_Stats_Summary) GoString ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_Stats_Summary) GoString() string
func (*NamespaceCapacityInfo_Stats_Summary) Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) Marshal() (dAtA []byte, err error)
func (*NamespaceCapacityInfo_Stats_Summary) MarshalTo ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo_Stats_Summary) MarshalToSizedBuffer ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamespaceCapacityInfo_Stats_Summary) ProtoMessage ¶ added in v0.55.0
func (*NamespaceCapacityInfo_Stats_Summary) ProtoMessage()
func (*NamespaceCapacityInfo_Stats_Summary) Reset ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) Reset()
func (*NamespaceCapacityInfo_Stats_Summary) Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) Size() (n int)
func (*NamespaceCapacityInfo_Stats_Summary) String ¶ added in v0.55.0
func (this *NamespaceCapacityInfo_Stats_Summary) String() string
func (*NamespaceCapacityInfo_Stats_Summary) Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) Unmarshal(dAtA []byte) error
func (*NamespaceCapacityInfo_Stats_Summary) XXX_DiscardUnknown ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) XXX_DiscardUnknown()
func (*NamespaceCapacityInfo_Stats_Summary) XXX_Marshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NamespaceCapacityInfo_Stats_Summary) XXX_Merge ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) XXX_Merge(src proto.Message)
func (*NamespaceCapacityInfo_Stats_Summary) XXX_Size ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) XXX_Size() int
func (*NamespaceCapacityInfo_Stats_Summary) XXX_Unmarshal ¶ added in v0.55.0
func (m *NamespaceCapacityInfo_Stats_Summary) XXX_Unmarshal(b []byte) error
type NamespaceRegionStatus ¶
type NamespaceRegionStatus struct {
// The current state of the namespace region.
// Possible values: adding, active, passive, removing, failed.
// For any failed state, reach out to Temporal Cloud support for remediation.
// Deprecated: Use state instead.
// temporal:versioning:max_version=v0.3.0
StateDeprecated string `protobuf:"bytes,1,opt,name=state_deprecated,json=stateDeprecated,proto3" json:"state_deprecated,omitempty"` // Deprecated: Do not use.
// The current state of the namespace region.
// temporal:versioning:min_version=v0.3.0
// temporal:enums:replaces=state_deprecated
State NamespaceRegionStatus_State `` /* 129-byte string literal not displayed */
// The id of the async operation that is making changes to where the namespace is available, if any.
AsyncOperationId string `protobuf:"bytes,2,opt,name=async_operation_id,json=asyncOperationId,proto3" json:"async_operation_id,omitempty"`
}
func (*NamespaceRegionStatus) Descriptor ¶
func (*NamespaceRegionStatus) Descriptor() ([]byte, []int)
func (*NamespaceRegionStatus) Equal ¶
func (this *NamespaceRegionStatus) Equal(that interface{}) bool
func (*NamespaceRegionStatus) GetAsyncOperationId ¶
func (m *NamespaceRegionStatus) GetAsyncOperationId() string
func (*NamespaceRegionStatus) GetState ¶
func (m *NamespaceRegionStatus) GetState() NamespaceRegionStatus_State
func (*NamespaceRegionStatus) GetStateDeprecated
deprecated
added in
v0.34.0
func (m *NamespaceRegionStatus) GetStateDeprecated() string
Deprecated: Do not use.
func (*NamespaceRegionStatus) GoString ¶
func (this *NamespaceRegionStatus) GoString() string
func (*NamespaceRegionStatus) Marshal ¶
func (m *NamespaceRegionStatus) Marshal() (dAtA []byte, err error)
func (*NamespaceRegionStatus) MarshalTo ¶
func (m *NamespaceRegionStatus) MarshalTo(dAtA []byte) (int, error)
func (*NamespaceRegionStatus) MarshalToSizedBuffer ¶
func (m *NamespaceRegionStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamespaceRegionStatus) ProtoMessage ¶
func (*NamespaceRegionStatus) ProtoMessage()
func (*NamespaceRegionStatus) Reset ¶
func (m *NamespaceRegionStatus) Reset()
func (*NamespaceRegionStatus) Size ¶
func (m *NamespaceRegionStatus) Size() (n int)
func (*NamespaceRegionStatus) String ¶
func (this *NamespaceRegionStatus) String() string
func (*NamespaceRegionStatus) Unmarshal ¶
func (m *NamespaceRegionStatus) Unmarshal(dAtA []byte) error
func (*NamespaceRegionStatus) XXX_DiscardUnknown ¶
func (m *NamespaceRegionStatus) XXX_DiscardUnknown()
func (*NamespaceRegionStatus) XXX_Marshal ¶
func (m *NamespaceRegionStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NamespaceRegionStatus) XXX_Merge ¶
func (m *NamespaceRegionStatus) XXX_Merge(src proto.Message)
func (*NamespaceRegionStatus) XXX_Size ¶
func (m *NamespaceRegionStatus) XXX_Size() int
func (*NamespaceRegionStatus) XXX_Unmarshal ¶
func (m *NamespaceRegionStatus) XXX_Unmarshal(b []byte) error
type NamespaceRegionStatus_State ¶ added in v0.34.0
type NamespaceRegionStatus_State int32
const ( STATE_UNSPECIFIED NamespaceRegionStatus_State = 0 STATE_ADDING NamespaceRegionStatus_State = 1 STATE_ACTIVE NamespaceRegionStatus_State = 2 STATE_PASSIVE NamespaceRegionStatus_State = 3 STATE_REMOVING NamespaceRegionStatus_State = 4 STATE_FAILED NamespaceRegionStatus_State = 5 )
func (NamespaceRegionStatus_State) EnumDescriptor ¶ added in v0.34.0
func (NamespaceRegionStatus_State) EnumDescriptor() ([]byte, []int)
func (NamespaceRegionStatus_State) String ¶ added in v0.34.0
func (x NamespaceRegionStatus_State) String() string
type NamespaceSpec ¶
type NamespaceSpec struct {
// The name to use for the namespace.
// This will create a namespace that's available at '<name>.<account>.tmprl.cloud:7233'.
// The name is immutable. Once set, it cannot be changed.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The ids of the regions where the namespace should be available.
// The GetRegions API can be used to get the list of valid region ids.
// Specifying more than one region makes the namespace "global", which is currently a preview only feature with restricted access.
// Please reach out to Temporal support for more information on global namespaces.
// When provisioned the global namespace will be active on the first region in the list and passive on the rest.
// Number of supported regions is 2.
// The regions is immutable. Once set, it cannot be changed.
// Example: ["aws-us-west-2"].
// Deprecated: Use replicas field instead.
// temporal:versioning:max_version=development
Regions []string `protobuf:"bytes,2,rep,name=regions,proto3" json:"regions,omitempty"` // Deprecated: Do not use.
// The number of days the workflows data will be retained for.
// Changes to the retention period may impact your storage costs.
// Any changes to the retention period will be applied to all new running workflows.
RetentionDays int32 `protobuf:"varint,3,opt,name=retention_days,json=retentionDays,proto3" json:"retention_days,omitempty"`
// The mTLS auth configuration for the namespace.
// If unspecified, mTLS will be disabled.
MtlsAuth *MtlsAuthSpec `protobuf:"bytes,4,opt,name=mtls_auth,json=mtlsAuth,proto3" json:"mtls_auth,omitempty"`
// The API key auth configuration for the namespace.
// If unspecified, API keys will be disabled.
// temporal:versioning:min_version=v0.2.0
ApiKeyAuth *ApiKeyAuthSpec `protobuf:"bytes,7,opt,name=api_key_auth,json=apiKeyAuth,proto3" json:"api_key_auth,omitempty"`
// The custom search attributes to use for the namespace.
// The name of the attribute is the key and the type is the value.
// Supported attribute types: text, keyword, int, double, bool, datetime, keyword_list.
// NOTE: currently deleting a search attribute is not supported.
// Optional, default is empty.
// Deprecated: Use search_attributes instead.
// temporal:versioning:max_version=v0.3.0
CustomSearchAttributes map[string]string `` // Deprecated: Do not use.
/* 217-byte string literal not displayed */
// The custom search attributes to use for the namespace.
// The name of the attribute is the key and the type is the value.
// Note: currently deleting a search attribute is not supported.
// Optional, default is empty.
// temporal:versioning:min_version=v0.3.0
// temporal:enums:replaces=custom_search_attributes
SearchAttributes map[string]NamespaceSpec_SearchAttributeType `` /* 269-byte string literal not displayed */
// Codec server spec used by UI to decode payloads for all users interacting with this namespace.
// Optional, default is unset.
CodecServer *CodecServerSpec `protobuf:"bytes,6,opt,name=codec_server,json=codecServer,proto3" json:"codec_server,omitempty"`
// The lifecycle configuration for the namespace.
// temporal:versioning:min_version=v0.4.0
Lifecycle *LifecycleSpec `protobuf:"bytes,9,opt,name=lifecycle,proto3" json:"lifecycle,omitempty"`
// The high availability configuration for the namespace.
// temporal:versioning:min_version=v0.4.0
HighAvailability *HighAvailabilitySpec `protobuf:"bytes,10,opt,name=high_availability,json=highAvailability,proto3" json:"high_availability,omitempty"`
// The existing connectivity rule ids for the namespace.
// temporal:versioning:min_version=v0.6.0
ConnectivityRuleIds []string `protobuf:"bytes,11,rep,name=connectivity_rule_ids,json=connectivityRuleIds,proto3" json:"connectivity_rule_ids,omitempty"`
// The capacity configuration for the namespace.
// temporal:versioning:min_version=v0.10.0
CapacitySpec *CapacitySpec `protobuf:"bytes,12,opt,name=capacity_spec,json=capacitySpec,proto3" json:"capacity_spec,omitempty"`
// The replication configuration for the namespace.
// At least one replica must be specified.
// Only one replica can be marked to be the desired active one.
// The status of each replica is available in the Namespace.replicas field.
// Use HighAvailabilitySpec to set the preferred primary replica ID.
// If the preferred primary replica ID is not set, the first replica in this replicas list will be the preferred primary.
// temporal:versioning:min_version=development
// temporal:dev
Replicas []*ReplicaSpec `protobuf:"bytes,13,rep,name=replicas,proto3" json:"replicas,omitempty"`
}
func (*NamespaceSpec) Descriptor ¶
func (*NamespaceSpec) Descriptor() ([]byte, []int)
func (*NamespaceSpec) Equal ¶
func (this *NamespaceSpec) Equal(that interface{}) bool
func (*NamespaceSpec) GetApiKeyAuth ¶
func (m *NamespaceSpec) GetApiKeyAuth() *ApiKeyAuthSpec
func (*NamespaceSpec) GetCapacitySpec ¶ added in v0.44.0
func (m *NamespaceSpec) GetCapacitySpec() *CapacitySpec
func (*NamespaceSpec) GetCodecServer ¶
func (m *NamespaceSpec) GetCodecServer() *CodecServerSpec
func (*NamespaceSpec) GetConnectivityRuleIds ¶ added in v0.41.0
func (m *NamespaceSpec) GetConnectivityRuleIds() []string
func (*NamespaceSpec) GetCustomSearchAttributes
deprecated
func (m *NamespaceSpec) GetCustomSearchAttributes() map[string]string
Deprecated: Do not use.
func (*NamespaceSpec) GetHighAvailability ¶ added in v0.39.0
func (m *NamespaceSpec) GetHighAvailability() *HighAvailabilitySpec
func (*NamespaceSpec) GetLifecycle ¶ added in v0.38.0
func (m *NamespaceSpec) GetLifecycle() *LifecycleSpec
func (*NamespaceSpec) GetMtlsAuth ¶
func (m *NamespaceSpec) GetMtlsAuth() *MtlsAuthSpec
func (*NamespaceSpec) GetName ¶
func (m *NamespaceSpec) GetName() string
func (*NamespaceSpec) GetRegions
deprecated
func (m *NamespaceSpec) GetRegions() []string
Deprecated: Do not use.
func (*NamespaceSpec) GetReplicas ¶ added in v0.55.0
func (m *NamespaceSpec) GetReplicas() []*ReplicaSpec
func (*NamespaceSpec) GetRetentionDays ¶
func (m *NamespaceSpec) GetRetentionDays() int32
func (*NamespaceSpec) GetSearchAttributes ¶ added in v0.34.0
func (m *NamespaceSpec) GetSearchAttributes() map[string]NamespaceSpec_SearchAttributeType
func (*NamespaceSpec) GoString ¶
func (this *NamespaceSpec) GoString() string
func (*NamespaceSpec) Marshal ¶
func (m *NamespaceSpec) Marshal() (dAtA []byte, err error)
func (*NamespaceSpec) MarshalToSizedBuffer ¶
func (m *NamespaceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NamespaceSpec) ProtoMessage ¶
func (*NamespaceSpec) ProtoMessage()
func (*NamespaceSpec) Reset ¶
func (m *NamespaceSpec) Reset()
func (*NamespaceSpec) Size ¶
func (m *NamespaceSpec) Size() (n int)
func (*NamespaceSpec) String ¶
func (this *NamespaceSpec) String() string
func (*NamespaceSpec) Unmarshal ¶
func (m *NamespaceSpec) Unmarshal(dAtA []byte) error
func (*NamespaceSpec) XXX_DiscardUnknown ¶
func (m *NamespaceSpec) XXX_DiscardUnknown()
func (*NamespaceSpec) XXX_Marshal ¶
func (m *NamespaceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NamespaceSpec) XXX_Merge ¶
func (m *NamespaceSpec) XXX_Merge(src proto.Message)
func (*NamespaceSpec) XXX_Size ¶
func (m *NamespaceSpec) XXX_Size() int
func (*NamespaceSpec) XXX_Unmarshal ¶
func (m *NamespaceSpec) XXX_Unmarshal(b []byte) error
type NamespaceSpec_SearchAttributeType ¶ added in v0.34.0
type NamespaceSpec_SearchAttributeType int32
const ( SEARCH_ATTRIBUTE_TYPE_UNSPECIFIED NamespaceSpec_SearchAttributeType = 0 SEARCH_ATTRIBUTE_TYPE_TEXT NamespaceSpec_SearchAttributeType = 1 SEARCH_ATTRIBUTE_TYPE_KEYWORD NamespaceSpec_SearchAttributeType = 2 SEARCH_ATTRIBUTE_TYPE_INT NamespaceSpec_SearchAttributeType = 3 SEARCH_ATTRIBUTE_TYPE_DOUBLE NamespaceSpec_SearchAttributeType = 4 SEARCH_ATTRIBUTE_TYPE_BOOL NamespaceSpec_SearchAttributeType = 5 SEARCH_ATTRIBUTE_TYPE_DATETIME NamespaceSpec_SearchAttributeType = 6 SEARCH_ATTRIBUTE_TYPE_KEYWORD_LIST NamespaceSpec_SearchAttributeType = 7 )
func (NamespaceSpec_SearchAttributeType) EnumDescriptor ¶ added in v0.34.0
func (NamespaceSpec_SearchAttributeType) EnumDescriptor() ([]byte, []int)
func (NamespaceSpec_SearchAttributeType) String ¶ added in v0.34.0
func (x NamespaceSpec_SearchAttributeType) String() string
type PrivateConnectivity ¶
type PrivateConnectivity struct {
// The id of the region where the private connectivity applies.
Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
// The AWS PrivateLink info.
// This will only be set for an aws region.
AwsPrivateLink *AWSPrivateLinkInfo `protobuf:"bytes,2,opt,name=aws_private_link,json=awsPrivateLink,proto3" json:"aws_private_link,omitempty"`
}
func (*PrivateConnectivity) Descriptor ¶
func (*PrivateConnectivity) Descriptor() ([]byte, []int)
func (*PrivateConnectivity) Equal ¶
func (this *PrivateConnectivity) Equal(that interface{}) bool
func (*PrivateConnectivity) GetAwsPrivateLink ¶
func (m *PrivateConnectivity) GetAwsPrivateLink() *AWSPrivateLinkInfo
func (*PrivateConnectivity) GetRegion ¶
func (m *PrivateConnectivity) GetRegion() string
func (*PrivateConnectivity) GoString ¶
func (this *PrivateConnectivity) GoString() string
func (*PrivateConnectivity) Marshal ¶
func (m *PrivateConnectivity) Marshal() (dAtA []byte, err error)
func (*PrivateConnectivity) MarshalTo ¶
func (m *PrivateConnectivity) MarshalTo(dAtA []byte) (int, error)
func (*PrivateConnectivity) MarshalToSizedBuffer ¶
func (m *PrivateConnectivity) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrivateConnectivity) ProtoMessage ¶
func (*PrivateConnectivity) ProtoMessage()
func (*PrivateConnectivity) Reset ¶
func (m *PrivateConnectivity) Reset()
func (*PrivateConnectivity) Size ¶
func (m *PrivateConnectivity) Size() (n int)
func (*PrivateConnectivity) String ¶
func (this *PrivateConnectivity) String() string
func (*PrivateConnectivity) Unmarshal ¶
func (m *PrivateConnectivity) Unmarshal(dAtA []byte) error
func (*PrivateConnectivity) XXX_DiscardUnknown ¶
func (m *PrivateConnectivity) XXX_DiscardUnknown()
func (*PrivateConnectivity) XXX_Marshal ¶
func (m *PrivateConnectivity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrivateConnectivity) XXX_Merge ¶
func (m *PrivateConnectivity) XXX_Merge(src proto.Message)
func (*PrivateConnectivity) XXX_Size ¶
func (m *PrivateConnectivity) XXX_Size() int
func (*PrivateConnectivity) XXX_Unmarshal ¶
func (m *PrivateConnectivity) XXX_Unmarshal(b []byte) error
type Replica ¶ added in v0.55.0
type Replica struct {
// The id of the replica. This is generated by Temporal after a replica is created.
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// Whether this replica is currently the primary one.
IsPrimary bool `protobuf:"varint,2,opt,name=is_primary,json=isPrimary,proto3" json:"is_primary,omitempty"`
// The current state of this replica.
State Replica_ReplicaState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.cloud.namespace.v1.Replica_ReplicaState" json:"state,omitempty"`
// The cloud provider and region of this replica.
Region string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty"`
}
temporal:dev
func (*Replica) Descriptor ¶ added in v0.55.0
func (*Replica) GetIsPrimary ¶ added in v0.55.0
func (*Replica) GetState ¶ added in v0.55.0
func (m *Replica) GetState() Replica_ReplicaState
func (*Replica) MarshalToSizedBuffer ¶ added in v0.55.0
func (*Replica) ProtoMessage ¶ added in v0.55.0
func (*Replica) ProtoMessage()
func (*Replica) XXX_DiscardUnknown ¶ added in v0.55.0
func (m *Replica) XXX_DiscardUnknown()
func (*Replica) XXX_Marshal ¶ added in v0.55.0
func (*Replica) XXX_Unmarshal ¶ added in v0.55.0
type ReplicaSpec ¶ added in v0.55.0
type ReplicaSpec struct {
// The id of the region where the replica should be placed.
// The GetRegions API can be used to get the list of valid region ids.
// All the replicas must adhere to the region's max_in_region_replicas limit and connectable_region_ids.
// Required. Immutable.
// Example: "aws-us-west-2".
Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
}
temporal:dev
func (*ReplicaSpec) Descriptor ¶ added in v0.55.0
func (*ReplicaSpec) Descriptor() ([]byte, []int)
func (*ReplicaSpec) Equal ¶ added in v0.55.0
func (this *ReplicaSpec) Equal(that interface{}) bool
func (*ReplicaSpec) GetRegion ¶ added in v0.55.0
func (m *ReplicaSpec) GetRegion() string
func (*ReplicaSpec) GoString ¶ added in v0.55.0
func (this *ReplicaSpec) GoString() string
func (*ReplicaSpec) Marshal ¶ added in v0.55.0
func (m *ReplicaSpec) Marshal() (dAtA []byte, err error)
func (*ReplicaSpec) MarshalTo ¶ added in v0.55.0
func (m *ReplicaSpec) MarshalTo(dAtA []byte) (int, error)
func (*ReplicaSpec) MarshalToSizedBuffer ¶ added in v0.55.0
func (m *ReplicaSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaSpec) ProtoMessage ¶ added in v0.55.0
func (*ReplicaSpec) ProtoMessage()
func (*ReplicaSpec) Reset ¶ added in v0.55.0
func (m *ReplicaSpec) Reset()
func (*ReplicaSpec) Size ¶ added in v0.55.0
func (m *ReplicaSpec) Size() (n int)
func (*ReplicaSpec) String ¶ added in v0.55.0
func (this *ReplicaSpec) String() string
func (*ReplicaSpec) Unmarshal ¶ added in v0.55.0
func (m *ReplicaSpec) Unmarshal(dAtA []byte) error
func (*ReplicaSpec) XXX_DiscardUnknown ¶ added in v0.55.0
func (m *ReplicaSpec) XXX_DiscardUnknown()
func (*ReplicaSpec) XXX_Marshal ¶ added in v0.55.0
func (m *ReplicaSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicaSpec) XXX_Merge ¶ added in v0.55.0
func (m *ReplicaSpec) XXX_Merge(src proto.Message)
func (*ReplicaSpec) XXX_Size ¶ added in v0.55.0
func (m *ReplicaSpec) XXX_Size() int
func (*ReplicaSpec) XXX_Unmarshal ¶ added in v0.55.0
func (m *ReplicaSpec) XXX_Unmarshal(b []byte) error
type Replica_ReplicaState ¶ added in v0.55.0
type Replica_ReplicaState int32
const ( REPLICA_STATE_UNSPECIFIED Replica_ReplicaState = 0 REPLICA_STATE_ADDING Replica_ReplicaState = 1 REPLICA_STATE_ACTIVE Replica_ReplicaState = 2 REPLICA_STATE_REMOVING Replica_ReplicaState = 3 REPLICA_STATE_FAILED Replica_ReplicaState = 5 )
func (Replica_ReplicaState) EnumDescriptor ¶ added in v0.55.0
func (Replica_ReplicaState) EnumDescriptor() ([]byte, []int)
func (Replica_ReplicaState) String ¶ added in v0.55.0
func (x Replica_ReplicaState) String() string
type ReplicationEstimate ¶ added in v0.51.0
type ReplicationEstimate struct {
// Estimated time remaining in seconds
TimeRemainingSeconds int64 `protobuf:"varint,1,opt,name=time_remaining_seconds,json=timeRemainingSeconds,proto3" json:"time_remaining_seconds,omitempty"`
// Number of workflows already replicated
ReplicatedCount int64 `protobuf:"varint,2,opt,name=replicated_count,json=replicatedCount,proto3" json:"replicated_count,omitempty"`
// Number of workflows remaining to be replicated
RemainingCount int64 `protobuf:"varint,3,opt,name=remaining_count,json=remainingCount,proto3" json:"remaining_count,omitempty"`
// Replication rate (workflows per second)
Rate float64 `protobuf:"fixed64,4,opt,name=rate,proto3" json:"rate,omitempty"`
}
temporal:dev
func (*ReplicationEstimate) Descriptor ¶ added in v0.51.0
func (*ReplicationEstimate) Descriptor() ([]byte, []int)
func (*ReplicationEstimate) Equal ¶ added in v0.51.0
func (this *ReplicationEstimate) Equal(that interface{}) bool
func (*ReplicationEstimate) GetRate ¶ added in v0.51.0
func (m *ReplicationEstimate) GetRate() float64
func (*ReplicationEstimate) GetRemainingCount ¶ added in v0.51.0
func (m *ReplicationEstimate) GetRemainingCount() int64
func (*ReplicationEstimate) GetReplicatedCount ¶ added in v0.51.0
func (m *ReplicationEstimate) GetReplicatedCount() int64
func (*ReplicationEstimate) GetTimeRemainingSeconds ¶ added in v0.51.0
func (m *ReplicationEstimate) GetTimeRemainingSeconds() int64
func (*ReplicationEstimate) GoString ¶ added in v0.51.0
func (this *ReplicationEstimate) GoString() string
func (*ReplicationEstimate) Marshal ¶ added in v0.51.0
func (m *ReplicationEstimate) Marshal() (dAtA []byte, err error)
func (*ReplicationEstimate) MarshalTo ¶ added in v0.51.0
func (m *ReplicationEstimate) MarshalTo(dAtA []byte) (int, error)
func (*ReplicationEstimate) MarshalToSizedBuffer ¶ added in v0.51.0
func (m *ReplicationEstimate) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicationEstimate) ProtoMessage ¶ added in v0.51.0
func (*ReplicationEstimate) ProtoMessage()
func (*ReplicationEstimate) Reset ¶ added in v0.51.0
func (m *ReplicationEstimate) Reset()
func (*ReplicationEstimate) Size ¶ added in v0.51.0
func (m *ReplicationEstimate) Size() (n int)
func (*ReplicationEstimate) String ¶ added in v0.51.0
func (this *ReplicationEstimate) String() string
func (*ReplicationEstimate) Unmarshal ¶ added in v0.51.0
func (m *ReplicationEstimate) Unmarshal(dAtA []byte) error
func (*ReplicationEstimate) XXX_DiscardUnknown ¶ added in v0.51.0
func (m *ReplicationEstimate) XXX_DiscardUnknown()
func (*ReplicationEstimate) XXX_Marshal ¶ added in v0.51.0
func (m *ReplicationEstimate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicationEstimate) XXX_Merge ¶ added in v0.51.0
func (m *ReplicationEstimate) XXX_Merge(src proto.Message)
func (*ReplicationEstimate) XXX_Size ¶ added in v0.51.0
func (m *ReplicationEstimate) XXX_Size() int
func (*ReplicationEstimate) XXX_Unmarshal ¶ added in v0.51.0
func (m *ReplicationEstimate) XXX_Unmarshal(b []byte) error