namespace

Sep 6, 2024

Changes in this version

type MockRegistry

+ func (m *MockRegistry) RefreshNamespaceById(namespaceId ID) (*Namespace, error)

type MockRegistryMockRecorder

+ func (mr *MockRegistryMockRecorder) RefreshNamespaceById(namespaceId interface{}) *gomock.Call

type Namespace

+ func (ns *Namespace) FailoverHistory() []*replication.FailoverStatus

type Registry

+ RefreshNamespaceById func(namespaceId ID) (*Namespace, error)

May 31, 2024

Changes in this version

+ type GetNamespaceOptions struct

+ DisableReadthrough bool

type MockRegistry

+ func (m *MockRegistry) GetNamespaceByIDWithOptions(id ID, opts GetNamespaceOptions) (*Namespace, error)

+ func (m *MockRegistry) GetNamespaceWithOptions(name Name, opts GetNamespaceOptions) (*Namespace, error)

+ func (m *MockRegistry) NexusOutgoingService(namespaceID ID, serviceName string) (*v1.OutgoingServiceSpec, error)

type MockRegistryMockRecorder

+ func (mr *MockRegistryMockRecorder) GetNamespaceByIDWithOptions(id, opts interface{}) *gomock.Call

+ func (mr *MockRegistryMockRecorder) GetNamespaceWithOptions(name, opts interface{}) *gomock.Call

+ func (mr *MockRegistryMockRecorder) NexusOutgoingService(namespaceID, serviceName interface{}) *gomock.Call

type Namespace

+ func (ns *Namespace) NexusOutgoingService(name string) (spec *nexuspb.OutgoingServiceSpec, ok bool)

type Registry

+ GetNamespaceByIDWithOptions func(id ID, opts GetNamespaceOptions) (*Namespace, error)

+ GetNamespaceWithOptions func(name Name, opts GetNamespaceOptions) (*Namespace, error)

+ NexusOutgoingService func(namespaceID ID, serviceName string) (*nexuspb.OutgoingServiceSpec, error)

Mar 22, 2024

Changes in this version

type Namespace

+ func FromAdminClientApiResponse(response *adminservice.GetNamespaceResponse) *Namespace

Feb 29, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 22, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 22, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 2, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 12, 2024 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 7, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 30, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 22, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 3, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 31, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 6, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 5, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type Registry

+ Start func()

+ Stop func()

Aug 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 21, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 8, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 28, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 24, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 14, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 1, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 23, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type MockRegistry

+ func (m *MockRegistry) GetCustomSearchAttributesMapper(name Name) (CustomSearchAttributesMapper, error)

type MockRegistryMockRecorder

+ func (mr *MockRegistryMockRecorder) GetCustomSearchAttributesMapper(name interface{}) *gomock.Call

type Registry

+ GetCustomSearchAttributesMapper func(name Name) (CustomSearchAttributesMapper, error)

Jul 13, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 15, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 17, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 29, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 17, 2023 GO-2024-2689

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ func ConvertClusterReplicationConfigFromProto(input []*replicationpb.ClusterReplicationConfig) []string

+ type ArchivalConfigEvent struct

+ DefaultURI string

+ State enumspb.ArchivalState

+ URI string

+ func (e *ArchivalConfigEvent) Validate() error

+ type ArchivalConfigState struct

+ State enumspb.ArchivalState

+ URI string

+ func NeverEnabledState() *ArchivalConfigState

+ func (s *ArchivalConfigState) GetNextState(e *ArchivalConfigEvent, URIValidationFunc func(URI string) error) (nextState *ArchivalConfigState, changed bool, err error)

type AttrValidatorImpl

+ func NewAttrValidator(clusterMetadata cluster.Metadata) *AttrValidatorImpl

+ func (d *AttrValidatorImpl) ValidateNamespaceConfig(config *persistencespb.NamespaceConfig) error

+ func (d *AttrValidatorImpl) ValidateNamespaceReplicationConfigForGlobalNamespace(replicationConfig *persistencespb.NamespaceReplicationConfig) error

+ func (d *AttrValidatorImpl) ValidateNamespaceReplicationConfigForLocalNamespace(replicationConfig *persistencespb.NamespaceReplicationConfig) error

+ type CustomSearchAttributesMapper struct

+ func (m *CustomSearchAttributesMapper) FieldToAliasMap() map[string]string

+ func (m *CustomSearchAttributesMapper) GetAlias(fieldName string, namespace string) (string, error)

+ func (m *CustomSearchAttributesMapper) GetFieldName(alias string, namespace string) (string, error)

type Namespace

+ func (ns *Namespace) CustomSearchAttributesMapper() CustomSearchAttributesMapper

+ func (ns *Namespace) IsOnCluster(clusterName string) bool

Jan 13, 2023 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 1, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type MockRegistry

+ func (m *MockRegistry) GetPingChecks() []common.PingCheck

type MockRegistryMockRecorder

+ func (mr *MockRegistryMockRecorder) GetPingChecks() *gomock.Call

Nov 15, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 31, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 18, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 10, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 16, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 14, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 30, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 16, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 17, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 2, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 17, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type MockRegistry

+ func (m *MockRegistry) RegisterStateChangeCallback(key any, cb StateChangeCallbackFn)

+ func (m *MockRegistry) UnregisterStateChangeCallback(key any)

type MockRegistryMockRecorder

+ func (mr *MockRegistryMockRecorder) RegisterStateChangeCallback(key, cb interface{}) *gomock.Call

+ func (mr *MockRegistryMockRecorder) UnregisterStateChangeCallback(key interface{}) *gomock.Call

type Registry

+ RegisterStateChangeCallback func(key any, cb StateChangeCallbackFn)

+ UnregisterStateChangeCallback func(key any)

+ type StateChangeCallbackFn func(ns *Namespace, deletedFromDb bool)

Jul 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 5, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

type Namespace

+ func (ns *Namespace) GetCustomData(key string) string

Apr 19, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 4, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 1, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 9, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ type PretendAsLocalNamespace struct

+ func NewPretendAsLocalNamespace(localClusterName string) PretendAsLocalNamespace

Mar 4, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 11, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 21, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 18, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 10, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ const EmptyID

+ const EmptyName

+ var ErrInvalidNamespaceStateUpdate = serviceerror.NewInvalidArgument("invalid namespace state update")

+ var RegistryLifetimeHooksModule = fx.Options(fx.Invoke(RegistryLifetimeHooks))

+ var RegistryModule = fx.Options(fx.Provide(NewRegistry), fx.Invoke(RegistryLifetimeHooks))

+ func RegistryLifetimeHooks(lc fx.Lifecycle, registry Registry)

+ type ID string

+ func NewID() ID

+ func (id ID) IsEmpty() bool

+ func (id ID) String() string

+ type Name string

+ func (n Name) IsEmpty() bool

+ func (n Name) String() string

type Namespace

+ func (ns *Namespace) ReplicationState() enumspb.ReplicationState

+ func (ns *Namespace) State() enumspb.NamespaceState

Feb 10, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 12, 2022 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 4, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ const CacheRefreshFailureRetryInterval

+ const CacheRefreshInterval

+ const CacheRefreshPageSize

+ const SampleRateKey

+ const SampleRetentionKey

+ type BadBinaryError struct

+ func (e BadBinaryError) Checksum() string

+ func (e BadBinaryError) Created() time.Time

+ func (e BadBinaryError) Error() string

+ func (e BadBinaryError) Operator() string

+ func (e BadBinaryError) Reason() string

+ type CallbackFn func(oldNamespaces []*Namespace, newNamespaces []*Namespace)

+ type Clock interface

+ Now func() time.Time

+ type MockClock struct

+ func NewMockClock(ctrl *gomock.Controller) *MockClock

+ func (m *MockClock) EXPECT() *MockClockMockRecorder

+ func (m *MockClock) Now() time.Time

+ type MockClockMockRecorder struct

+ func (mr *MockClockMockRecorder) Now() *gomock.Call

+ type MockPersistence struct

+ func NewMockPersistence(ctrl *gomock.Controller) *MockPersistence

+ func (m *MockPersistence) EXPECT() *MockPersistenceMockRecorder

+ func (m *MockPersistence) GetMetadata() (*persistence.GetMetadataResponse, error)

+ func (m *MockPersistence) GetNamespace(request *persistence.GetNamespaceRequest) (*persistence.GetNamespaceResponse, error)

+ func (m *MockPersistence) ListNamespaces(arg0 *persistence.ListNamespacesRequest) (*persistence.ListNamespacesResponse, error)

+ type MockPersistenceMockRecorder struct

+ func (mr *MockPersistenceMockRecorder) GetMetadata() *gomock.Call

+ func (mr *MockPersistenceMockRecorder) GetNamespace(request interface{}) *gomock.Call

+ func (mr *MockPersistenceMockRecorder) ListNamespaces(arg0 interface{}) *gomock.Call

+ type MockRegistry struct

+ func NewMockRegistry(ctrl *gomock.Controller) *MockRegistry

+ func (m *MockRegistry) EXPECT() *MockRegistryMockRecorder

+ func (m *MockRegistry) GetCacheSize() (int64, int64)

+ func (m *MockRegistry) GetNamespace(name string) (*Namespace, error)

+ func (m *MockRegistry) GetNamespaceByID(id string) (*Namespace, error)

+ func (m *MockRegistry) GetNamespaceID(name string) (string, error)

+ func (m *MockRegistry) GetNamespaceName(id string) (string, error)

+ func (m *MockRegistry) Refresh()

+ func (m *MockRegistry) RegisterNamespaceChangeCallback(shard int32, initialNotificationVersion int64, ...)

+ func (m *MockRegistry) Start()

+ func (m *MockRegistry) Stop()

+ func (m *MockRegistry) UnregisterNamespaceChangeCallback(shard int32)

+ type MockRegistryMockRecorder struct

+ func (mr *MockRegistryMockRecorder) GetCacheSize() *gomock.Call

+ func (mr *MockRegistryMockRecorder) GetNamespace(name interface{}) *gomock.Call

+ func (mr *MockRegistryMockRecorder) GetNamespaceByID(id interface{}) *gomock.Call

+ func (mr *MockRegistryMockRecorder) GetNamespaceID(name interface{}) *gomock.Call

+ func (mr *MockRegistryMockRecorder) GetNamespaceName(id interface{}) *gomock.Call

+ func (mr *MockRegistryMockRecorder) Refresh() *gomock.Call

+ func (mr *MockRegistryMockRecorder) RegisterNamespaceChangeCallback(shard, initialNotificationVersion, prepareCallback, callback interface{}) *gomock.Call

+ func (mr *MockRegistryMockRecorder) Start() *gomock.Call

+ func (mr *MockRegistryMockRecorder) Stop() *gomock.Call

+ func (mr *MockRegistryMockRecorder) UnregisterNamespaceChangeCallback(shard interface{}) *gomock.Call

+ type Mutation interface

+ func WithActiveCluster(name string) Mutation

+ func WithBadBinary(chksum string) Mutation

+ func WithData(key, value string) Mutation

+ func WithGlobalFlag(b bool) Mutation

+ func WithID(id string) Mutation

+ func WithRetention(dur *time.Duration) Mutation

+ type Namespace struct

+ func FromPersistentState(record *persistence.GetNamespaceResponse) *Namespace

+ func NewGlobalNamespaceForTest(info *persistencespb.NamespaceInfo, config *persistencespb.NamespaceConfig, ...) *Namespace

+ func NewLocalNamespaceForTest(info *persistencespb.NamespaceInfo, config *persistencespb.NamespaceConfig, ...) *Namespace

+ func NewNamespaceForTest(info *persistencespb.NamespaceInfo, config *persistencespb.NamespaceConfig, ...) *Namespace

+ func (ns *Namespace) ActiveClusterName() string

+ func (ns *Namespace) ActiveInCluster(clusterName string) bool

+ func (ns *Namespace) Clone(ms ...Mutation) *Namespace

+ func (ns *Namespace) ClusterNames() []string

+ func (ns *Namespace) ConfigVersion() int64

+ func (ns *Namespace) FailoverNotificationVersion() int64

+ func (ns *Namespace) FailoverVersion() int64

+ func (ns *Namespace) HistoryArchivalState() ArchivalState

+ func (ns *Namespace) ID() string

+ func (ns *Namespace) IsGlobalNamespace() bool

+ func (ns *Namespace) IsSampledForLongerRetention(workflowID string) bool

+ func (ns *Namespace) IsSampledForLongerRetentionEnabled(string) bool

+ func (ns *Namespace) Name() string

+ func (ns *Namespace) NotificationVersion() int64

+ func (ns *Namespace) ReplicationPolicy() ReplicationPolicy

+ func (ns *Namespace) Retention(workflowID string) time.Duration

+ func (ns *Namespace) VerifyBinaryChecksum(cksum string) error

+ func (ns *Namespace) VisibilityArchivalState() ArchivalState

+ type Namespaces []*Namespace

+ func (t Namespaces) Len() int

+ func (t Namespaces) Less(i, j int) bool

+ func (t Namespaces) Swap(i, j int)

+ type Persistence interface

+ GetMetadata func() (*persistence.GetMetadataResponse, error)

+ GetNamespace func(request *persistence.GetNamespaceRequest) (*persistence.GetNamespaceResponse, error)

+ ListNamespaces func(*persistence.ListNamespacesRequest) (*persistence.ListNamespacesResponse, error)

+ type PrepareCallbackFn func()

+ type Registry interface

+ GetCacheSize func() (sizeOfCacheByName int64, sizeOfCacheByID int64)

+ GetNamespace func(name string) (*Namespace, error)

+ GetNamespaceByID func(id string) (*Namespace, error)

+ GetNamespaceID func(name string) (string, error)

+ GetNamespaceName func(id string) (string, error)

+ Refresh func()

+ RegisterNamespaceChangeCallback func(shard int32, initialNotificationVersion int64, ...)

+ UnregisterNamespaceChangeCallback func(shard int32)

+ func NewRegistry(persistence Persistence, enableGlobalNamespaces bool, ...) Registry

+ type ReplicationPolicy int

+ const ReplicationPolicyMultiCluster

+ const ReplicationPolicyOneCluster

Oct 29, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 4, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 16, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 31, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Aug 6, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 20, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ const MinRetentionGlobal

+ const MinRetentionLocal

Jun 24, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 8, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 2, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jun 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

May 5, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 27, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 29, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 16, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 15, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 30, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 26, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Apr 7, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Mar 23, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 13, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 26, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 22, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 22, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jan 25, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 10, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Dec 9, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 16, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 11, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Nov 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 27, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 20, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Oct 14, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Feb 18, 2021 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 30, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 28, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 22, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Sep 17, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 31, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Jul 15, 2020 GO-2023-1879 +1 more

  GO-2023-1879: Temporal Server vulnerable to Incorrect Authorization and Insecure Default Initialization of Resource in go.temporal.io/server

  GO-2024-2689: Temporal Server Denial of Service in go.temporal.io/server

Changes in this version

+ const MaxBadBinaries

+ const MinRetentionDays

+ var ErrEmptyNamespaceReplicationTask = serviceerror.NewInvalidArgument("empty namespace replication task")

+ var ErrInvalidNamespaceConfig = serviceerror.NewInvalidArgument("invalid namespace config attribute")

+ var ErrInvalidNamespaceConfigVersion = serviceerror.NewInvalidArgument("invalid namespace config version attribute")

+ var ErrInvalidNamespaceFailoverVersion = serviceerror.NewInvalidArgument("invalid namespace failover version attribute")

+ var ErrInvalidNamespaceID = serviceerror.NewInvalidArgument("invalid namespace ID attribute")

+ var ErrInvalidNamespaceInfo = serviceerror.NewInvalidArgument("invalid namespace info attribute")

+ var ErrInvalidNamespaceOperation = serviceerror.NewInvalidArgument("invalid namespace operation attribute")

+ var ErrInvalidNamespaceReplicationConfig = serviceerror.NewInvalidArgument("invalid namespace replication config attribute")

+ var ErrInvalidNamespaceState = serviceerror.NewInvalidArgument("invalid namespace state attribute")

+ var ErrNameUUIDCollision = serviceerror.NewInvalidArgument("namespace replication encounter name / UUID collision")

+ type ArchivalEvent struct

+ URI string

+ type ArchivalState struct

+ State enumspb.ArchivalState

+ URI string

+ type AttrValidatorImpl struct

+ type DLQMessageHandler interface

+ Merge func(lastMessageID int64, pageSize int, pageToken []byte) ([]byte, error)

+ Purge func(lastMessageID int64) error

+ Read func(lastMessageID int64, pageSize int, pageToken []byte) ([]*replicationspb.ReplicationTask, []byte, error)

+ func NewDLQMessageHandler(replicationHandler ReplicationTaskExecutor, ...) DLQMessageHandler

+ type Handler interface

+ DeprecateNamespace func(ctx context.Context, ...) (*workflowservice.DeprecateNamespaceResponse, error)

+ DescribeNamespace func(ctx context.Context, describeRequest *workflowservice.DescribeNamespaceRequest) (*workflowservice.DescribeNamespaceResponse, error)

+ ListNamespaces func(ctx context.Context, listRequest *workflowservice.ListNamespacesRequest) (*workflowservice.ListNamespacesResponse, error)

+ RegisterNamespace func(ctx context.Context, registerRequest *workflowservice.RegisterNamespaceRequest) (*workflowservice.RegisterNamespaceResponse, error)

+ UpdateNamespace func(ctx context.Context, updateRequest *workflowservice.UpdateNamespaceRequest) (*workflowservice.UpdateNamespaceResponse, error)

+ type HandlerImpl struct

+ func NewHandler(minRetentionDays int, ...) *HandlerImpl

+ func (d *HandlerImpl) DeprecateNamespace(ctx context.Context, ...) (*workflowservice.DeprecateNamespaceResponse, error)

+ func (d *HandlerImpl) DescribeNamespace(ctx context.Context, describeRequest *workflowservice.DescribeNamespaceRequest) (*workflowservice.DescribeNamespaceResponse, error)

+ func (d *HandlerImpl) ListNamespaces(ctx context.Context, listRequest *workflowservice.ListNamespacesRequest) (*workflowservice.ListNamespacesResponse, error)

+ func (d *HandlerImpl) RegisterNamespace(_ context.Context, registerRequest *workflowservice.RegisterNamespaceRequest) (*workflowservice.RegisterNamespaceResponse, error)

+ func (d *HandlerImpl) UpdateNamespace(ctx context.Context, updateRequest *workflowservice.UpdateNamespaceRequest) (*workflowservice.UpdateNamespaceResponse, error)

+ type MockDLQMessageHandler struct

+ func NewMockDLQMessageHandler(ctrl *gomock.Controller) *MockDLQMessageHandler

+ func (m *MockDLQMessageHandler) EXPECT() *MockDLQMessageHandlerMockRecorder

+ func (m *MockDLQMessageHandler) Merge(lastMessageID int64, pageSize int, pageToken []byte) ([]byte, error)

+ func (m *MockDLQMessageHandler) Purge(lastMessageID int64) error

+ func (m *MockDLQMessageHandler) Read(lastMessageID int64, pageSize int, pageToken []byte) ([]*repication.ReplicationTask, []byte, error)

+ type MockDLQMessageHandlerMockRecorder struct

+ func (mr *MockDLQMessageHandlerMockRecorder) Merge(lastMessageID, pageSize, pageToken interface{}) *gomock.Call

+ func (mr *MockDLQMessageHandlerMockRecorder) Purge(lastMessageID interface{}) *gomock.Call

+ func (mr *MockDLQMessageHandlerMockRecorder) Read(lastMessageID, pageSize, pageToken interface{}) *gomock.Call

+ type MockHandler struct

+ func NewMockHandler(ctrl *gomock.Controller) *MockHandler

+ func (m *MockHandler) DeprecateNamespace(ctx context.Context, ...) (*workflowservice.DeprecateNamespaceResponse, error)

+ func (m *MockHandler) DescribeNamespace(ctx context.Context, describeRequest *workflowservice.DescribeNamespaceRequest) (*workflowservice.DescribeNamespaceResponse, error)

+ func (m *MockHandler) EXPECT() *MockHandlerMockRecorder

+ func (m *MockHandler) ListNamespaces(ctx context.Context, listRequest *workflowservice.ListNamespacesRequest) (*workflowservice.ListNamespacesResponse, error)

+ func (m *MockHandler) RegisterNamespace(ctx context.Context, registerRequest *workflowservice.RegisterNamespaceRequest) (*workflowservice.RegisterNamespaceResponse, error)

+ func (m *MockHandler) UpdateNamespace(ctx context.Context, updateRequest *workflowservice.UpdateNamespaceRequest) (*workflowservice.UpdateNamespaceResponse, error)

+ type MockHandlerMockRecorder struct

+ func (mr *MockHandlerMockRecorder) DeprecateNamespace(ctx, deprecateRequest interface{}) *gomock.Call

+ func (mr *MockHandlerMockRecorder) DescribeNamespace(ctx, describeRequest interface{}) *gomock.Call

+ func (mr *MockHandlerMockRecorder) ListNamespaces(ctx, listRequest interface{}) *gomock.Call

+ func (mr *MockHandlerMockRecorder) RegisterNamespace(ctx, registerRequest interface{}) *gomock.Call

+ func (mr *MockHandlerMockRecorder) UpdateNamespace(ctx, updateRequest interface{}) *gomock.Call

+ type MockReplicationTaskExecutor struct

+ func NewMockReplicationTaskExecutor(ctrl *gomock.Controller) *MockReplicationTaskExecutor

+ func (m *MockReplicationTaskExecutor) EXPECT() *MockReplicationTaskExecutorMockRecorder

+ func (m *MockReplicationTaskExecutor) Execute(task *repication.NamespaceTaskAttributes) error

+ type MockReplicationTaskExecutorMockRecorder struct

+ func (mr *MockReplicationTaskExecutorMockRecorder) Execute(task interface{}) *gomock.Call

+ type ReplicationTaskExecutor interface

+ Execute func(task *replicationspb.NamespaceTaskAttributes) error

+ func NewReplicationTaskExecutor(metadataManagerV2 persistence.MetadataManager, logger log.Logger) ReplicationTaskExecutor

+ type Replicator interface

+ HandleTransmissionTask func(namespaceOperation enumsspb.NamespaceOperation, ...) error

+ func NewNamespaceReplicator(replicationMessageSink messaging.Producer, logger log.Logger) Replicator