nexustest

Documentation

Index

• type NamespaceService
  • func (n *NamespaceService) GetNamespace(ctx context.Context, request *persistence.GetNamespaceRequest) (*persistence.GetNamespaceResponse, error)
  • func (n *NamespaceService) HandleTransmissionTask(ctx context.Context, namespaceOperation enumsspb.NamespaceOperation, ...) error
  • func (n *NamespaceService) UpdateNamespace(ctx context.Context, request *persistence.UpdateNamespaceRequest) error

Types

type NamespaceService

type NamespaceService struct {
	OnGetNamespace    func(ctx context.Context, request *persistence.GetNamespaceRequest) (*persistence.GetNamespaceResponse, error)
	OnUpdateNamespace func(ctx context.Context, request *persistence.UpdateNamespaceRequest) error
}

NamespaceService is a test implementation of nexus.NamespaceService and [namespace.Replicator] that allows you to easily override its methods. It will panic if any of its methods are called without their respective On* fields being set.

func (*NamespaceService) GetNamespace

func (n *NamespaceService) GetNamespace(ctx context.Context, request *persistence.GetNamespaceRequest) (*persistence.GetNamespaceResponse, error)

func (*NamespaceService) HandleTransmissionTask

func (n *NamespaceService) HandleTransmissionTask(
	ctx context.Context,
	namespaceOperation enumsspb.NamespaceOperation,
	info *persistencespb.NamespaceInfo,
	config *persistencespb.NamespaceConfig,
	replicationConfig *persistencespb.NamespaceReplicationConfig,
	nexusOutgoingServices []*persistencespb.NexusOutgoingService,
	replicationClusterListUpdated bool,
	configVersion int64,
	failoverVersion int64,
	isGlobalNamespace bool,
	failoverHistory []*persistencespb.FailoverStatus,
) error

func (*NamespaceService) UpdateNamespace

func (n *NamespaceService) UpdateNamespace(ctx context.Context, request *persistence.UpdateNamespaceRequest) error