common

package
v0.26.0 Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var FailoverStatus_name = map[int32]string{
	0: "Unspecified",
	1: "Succeeded",
	2: "Failed",
}
View Source 
var FailoverStatus_value = map[string]int32{
	"Unspecified": 0,
	"Succeeded":   1,
	"Failed":      2,
}
View Source 
var FailoverType_name = map[int32]string{
	0: "Unspecified",
	1: "Graceful",
	2: "Force",
}
View Source 
var FailoverType_value = map[string]int32{
	"Unspecified": 0,
	"Graceful":    1,
	"Force":       2,
}
View Source 
var RegionID_CloudProvider_name = map[int32]string{
	0: "CloudProviderUnspecified",
	1: "CloudProviderAws",
	2: "CloudProviderGcp",
}
View Source 
var RegionID_CloudProvider_value = map[string]int32{
	"CloudProviderUnspecified": 0,
	"CloudProviderAws":         1,
	"CloudProviderGcp":         2,
}
View Source 
var ReplicaMode_name = map[int32]string{
	0: "Unspecified",
	1: "Active",
	2: "Passive",
}
View Source 
var ReplicaMode_value = map[string]int32{
	"Unspecified": 0,
	"Active":      1,
	"Passive":     2,
}
View Source 
var ReplicaState_name = map[int32]string{
	0: "Unspecified",
	1: "Activating",
	2: "ActivationFailed",
	3: "Activated",
	4: "Deactivating",
	5: "DeactivationFailed",
	6: "Deactivated",
	7: "FailoverInProgress",
	8: "FailoverFailed",
}
View Source 
var ReplicaState_value = map[string]int32{
	"Unspecified":        0,
	"Activating":         1,
	"ActivationFailed":   2,
	"Activated":          3,
	"Deactivating":       4,
	"DeactivationFailed": 5,
	"Deactivated":        6,
	"FailoverInProgress": 7,
	"FailoverFailed":     8,
}

Functions

This section is empty.

Types

type FailoverStatus added in v0.20.0 

type FailoverStatus int32
const (
	FAILOVER_STATUS_UNSPECIFIED FailoverStatus = 0
	FAILOVER_STATUS_SUCCEEDED   FailoverStatus = 1
	FAILOVER_STATUS_FAILED      FailoverStatus = 2
)

func (FailoverStatus) EnumDescriptor added in v0.20.0 

func (FailoverStatus) EnumDescriptor() ([]byte, []int)

func (FailoverStatus) String added in v0.20.0 

func (x FailoverStatus) String() string

type FailoverType added in v0.20.0 

type FailoverType int32
const (
	FAILOVER_TYPE_UNSPECIFIED FailoverType = 0
	FAILOVER_TYPE_GRACEFUL    FailoverType = 1
	FAILOVER_TYPE_FORCE       FailoverType = 2
)

func (FailoverType) EnumDescriptor added in v0.20.0 

func (FailoverType) EnumDescriptor() ([]byte, []int)

func (FailoverType) String added in v0.20.0 

func (x FailoverType) String() string

type Region 

type Region struct {
	// E.g., aws, gcp, azure.
	CloudProvider string `protobuf:"bytes,1,opt,name=cloud_provider,json=cloudProvider,proto3" json:"cloud_provider,omitempty"` // Deprecated: Do not use.
	// Cloud-specific region name. E.g., us-west-2 for AWS and europe-west1 for GCP.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Deprecated: Do not use.
	// The flag indicates if the region supports global namespace.
	SupportGlobalNamespace bool `` // Deprecated: Do not use.
	/* 130-byte string literal not displayed */
	// The allow list of connection between the current region with a target region.
	ConnectableRegions []*RegionID `protobuf:"bytes,4,rep,name=connectable_regions,json=connectableRegions,proto3" json:"connectable_regions,omitempty"`
	// Region id including cloud provider and region name.
	RegionId *RegionID `protobuf:"bytes,5,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

(-- api-linter: core::0123::resource-annotation=disabled --)

func (*Region) Descriptor 

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

func (*Region) Equal 

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

func (*Region) GetCloudProvider 

func (m *Region) GetCloudProvider() string

func (*Region) GetConnectableRegions 

func (m *Region) GetConnectableRegions() []*RegionID

func (*Region) GetName 

func (m *Region) GetName() string

func (*Region) GetRegionId added in v0.26.0 

func (m *Region) GetRegionId() *RegionID

func (*Region) GetSupportGlobalNamespace deprecated 

func (m *Region) GetSupportGlobalNamespace() bool

Deprecated: Do not use.

func (*Region) GoString 

func (this *Region) GoString() string

func (*Region) Marshal 

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

func (*Region) MarshalTo 

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

func (*Region) MarshalToSizedBuffer 

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

func (*Region) ProtoMessage 

func (*Region) ProtoMessage()

func (*Region) Reset 

func (m *Region) Reset()

func (*Region) Size 

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

func (*Region) String 

func (this *Region) String() string

func (*Region) Unmarshal 

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

func (*Region) XXX_DiscardUnknown 

func (m *Region) XXX_DiscardUnknown()

func (*Region) XXX_Marshal 

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

func (*Region) XXX_Merge 

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

func (*Region) XXX_Size 

func (m *Region) XXX_Size() int

func (*Region) XXX_Unmarshal 

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

type RegionID 

type RegionID struct {
	// E.g., aws, gcp, azure.
	CloudProvider string `protobuf:"bytes,1,opt,name=cloud_provider,json=cloudProvider,proto3" json:"cloud_provider,omitempty"` // Deprecated: Do not use.
	// Cloud-specific region name. E.g., us-west-2 for AWS and europe-west1 for GCP.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Enum of the provider, we may use this to replace the string field. E.g. aws, gcp, azure
	// temporal:enums:replaces=cloud_provider
	Provider RegionID_CloudProvider `protobuf:"varint,3,opt,name=provider,proto3,enum=api.common.v1.RegionID_CloudProvider" json:"provider,omitempty"`
}

func (*RegionID) Descriptor 

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

func (*RegionID) Equal 

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

func (*RegionID) GetCloudProvider deprecated 

func (m *RegionID) GetCloudProvider() string

Deprecated: Do not use.

func (*RegionID) GetName 

func (m *RegionID) GetName() string

func (*RegionID) GetProvider added in v0.26.0 

func (m *RegionID) GetProvider() RegionID_CloudProvider

func (*RegionID) GoString 

func (this *RegionID) GoString() string

func (*RegionID) Marshal 

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

func (*RegionID) MarshalTo 

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

func (*RegionID) MarshalToSizedBuffer 

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

func (*RegionID) ProtoMessage 

func (*RegionID) ProtoMessage()

func (*RegionID) Reset 

func (m *RegionID) Reset()

func (*RegionID) Size 

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

func (*RegionID) String 

func (this *RegionID) String() string

func (*RegionID) Unmarshal 

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

func (*RegionID) XXX_DiscardUnknown 

func (m *RegionID) XXX_DiscardUnknown()

func (*RegionID) XXX_Marshal 

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

func (*RegionID) XXX_Merge 

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

func (*RegionID) XXX_Size 

func (m *RegionID) XXX_Size() int

func (*RegionID) XXX_Unmarshal 

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

type RegionID_CloudProvider added in v0.26.0 

type RegionID_CloudProvider int32
const (
	CLOUD_PROVIDER_UNSPECIFIED RegionID_CloudProvider = 0
	CLOUD_PROVIDER_AWS         RegionID_CloudProvider = 1
	CLOUD_PROVIDER_GCP         RegionID_CloudProvider = 2
)

func (RegionID_CloudProvider) EnumDescriptor added in v0.26.0 

func (RegionID_CloudProvider) EnumDescriptor() ([]byte, []int)

func (RegionID_CloudProvider) String added in v0.26.0 

func (x RegionID_CloudProvider) String() string

type ReplicaMode added in v0.26.0 

type ReplicaMode int32
const (
	REPLICA_MODE_UNSPECIFIED ReplicaMode = 0
	REPLICA_MODE_ACTIVE      ReplicaMode = 1
	REPLICA_MODE_PASSIVE     ReplicaMode = 2
)

func (ReplicaMode) EnumDescriptor added in v0.26.0 

func (ReplicaMode) EnumDescriptor() ([]byte, []int)

func (ReplicaMode) String added in v0.26.0 

func (x ReplicaMode) String() string

type ReplicaState added in v0.20.0 

type ReplicaState int32
const (
	REPLICA_STATE_UNSPECIFIED          ReplicaState = 0
	REPLICA_STATE_ACTIVATING           ReplicaState = 1
	REPLICA_STATE_ACTIVATION_FAILED    ReplicaState = 2
	REPLICA_STATE_ACTIVATED            ReplicaState = 3
	REPLICA_STATE_DEACTIVATING         ReplicaState = 4
	REPLICA_STATE_DEACTIVATION_FAILED  ReplicaState = 5
	REPLICA_STATE_DEACTIVATED          ReplicaState = 6
	REPLICA_STATE_FAILOVER_IN_PROGRESS ReplicaState = 7
	REPLICA_STATE_FAILOVER_FAILED      ReplicaState = 8
)

func (ReplicaState) EnumDescriptor added in v0.20.0 

func (ReplicaState) EnumDescriptor() ([]byte, []int)

func (ReplicaState) String added in v0.20.0 

func (x ReplicaState) String() string

type ReplicaStatus added in v0.20.0 

type ReplicaStatus struct {
	// The replica located region
	Region *RegionID `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// The workflow number to be copied to the replica.
	ToBeReplicatedWorkflowCount int64 `` /* 149-byte string literal not displayed */
	// The workflow number that already replicated to the replica.
	ReplicatedWorkflowCount int64 `` /* 133-byte string literal not displayed */
	// The estimated time when this replica is ready.
	EstimatedCompletionDuration *types.Duration `` /* 144-byte string literal not displayed */
	// The current status of a replica.
	State ReplicaState `protobuf:"varint,5,opt,name=state,proto3,enum=api.common.v1.ReplicaState" json:"state,omitempty"`
	// Whether the replica is active or passive.
	Mode ReplicaMode `protobuf:"varint,6,opt,name=mode,proto3,enum=api.common.v1.ReplicaMode" json:"mode,omitempty"`
}

func (*ReplicaStatus) Descriptor added in v0.20.0 

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

func (*ReplicaStatus) Equal added in v0.20.0 

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

func (*ReplicaStatus) GetEstimatedCompletionDuration added in v0.20.0 

func (m *ReplicaStatus) GetEstimatedCompletionDuration() *types.Duration

func (*ReplicaStatus) GetMode added in v0.26.0 

func (m *ReplicaStatus) GetMode() ReplicaMode

func (*ReplicaStatus) GetRegion added in v0.20.0 

func (m *ReplicaStatus) GetRegion() *RegionID

func (*ReplicaStatus) GetReplicatedWorkflowCount added in v0.20.0 

func (m *ReplicaStatus) GetReplicatedWorkflowCount() int64

func (*ReplicaStatus) GetState added in v0.20.0 

func (m *ReplicaStatus) GetState() ReplicaState

func (*ReplicaStatus) GetToBeReplicatedWorkflowCount added in v0.20.0 

func (m *ReplicaStatus) GetToBeReplicatedWorkflowCount() int64

func (*ReplicaStatus) GoString added in v0.20.0 

func (this *ReplicaStatus) GoString() string

func (*ReplicaStatus) Marshal added in v0.20.0 

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

func (*ReplicaStatus) MarshalTo added in v0.20.0 

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

func (*ReplicaStatus) MarshalToSizedBuffer added in v0.20.0 

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

func (*ReplicaStatus) ProtoMessage added in v0.20.0 

func (*ReplicaStatus) ProtoMessage()

func (*ReplicaStatus) Reset added in v0.20.0 

func (m *ReplicaStatus) Reset()

func (*ReplicaStatus) Size added in v0.20.0 

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

func (*ReplicaStatus) String added in v0.20.0 

func (this *ReplicaStatus) String() string

func (*ReplicaStatus) Unmarshal added in v0.20.0 

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

func (*ReplicaStatus) XXX_DiscardUnknown added in v0.20.0 

func (m *ReplicaStatus) XXX_DiscardUnknown()

func (*ReplicaStatus) XXX_Marshal added in v0.20.0 

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

func (*ReplicaStatus) XXX_Merge added in v0.20.0 

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

func (*ReplicaStatus) XXX_Size added in v0.20.0 

func (m *ReplicaStatus) XXX_Size() int

func (*ReplicaStatus) XXX_Unmarshal added in v0.20.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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