database

package
v0.0.0-...-b34249d Latest Latest
Warning

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

 Go to latest Published: Mar 18, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Overview

Package database is a generated GoMock package.

Package database is a generated GoMock package.

Package database is a generated GoMock package.

Package database is a generated GoMock package.

Package database is a generated GoMock package.

Package database is a generated GoMock package.

Package database is a generated GoMock package.

Package database is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var ErrAmbiguousResult = errors.New("ambiguous result")

ErrAmbiguousResult occurs when a database query intended to yield a single item unexpectedly yields multiple items.

View Source 
var ErrItemNotFound = errors.New("item not found")

ErrItemNotFound occurs when the requested item ID was not found, such as in a DBTransactionResult.

View Source 
var ErrWrongPartition = errors.New("wrong partition key for transaction")

ErrWrongPartition occurs in a DBTransaction create step when the document has a partition key that differs from the transaction's partition key.

Functions

func CosmosGenericToInternal 

func CosmosGenericToInternal[InternalAPIType any](cosmosObj *GenericDocument[InternalAPIType]) (*InternalAPIType, error)

func CosmosToInternal 

func CosmosToInternal[InternalAPIType, CosmosAPIType any](obj *CosmosAPIType) (*InternalAPIType, error)

func CosmosToInternalCluster 

func CosmosToInternalCluster(cosmosObj *HCPCluster) (*api.HCPOpenShiftCluster, error)

func CosmosToInternalExternalAuth 

func CosmosToInternalExternalAuth(cosmosObj *ExternalAuth) (*api.HCPOpenShiftClusterExternalAuth, error)

func CosmosToInternalNodePool 

func CosmosToInternalNodePool(cosmosObj *NodePool) (*api.HCPOpenShiftClusterNodePool, error)

func Delay 

func Delay(ctx context.Context, delay time.Duration) error

Copied from azcore/internal/shared/shared.go

func InternalToCosmos 

func InternalToCosmos[InternalAPIType, CosmosAPIType any](obj *InternalAPIType) (*CosmosAPIType, error)

func IsResponseError 

func IsResponseError(err error, statusCode int) bool

func NewClusterResourceID 

func NewClusterResourceID(subscriptionID, resourceGroupName, clusterName string) *azcorearm.ResourceID

func NewCosmosDatabaseClient 

func NewCosmosDatabaseClient(url string, dbName string, clientOptions azcore.ClientOptions) (*azcosmos.DatabaseClient, error)

NewCosmosDatabaseClient instantiates a generic Cosmos database client.

func NewCosmosResourceCRUD 

func NewCosmosResourceCRUD[InternalAPIType, CosmosAPIType any](
	containerClient *azcosmos.ContainerClient, parentResourceID *azcorearm.ResourceID, resourceType azcorearm.ResourceType) *nestedCosmosResourceCRUD[InternalAPIType, CosmosAPIType]

func NewNodePoolResourceID 

func NewNodePoolResourceID(subscriptionID, resourceGroupName, clusterName, nodePoolName string) *azcorearm.ResourceID

func NewNotFoundError 

func NewNotFoundError() *azcore.ResponseError

func NewOperation 

func NewOperation(
	request OperationRequest,
	externalID *azcorearm.ResourceID,
	internalID ocm.InternalID,
	location, tenantID, clientID, notificationURI string,
	correlationData *arm.CorrelationData,
) *api.Operation

func NewPartitionKey 

func NewPartitionKey(subscriptionID string) azcosmos.PartitionKey

NewPartitionKey creates a partition key from an Azure subscription ID.

func OldResourceIDToCosmosID 

func OldResourceIDToCosmosID(resourceID *azcorearm.ResourceID) (string, error)

func PatchOperationDocument 

func PatchOperationDocument(ctx context.Context, dbClient DBClient, oldOperation *api.Operation, newOperationStatus arm.ProvisioningState, newOperationError *arm.CloudErrorBody, postAsyncNotificationFn PostAsyncNotificationFunc) error

PatchOperationDocument patches the status and error fields of an OperationDocument.

func ToStatus 

func ToStatus(doc *api.Operation) *arm.Operation

ToStatus converts an OperationDocument to the ARM operation status format.

func UpdateOperationStatus 

func UpdateOperationStatus(ctx context.Context, cosmosClient DBClient, existingOperation *api.Operation, newOperationStatus arm.ProvisioningState, newOperationError *arm.CloudErrorBody, postAsyncNotificationFn PostAsyncNotificationFunc) error

UpdateOperationStatus updates Cosmos DB to reflect an updated resource status.

Types

type BaseDocument 

type BaseDocument struct {
	ID string `json:"id,omitempty"`

	// https://learn.microsoft.com/en-us/azure/cosmos-db/nosql/time-to-live
	TimeToLive int `json:"ttl,omitempty"`

	// System-defined properties generated by Cosmos DB
	CosmosResourceID  string      `json:"_rid,omitempty"`
	CosmosSelf        string      `json:"_self,omitempty"`
	CosmosETag        azcore.ETag `json:"_etag,omitempty"`
	CosmosAttachments string      `json:"_attachments,omitempty"`
	CosmosTimestamp   int         `json:"_ts,omitempty"`
}

BaseDocument includes fields common to all container items.

type BillingDocument 

type BillingDocument struct {
	BaseDocument

	// The cluster creation time represents the time when the cluster was provisioned successfully
	CreationTime time.Time `json:"creationTime,omitempty"`
	// The cluster deletion time
	DeletionTime *time.Time `json:"deletionTime,omitempty"`

	// The location of the HCP cluster
	Location string `json:"location,omitempty"`
	// The tenant ID of the HCP cluster
	TenantID string `json:"tenantId,omitempty"`
	// The subscription ID of the HCP cluster (also the partition key)
	SubscriptionID string `json:"subscriptionId,omitempty"`
	// The HCP cluster ARM resource ID
	ResourceID *azcorearm.ResourceID `json:"resourceId,omitempty"`
	// The ARM resource ID of the managed resource group of the HCP cluster
	ManagedResourceGroup string `json:"managedResourceGroup,omitempty"`
}

BillingDocument records timestamps of Hosted Control Plane OpenShift cluster creation and deletion for the purpose of customer billing.

func NewBillingDocument 

func NewBillingDocument(resourceID *azcorearm.ResourceID) *BillingDocument

type BillingDocumentPatchOperations 

type BillingDocumentPatchOperations struct {
	azcosmos.PatchOperations
}

BillingDocumentPatchOperations represents a patch request for a BillingDocument.

func (*BillingDocumentPatchOperations) SetDeletionTime 

func (p *BillingDocumentPatchOperations) SetDeletionTime(deletionTime time.Time)

SetDeletionTime appends a set operation for the DeletionTime field.

type ClusterInternalState 

type ClusterInternalState struct {
	InternalAPI api.HCPOpenShiftCluster `json:"internalAPI"`
}

type ControllerContainer 

type ControllerContainer interface {
	// TODO controllers are a concept that is at this scope and at lower scopes and sometimes you want to query all like it
	// TODO they look a lot like operations, though we can model them as a one-off to start.
	Controllers(hcpClusterID string) ResourceCRUD[api.Controller]
}

type CosmosDBTransactionDetails 

type CosmosDBTransactionDetails struct {
	PartitionKey string                           `json:"partitionKey"`
	Steps        []CosmosDBTransactionStepDetails `json:"steps"`
}

type CosmosDBTransactionStep 

type CosmosDBTransactionStep func(b *azcosmos.TransactionalBatch) (string, error)

type CosmosDBTransactionStepDetails 

type CosmosDBTransactionStepDetails struct {
	ActionType string      `json:"actionType"`
	CosmosID   string      `json:"cosmosID"`
	ResourceID string      `json:"resourceID"`
	GoType     string      `json:"goType"`
	Etag       azcore.ETag `json:"etag"`
}

type DBClient 

type DBClient interface {
	// GetLockClient returns a LockClient, or nil if the DBClient does not support a LockClient.
	GetLockClient() LockClientInterface

	// NewTransaction initiates a new transactional batch for the given partition key.
	NewTransaction(pk string) DBTransaction

	// CreateBillingDoc creates a new document in the "Billing" container.
	CreateBillingDoc(ctx context.Context, doc *BillingDocument) error

	// PatchBillingDoc patches a document in the "Billing" container by applying a sequence
	// of patch operations. The patch operations may include a precondition which, if not
	// satisfied, will cause the function to return an azcore.ResponseError with a StatusCode
	// of http.StatusPreconditionFailed.
	PatchBillingDoc(ctx context.Context, resourceID *azcorearm.ResourceID, ops BillingDocumentPatchOperations) error

	// UntypedCRUD provides access documents in the subscription
	UntypedCRUD(parentResourceID azcorearm.ResourceID) (UntypedResourceCRUD, error)

	// HCPClusters retrieves a CRUD interface for managing HCPCluster resources and their nested resources.
	HCPClusters(subscriptionID, resourceGroupName string) HCPClusterCRUD

	// Operations retrieves a CRUD interface for managing operations.  Remember that operations are not directly accessible
	// to end users via ARM.  They must also survive the thing they are deleting, so they live under a subscription directly.
	Operations(subscriptionID string) OperationCRUD

	Subscriptions() SubscriptionCRUD

	ServiceProviderClusters(subscriptionID, resourceGroupName, clusterName string) ServiceProviderClusterCRUD

	// GlobalListers returns interfaces for listing all resources of a particular
	// type across all partitions, intended for feeding SharedInformers.
	GlobalListers() GlobalListers

	ServiceProviderNodePools(subscriptionID, resourceGroupName, clusterName, nodePoolName string) ServiceProviderNodePoolCRUD

	ManagementClusterContents(subscriptionID, resourceGroupName, clusterName string) ManagementClusterContentCRUD
}

DBClient provides a customized interface to the Cosmos DB containers used by the ARO-HCP resource provider.

func NewDBClient 

func NewDBClient(ctx context.Context, database *azcosmos.DatabaseClient) (DBClient, error)

NewDBClient instantiates a DBClient from a Cosmos DatabaseClient instance targeting the Frontends async database.

type DBClientIterator 

type DBClientIterator[T any] interface {
	Items(ctx context.Context) DBClientIteratorItem[T]
	GetContinuationToken() string
	GetError() error
}

type DBClientIteratorItem 

type DBClientIteratorItem[T any] iter.Seq2[string, *T]

type DBClientListActiveOperationDocsOptions 

type DBClientListActiveOperationDocsOptions struct {
	// Request matches the type of asynchronous operation requested
	Request *OperationRequest
	// ExternalID matches (case-insensitively) the Azure resource ID of the cluster or node pool
	ExternalID *azcorearm.ResourceID
	// IncludeNestedResources includes nested resources under ExternalID
	IncludeNestedResources bool
}

DBClientListActiveOperationDocsOptions allows for limiting the results of DBClient.ListActiveOperationDocs.

type DBClientListResourceDocsOptions 

type DBClientListResourceDocsOptions struct {
	// ResourceType matches (case-insensitively) the Azure resource type. If unspecified,
	// DBClient.ListResourceDocs will match resource documents for any resource type.
	ResourceType *azcorearm.ResourceType

	// PageSizeHint can limit the number of items returned at once. A negative value will cause
	// the returned iterator to yield all matching documents (same as leaving the option nil).
	// A positive value will cause the returned iterator to include a continuation token if
	// additional items are available.
	PageSizeHint *int32

	// ContinuationToken can be supplied when limiting the number of items returned at once
	// through PageSizeHint.
	ContinuationToken *string
}

DBClientListResourceDocsOptions allows for limiting the results of DBClient.ListResourceDocs.

type DBTransaction 

type DBTransaction interface {
	// AddStep adds a transaction function to the list to perform
	AddStep(CosmosDBTransactionStepDetails, CosmosDBTransactionStep)

	// GetPartitionKey returns the transaction's partition key.
	GetPartitionKey() string

	// OnSuccess adds a function to call if the transaction executes successfully.
	OnSuccess(callback DBTransactionCallback)

	// Execute submits the prepared transaction.
	Execute(ctx context.Context, o *azcosmos.TransactionalBatchOptions) (DBTransactionResult, error)
}

type DBTransactionCallback 

type DBTransactionCallback func(DBTransactionResult)

type DBTransactionResult 

type DBTransactionResult interface {
	// GetItem returns the internal API representation for the cosmosUID.
	// That is consistent with other returns from our database layer.
	// The Item is only available if the transaction was
	// executed with the EnableContentResponseOnWrite option set, or
	// the document was requested with DBTransaction.ReadDoc.
	GetItem(cosmosUID string) (any, error)
}

type ExternalAuth 

type ExternalAuth struct {
	TypedDocument `json:",inline"`

	ExternalAuthProperties `json:"properties"`
}

func InternalToCosmosExternalAuth 

func InternalToCosmosExternalAuth(internalObj *api.HCPOpenShiftClusterExternalAuth) (*ExternalAuth, error)

func (*ExternalAuth) GetTypedDocument 

func (o *ExternalAuth) GetTypedDocument() *TypedDocument

type ExternalAuthInternalState 

type ExternalAuthInternalState struct {
	InternalAPI api.HCPOpenShiftClusterExternalAuth `json:"internalAPI"`
}

type ExternalAuthProperties 

type ExternalAuthProperties struct {
	*ResourceDocument `json:",inline"`

	// when we switch to inlining the internalObj, this will be in the right spot.  We add it now so that we can switch our
	// queries to select on cosmosMetata.ResourceID instead of resourceId
	CosmosMetadata api.CosmosMetadata `json:"cosmosMetadata"`

	// IntermediateResourceDoc exists so that we can stop inlining the resource document so that we can directly
	// embed the InternalAPIType which has colliding serialization fields.
	IntermediateResourceDoc *ResourceDocument `json:"intermediateResourceDoc"`

	// TODO we may need look-aside data that we want to store in the same place.  Build the nesting to allow it
	InternalState ExternalAuthInternalState `json:"internalState"`
}

type ExternalAuthsCRUD 

type ExternalAuthsCRUD interface {
	ResourceCRUD[api.HCPOpenShiftClusterExternalAuth]
	ControllerContainer
}

type GenericDocument 

type GenericDocument[InternalAPIType any] struct {
	TypedDocument `json:",inline"`

	Content InternalAPIType `json:"properties"`
}

pointer of InternalAPIType needs to be arm.CosmosMetadataAccessor

func InternalToCosmosGeneric 

func InternalToCosmosGeneric[InternalAPIType any](internalObj *InternalAPIType) (*GenericDocument[InternalAPIType], error)

type GlobalLister 

type GlobalLister[T any] interface {
	List(ctx context.Context, options *DBClientListResourceDocsOptions) (DBClientIterator[T], error)
}

GlobalLister lists all resources of a particular type across all partitions.

type GlobalListers 

type GlobalListers interface {
	Subscriptions() GlobalLister[arm.Subscription]
	Clusters() GlobalLister[api.HCPOpenShiftCluster]
	NodePools() GlobalLister[api.HCPOpenShiftClusterNodePool]
	ExternalAuths() GlobalLister[api.HCPOpenShiftClusterExternalAuth]
	ServiceProviderClusters() GlobalLister[api.ServiceProviderCluster]
	ServiceProviderNodePools() GlobalLister[api.ServiceProviderNodePool]
	Controllers() GlobalLister[api.Controller]
	ManagementClusterContents() GlobalLister[api.ManagementClusterContent]
	Operations() GlobalLister[api.Operation]
	ActiveOperations() GlobalLister[api.Operation]
}

GlobalListers provides access to global listers for each resource type. These are intended to feed SharedInformers via ListerWatchers.

func NewCosmosGlobalListers 

func NewCosmosGlobalListers(resources *azcosmos.ContainerClient) GlobalListers

type HCPCluster 

type HCPCluster struct {
	TypedDocument `json:",inline"`

	HCPClusterProperties `json:"properties"`
}

func InternalToCosmosCluster 

func InternalToCosmosCluster(internalObj *api.HCPOpenShiftCluster) (*HCPCluster, error)

func (*HCPCluster) GetTypedDocument 

func (o *HCPCluster) GetTypedDocument() *TypedDocument

type HCPClusterCRUD 

type HCPClusterCRUD interface {
	ResourceCRUD[api.HCPOpenShiftCluster]
	ControllerContainer

	ExternalAuth(hcpClusterID string) ExternalAuthsCRUD
	NodePools(hcpClusterID string) NodePoolsCRUD
}

func NewHCPClusterCRUD 

func NewHCPClusterCRUD(containerClient *azcosmos.ContainerClient, subscriptionID, resourceGroupName string) HCPClusterCRUD

type HCPClusterProperties 

type HCPClusterProperties struct {
	*ResourceDocument `json:",inline"`

	// when we switch to inlining the internalObj, this will be in the right spot.  We add it now so that we can switch our
	// queries to select on cosmosMetata.ResourceID instead of resourceId
	CosmosMetadata api.CosmosMetadata `json:"cosmosMetadata"`

	// IntermediateResourceDoc exists so that we can stop inlining the resource document so that we can directly
	// embed the InternalAPIType which has colliding serialization fields.
	IntermediateResourceDoc *ResourceDocument `json:"intermediateResourceDoc"`

	// TODO we may need look-aside data that we want to store in the same place.  Build the nesting to allow it
	InternalState ClusterInternalState `json:"internalState"`
}

type LockClient 

type LockClient struct {
	// contains filtered or unexported fields
}

func NewLockClient 

func NewLockClient(ctx context.Context, containerClient *azcosmos.ContainerClient) (*LockClient, error)

NewLockClient creates a LockClient around a ContainerClient. It attempts to read container properties to extract a default TTL. If this fails or if the container does not define a default TTL, the function returns an error.

func (*LockClient) AcquireLock 

func (c *LockClient) AcquireLock(ctx context.Context, id string, timeout *time.Duration) (*azcosmos.ItemResponse, error)

AcquireLock persistently tries to acquire a lock for the given ID. If a timeout is provided, the function will cease after the timeout duration and return a context.DeadlineExceeded error.

func (*LockClient) GetDefaultTimeToLive 

func (c *LockClient) GetDefaultTimeToLive() time.Duration

GetDefaultTimeToLive returns the default time-to-live value of the container as a time.Duration.

func (*LockClient) HoldLock 

func (c *LockClient) HoldLock(ctx context.Context, item *azcosmos.ItemResponse) (cancelCtx context.Context, stop StopHoldLock)

HoldLock tries to hold an acquired lock by renewing it periodically from a goroutine until the returned stop function is called. The function also returns a new context which is cancelled if the lock is lost or some other error occurs. The stop function terminates the goroutine and returns the current lock, or nil if the lock was lost.

func (*LockClient) ReleaseLock 

func (c *LockClient) ReleaseLock(ctx context.Context, item *azcosmos.ItemResponse) error

ReleaseLock attempts to release an acquired lock. Errors should be logged but not treated as fatal, since the container item's TTL value guarantees that it will be released eventually.

func (*LockClient) RenewLock 

func (c *LockClient) RenewLock(ctx context.Context, item *azcosmos.ItemResponse) (*azcosmos.ItemResponse, error)

RenewLock attempts to renew an acquired lock. If successful it returns a new lock. If the lock was somehow lost, it returns a nil azcosmos.ItemResponse and no error.

func (*LockClient) SetName 

func (c *LockClient) SetName(name string)

SetName overrides how a lock item identifies the owner. This is for informational purposes only. LockClient uses the hostname by default.

func (*LockClient) SetRetryAfterHeader 

func (c *LockClient) SetRetryAfterHeader(header http.Header)

SetRetryAfterHeader sets a "Retry-After" header to the default TTL value.

func (*LockClient) TryAcquireLock 

func (c *LockClient) TryAcquireLock(ctx context.Context, id string) (*azcosmos.ItemResponse, error)

TryAcquireLock tries once to acquire a lock for the given ID. If the lock is already taken, it returns a nil azcosmos.ItemResponse and no error.

type LockClientInterface 

type LockClientInterface interface {
	GetDefaultTimeToLive() time.Duration
	SetRetryAfterHeader(header http.Header)
	AcquireLock(ctx context.Context, id string, timeout *time.Duration) (*azcosmos.ItemResponse, error)
	TryAcquireLock(ctx context.Context, id string) (*azcosmos.ItemResponse, error)
	HoldLock(ctx context.Context, item *azcosmos.ItemResponse) (context.Context, StopHoldLock)
	RenewLock(ctx context.Context, item *azcosmos.ItemResponse) (*azcosmos.ItemResponse, error)
	ReleaseLock(ctx context.Context, item *azcosmos.ItemResponse) error
}

type ManagementClusterContentCRUD 

type ManagementClusterContentCRUD interface {
	ResourceCRUD[api.ManagementClusterContent]
}

type MockControllerContainer 

type MockControllerContainer struct {
	// contains filtered or unexported fields
}

MockControllerContainer is a mock of ControllerContainer interface.

func NewMockControllerContainer 

func NewMockControllerContainer(ctrl *gomock.Controller) *MockControllerContainer

NewMockControllerContainer creates a new mock instance.

func (*MockControllerContainer) Controllers 

func (m *MockControllerContainer) Controllers(hcpClusterID string) ResourceCRUD[api.Controller]

Controllers mocks base method.

func (*MockControllerContainer) EXPECT 

func (m *MockControllerContainer) EXPECT() *MockControllerContainerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockControllerContainerControllersCall 

type MockControllerContainerControllersCall struct {
	*gomock.Call
}

MockControllerContainerControllersCall wrap *gomock.Call

func (*MockControllerContainerControllersCall) Do 

func (c *MockControllerContainerControllersCall) Do(f func(string) ResourceCRUD[api.Controller]) *MockControllerContainerControllersCall

Do rewrite *gomock.Call.Do

func (*MockControllerContainerControllersCall) DoAndReturn 

func (c *MockControllerContainerControllersCall) DoAndReturn(f func(string) ResourceCRUD[api.Controller]) *MockControllerContainerControllersCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockControllerContainerControllersCall) Return 

func (c *MockControllerContainerControllersCall) Return(arg0 ResourceCRUD[api.Controller]) *MockControllerContainerControllersCall

Return rewrite *gomock.Call.Return

type MockControllerContainerMockRecorder 

type MockControllerContainerMockRecorder struct {
	// contains filtered or unexported fields
}

MockControllerContainerMockRecorder is the mock recorder for MockControllerContainer.

func (*MockControllerContainerMockRecorder) Controllers 

func (mr *MockControllerContainerMockRecorder) Controllers(hcpClusterID any) *MockControllerContainerControllersCall

Controllers indicates an expected call of Controllers.

type MockDBClient 

type MockDBClient struct {
	// contains filtered or unexported fields
}

MockDBClient is a mock of DBClient interface.

func NewMockDBClient 

func NewMockDBClient(ctrl *gomock.Controller) *MockDBClient

NewMockDBClient creates a new mock instance.

func (*MockDBClient) CreateBillingDoc 

func (m *MockDBClient) CreateBillingDoc(ctx context.Context, doc *BillingDocument) error

CreateBillingDoc mocks base method.

func (*MockDBClient) EXPECT 

func (m *MockDBClient) EXPECT() *MockDBClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDBClient) GetLockClient 

func (m *MockDBClient) GetLockClient() LockClientInterface

GetLockClient mocks base method.

func (*MockDBClient) GlobalListers 

func (m *MockDBClient) GlobalListers() GlobalListers

GlobalListers mocks base method.

func (*MockDBClient) HCPClusters 

func (m *MockDBClient) HCPClusters(subscriptionID, resourceGroupName string) HCPClusterCRUD

HCPClusters mocks base method.

func (*MockDBClient) ManagementClusterContents 

func (m *MockDBClient) ManagementClusterContents(subscriptionID, resourceGroupName, clusterName string) ManagementClusterContentCRUD

ManagementClusterContents mocks base method.

func (*MockDBClient) NewTransaction 

func (m *MockDBClient) NewTransaction(pk string) DBTransaction

NewTransaction mocks base method.

func (*MockDBClient) Operations 

func (m *MockDBClient) Operations(subscriptionID string) OperationCRUD

Operations mocks base method.

func (*MockDBClient) PatchBillingDoc 

func (m *MockDBClient) PatchBillingDoc(ctx context.Context, resourceID *arm.ResourceID, ops BillingDocumentPatchOperations) error

PatchBillingDoc mocks base method.

func (*MockDBClient) ServiceProviderClusters 

func (m *MockDBClient) ServiceProviderClusters(subscriptionID, resourceGroupName, clusterName string) ServiceProviderClusterCRUD

ServiceProviderClusters mocks base method.

func (*MockDBClient) ServiceProviderNodePools 

func (m *MockDBClient) ServiceProviderNodePools(subscriptionID, resourceGroupName, clusterName, nodePoolName string) ServiceProviderNodePoolCRUD

ServiceProviderNodePools mocks base method.

func (*MockDBClient) Subscriptions 

func (m *MockDBClient) Subscriptions() SubscriptionCRUD

Subscriptions mocks base method.

func (*MockDBClient) UntypedCRUD 

func (m *MockDBClient) UntypedCRUD(parentResourceID arm.ResourceID) (UntypedResourceCRUD, error)

UntypedCRUD mocks base method.

type MockDBClientCreateBillingDocCall 

type MockDBClientCreateBillingDocCall struct {
	*gomock.Call
}

MockDBClientCreateBillingDocCall wrap *gomock.Call

func (*MockDBClientCreateBillingDocCall) Do 

func (c *MockDBClientCreateBillingDocCall) Do(f func(context.Context, *BillingDocument) error) *MockDBClientCreateBillingDocCall

Do rewrite *gomock.Call.Do

func (*MockDBClientCreateBillingDocCall) DoAndReturn 

func (c *MockDBClientCreateBillingDocCall) DoAndReturn(f func(context.Context, *BillingDocument) error) *MockDBClientCreateBillingDocCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientCreateBillingDocCall) Return 

func (c *MockDBClientCreateBillingDocCall) Return(arg0 error) *MockDBClientCreateBillingDocCall

Return rewrite *gomock.Call.Return

type MockDBClientGetLockClientCall 

type MockDBClientGetLockClientCall struct {
	*gomock.Call
}

MockDBClientGetLockClientCall wrap *gomock.Call

func (*MockDBClientGetLockClientCall) Do 

func (c *MockDBClientGetLockClientCall) Do(f func() LockClientInterface) *MockDBClientGetLockClientCall

Do rewrite *gomock.Call.Do

func (*MockDBClientGetLockClientCall) DoAndReturn 

func (c *MockDBClientGetLockClientCall) DoAndReturn(f func() LockClientInterface) *MockDBClientGetLockClientCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientGetLockClientCall) Return 

func (c *MockDBClientGetLockClientCall) Return(arg0 LockClientInterface) *MockDBClientGetLockClientCall

Return rewrite *gomock.Call.Return

type MockDBClientGlobalListersCall 

type MockDBClientGlobalListersCall struct {
	*gomock.Call
}

MockDBClientGlobalListersCall wrap *gomock.Call

func (*MockDBClientGlobalListersCall) Do 

func (c *MockDBClientGlobalListersCall) Do(f func() GlobalListers) *MockDBClientGlobalListersCall

Do rewrite *gomock.Call.Do

func (*MockDBClientGlobalListersCall) DoAndReturn 

func (c *MockDBClientGlobalListersCall) DoAndReturn(f func() GlobalListers) *MockDBClientGlobalListersCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientGlobalListersCall) Return 

func (c *MockDBClientGlobalListersCall) Return(arg0 GlobalListers) *MockDBClientGlobalListersCall

Return rewrite *gomock.Call.Return

type MockDBClientHCPClustersCall 

type MockDBClientHCPClustersCall struct {
	*gomock.Call
}

MockDBClientHCPClustersCall wrap *gomock.Call

func (*MockDBClientHCPClustersCall) Do 

func (c *MockDBClientHCPClustersCall) Do(f func(string, string) HCPClusterCRUD) *MockDBClientHCPClustersCall

Do rewrite *gomock.Call.Do

func (*MockDBClientHCPClustersCall) DoAndReturn 

func (c *MockDBClientHCPClustersCall) DoAndReturn(f func(string, string) HCPClusterCRUD) *MockDBClientHCPClustersCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientHCPClustersCall) Return 

func (c *MockDBClientHCPClustersCall) Return(arg0 HCPClusterCRUD) *MockDBClientHCPClustersCall

Return rewrite *gomock.Call.Return

type MockDBClientIterator 

type MockDBClientIterator[T any] struct {
	// contains filtered or unexported fields
}

MockDBClientIterator is a mock of DBClientIterator interface.

func NewMockDBClientIterator 

func NewMockDBClientIterator[T any](ctrl *gomock.Controller) *MockDBClientIterator[T]

NewMockDBClientIterator creates a new mock instance.

func (*MockDBClientIterator[T]) EXPECT 

func (m *MockDBClientIterator[T]) EXPECT() *MockDBClientIteratorMockRecorder[T]

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDBClientIterator[T]) GetContinuationToken 

func (m *MockDBClientIterator[T]) GetContinuationToken() string

GetContinuationToken mocks base method.

func (*MockDBClientIterator[T]) GetError 

func (m *MockDBClientIterator[T]) GetError() error

GetError mocks base method.

func (*MockDBClientIterator[T]) Items 

func (m *MockDBClientIterator[T]) Items(ctx context.Context) DBClientIteratorItem[T]

Items mocks base method.

type MockDBClientIteratorGetContinuationTokenCall 

type MockDBClientIteratorGetContinuationTokenCall[T any] struct {
	*gomock.Call
}

MockDBClientIteratorGetContinuationTokenCall wrap *gomock.Call

func (*MockDBClientIteratorGetContinuationTokenCall[T]) Do 

func (c *MockDBClientIteratorGetContinuationTokenCall[T]) Do(f func() string) *MockDBClientIteratorGetContinuationTokenCall[T]

Do rewrite *gomock.Call.Do

func (*MockDBClientIteratorGetContinuationTokenCall[T]) DoAndReturn 

func (c *MockDBClientIteratorGetContinuationTokenCall[T]) DoAndReturn(f func() string) *MockDBClientIteratorGetContinuationTokenCall[T]

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientIteratorGetContinuationTokenCall[T]) Return 

func (c *MockDBClientIteratorGetContinuationTokenCall[T]) Return(arg0 string) *MockDBClientIteratorGetContinuationTokenCall[T]

Return rewrite *gomock.Call.Return

type MockDBClientIteratorGetErrorCall 

type MockDBClientIteratorGetErrorCall[T any] struct {
	*gomock.Call
}

MockDBClientIteratorGetErrorCall wrap *gomock.Call

func (*MockDBClientIteratorGetErrorCall[T]) Do 

func (c *MockDBClientIteratorGetErrorCall[T]) Do(f func() error) *MockDBClientIteratorGetErrorCall[T]

Do rewrite *gomock.Call.Do

func (*MockDBClientIteratorGetErrorCall[T]) DoAndReturn 

func (c *MockDBClientIteratorGetErrorCall[T]) DoAndReturn(f func() error) *MockDBClientIteratorGetErrorCall[T]

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientIteratorGetErrorCall[T]) Return 

func (c *MockDBClientIteratorGetErrorCall[T]) Return(arg0 error) *MockDBClientIteratorGetErrorCall[T]

Return rewrite *gomock.Call.Return

type MockDBClientIteratorItemsCall 

type MockDBClientIteratorItemsCall[T any] struct {
	*gomock.Call
}

MockDBClientIteratorItemsCall wrap *gomock.Call

func (*MockDBClientIteratorItemsCall[T]) Do 

func (c *MockDBClientIteratorItemsCall[T]) Do(f func(context.Context) DBClientIteratorItem[T]) *MockDBClientIteratorItemsCall[T]

Do rewrite *gomock.Call.Do

func (*MockDBClientIteratorItemsCall[T]) DoAndReturn 

func (c *MockDBClientIteratorItemsCall[T]) DoAndReturn(f func(context.Context) DBClientIteratorItem[T]) *MockDBClientIteratorItemsCall[T]

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientIteratorItemsCall[T]) Return 

func (c *MockDBClientIteratorItemsCall[T]) Return(arg0 DBClientIteratorItem[T]) *MockDBClientIteratorItemsCall[T]

Return rewrite *gomock.Call.Return

type MockDBClientIteratorMockRecorder 

type MockDBClientIteratorMockRecorder[T any] struct {
	// contains filtered or unexported fields
}

MockDBClientIteratorMockRecorder is the mock recorder for MockDBClientIterator.

func (*MockDBClientIteratorMockRecorder[T]) GetContinuationToken 

func (mr *MockDBClientIteratorMockRecorder[T]) GetContinuationToken() *MockDBClientIteratorGetContinuationTokenCall[T]

GetContinuationToken indicates an expected call of GetContinuationToken.

func (*MockDBClientIteratorMockRecorder[T]) GetError 

func (mr *MockDBClientIteratorMockRecorder[T]) GetError() *MockDBClientIteratorGetErrorCall[T]

GetError indicates an expected call of GetError.

func (*MockDBClientIteratorMockRecorder[T]) Items 

func (mr *MockDBClientIteratorMockRecorder[T]) Items(ctx any) *MockDBClientIteratorItemsCall[T]

Items indicates an expected call of Items.

type MockDBClientManagementClusterContentsCall 

type MockDBClientManagementClusterContentsCall struct {
	*gomock.Call
}

MockDBClientManagementClusterContentsCall wrap *gomock.Call

func (*MockDBClientManagementClusterContentsCall) Do 

func (c *MockDBClientManagementClusterContentsCall) Do(f func(string, string, string) ManagementClusterContentCRUD) *MockDBClientManagementClusterContentsCall

Do rewrite *gomock.Call.Do

func (*MockDBClientManagementClusterContentsCall) DoAndReturn 

func (c *MockDBClientManagementClusterContentsCall) DoAndReturn(f func(string, string, string) ManagementClusterContentCRUD) *MockDBClientManagementClusterContentsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientManagementClusterContentsCall) Return 

func (c *MockDBClientManagementClusterContentsCall) Return(arg0 ManagementClusterContentCRUD) *MockDBClientManagementClusterContentsCall

Return rewrite *gomock.Call.Return

type MockDBClientMockRecorder 

type MockDBClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockDBClientMockRecorder is the mock recorder for MockDBClient.

func (*MockDBClientMockRecorder) CreateBillingDoc 

func (mr *MockDBClientMockRecorder) CreateBillingDoc(ctx, doc any) *MockDBClientCreateBillingDocCall

CreateBillingDoc indicates an expected call of CreateBillingDoc.

func (*MockDBClientMockRecorder) GetLockClient 

func (mr *MockDBClientMockRecorder) GetLockClient() *MockDBClientGetLockClientCall

GetLockClient indicates an expected call of GetLockClient.

func (*MockDBClientMockRecorder) GlobalListers 

func (mr *MockDBClientMockRecorder) GlobalListers() *MockDBClientGlobalListersCall

GlobalListers indicates an expected call of GlobalListers.

func (*MockDBClientMockRecorder) HCPClusters 

func (mr *MockDBClientMockRecorder) HCPClusters(subscriptionID, resourceGroupName any) *MockDBClientHCPClustersCall

HCPClusters indicates an expected call of HCPClusters.

func (*MockDBClientMockRecorder) ManagementClusterContents 

func (mr *MockDBClientMockRecorder) ManagementClusterContents(subscriptionID, resourceGroupName, clusterName any) *MockDBClientManagementClusterContentsCall

ManagementClusterContents indicates an expected call of ManagementClusterContents.

func (*MockDBClientMockRecorder) NewTransaction 

func (mr *MockDBClientMockRecorder) NewTransaction(pk any) *MockDBClientNewTransactionCall

NewTransaction indicates an expected call of NewTransaction.

func (*MockDBClientMockRecorder) Operations 

func (mr *MockDBClientMockRecorder) Operations(subscriptionID any) *MockDBClientOperationsCall

Operations indicates an expected call of Operations.

func (*MockDBClientMockRecorder) PatchBillingDoc 

func (mr *MockDBClientMockRecorder) PatchBillingDoc(ctx, resourceID, ops any) *MockDBClientPatchBillingDocCall

PatchBillingDoc indicates an expected call of PatchBillingDoc.

func (*MockDBClientMockRecorder) ServiceProviderClusters 

func (mr *MockDBClientMockRecorder) ServiceProviderClusters(subscriptionID, resourceGroupName, clusterName any) *MockDBClientServiceProviderClustersCall

ServiceProviderClusters indicates an expected call of ServiceProviderClusters.

func (*MockDBClientMockRecorder) ServiceProviderNodePools 

func (mr *MockDBClientMockRecorder) ServiceProviderNodePools(subscriptionID, resourceGroupName, clusterName, nodePoolName any) *MockDBClientServiceProviderNodePoolsCall

ServiceProviderNodePools indicates an expected call of ServiceProviderNodePools.

func (*MockDBClientMockRecorder) Subscriptions 

func (mr *MockDBClientMockRecorder) Subscriptions() *MockDBClientSubscriptionsCall

Subscriptions indicates an expected call of Subscriptions.

func (*MockDBClientMockRecorder) UntypedCRUD 

func (mr *MockDBClientMockRecorder) UntypedCRUD(parentResourceID any) *MockDBClientUntypedCRUDCall

UntypedCRUD indicates an expected call of UntypedCRUD.

type MockDBClientNewTransactionCall 

type MockDBClientNewTransactionCall struct {
	*gomock.Call
}

MockDBClientNewTransactionCall wrap *gomock.Call

func (*MockDBClientNewTransactionCall) Do 

func (c *MockDBClientNewTransactionCall) Do(f func(string) DBTransaction) *MockDBClientNewTransactionCall

Do rewrite *gomock.Call.Do

func (*MockDBClientNewTransactionCall) DoAndReturn 

func (c *MockDBClientNewTransactionCall) DoAndReturn(f func(string) DBTransaction) *MockDBClientNewTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientNewTransactionCall) Return 

func (c *MockDBClientNewTransactionCall) Return(arg0 DBTransaction) *MockDBClientNewTransactionCall

Return rewrite *gomock.Call.Return

type MockDBClientOperationsCall 

type MockDBClientOperationsCall struct {
	*gomock.Call
}

MockDBClientOperationsCall wrap *gomock.Call

func (*MockDBClientOperationsCall) Do 

func (c *MockDBClientOperationsCall) Do(f func(string) OperationCRUD) *MockDBClientOperationsCall

Do rewrite *gomock.Call.Do

func (*MockDBClientOperationsCall) DoAndReturn 

func (c *MockDBClientOperationsCall) DoAndReturn(f func(string) OperationCRUD) *MockDBClientOperationsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientOperationsCall) Return 

func (c *MockDBClientOperationsCall) Return(arg0 OperationCRUD) *MockDBClientOperationsCall

Return rewrite *gomock.Call.Return

type MockDBClientPatchBillingDocCall 

type MockDBClientPatchBillingDocCall struct {
	*gomock.Call
}

MockDBClientPatchBillingDocCall wrap *gomock.Call

func (*MockDBClientPatchBillingDocCall) Do 

func (c *MockDBClientPatchBillingDocCall) Do(f func(context.Context, *arm.ResourceID, BillingDocumentPatchOperations) error) *MockDBClientPatchBillingDocCall

Do rewrite *gomock.Call.Do

func (*MockDBClientPatchBillingDocCall) DoAndReturn 

func (c *MockDBClientPatchBillingDocCall) DoAndReturn(f func(context.Context, *arm.ResourceID, BillingDocumentPatchOperations) error) *MockDBClientPatchBillingDocCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientPatchBillingDocCall) Return 

func (c *MockDBClientPatchBillingDocCall) Return(arg0 error) *MockDBClientPatchBillingDocCall

Return rewrite *gomock.Call.Return

type MockDBClientServiceProviderClustersCall 

type MockDBClientServiceProviderClustersCall struct {
	*gomock.Call
}

MockDBClientServiceProviderClustersCall wrap *gomock.Call

func (*MockDBClientServiceProviderClustersCall) Do 

func (c *MockDBClientServiceProviderClustersCall) Do(f func(string, string, string) ServiceProviderClusterCRUD) *MockDBClientServiceProviderClustersCall

Do rewrite *gomock.Call.Do

func (*MockDBClientServiceProviderClustersCall) DoAndReturn 

func (c *MockDBClientServiceProviderClustersCall) DoAndReturn(f func(string, string, string) ServiceProviderClusterCRUD) *MockDBClientServiceProviderClustersCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientServiceProviderClustersCall) Return 

func (c *MockDBClientServiceProviderClustersCall) Return(arg0 ServiceProviderClusterCRUD) *MockDBClientServiceProviderClustersCall

Return rewrite *gomock.Call.Return

type MockDBClientServiceProviderNodePoolsCall 

type MockDBClientServiceProviderNodePoolsCall struct {
	*gomock.Call
}

MockDBClientServiceProviderNodePoolsCall wrap *gomock.Call

func (*MockDBClientServiceProviderNodePoolsCall) Do 

func (c *MockDBClientServiceProviderNodePoolsCall) Do(f func(string, string, string, string) ServiceProviderNodePoolCRUD) *MockDBClientServiceProviderNodePoolsCall

Do rewrite *gomock.Call.Do

func (*MockDBClientServiceProviderNodePoolsCall) DoAndReturn 

func (c *MockDBClientServiceProviderNodePoolsCall) DoAndReturn(f func(string, string, string, string) ServiceProviderNodePoolCRUD) *MockDBClientServiceProviderNodePoolsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientServiceProviderNodePoolsCall) Return 

func (c *MockDBClientServiceProviderNodePoolsCall) Return(arg0 ServiceProviderNodePoolCRUD) *MockDBClientServiceProviderNodePoolsCall

Return rewrite *gomock.Call.Return

type MockDBClientSubscriptionsCall 

type MockDBClientSubscriptionsCall struct {
	*gomock.Call
}

MockDBClientSubscriptionsCall wrap *gomock.Call

func (*MockDBClientSubscriptionsCall) Do 

func (c *MockDBClientSubscriptionsCall) Do(f func() SubscriptionCRUD) *MockDBClientSubscriptionsCall

Do rewrite *gomock.Call.Do

func (*MockDBClientSubscriptionsCall) DoAndReturn 

func (c *MockDBClientSubscriptionsCall) DoAndReturn(f func() SubscriptionCRUD) *MockDBClientSubscriptionsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientSubscriptionsCall) Return 

func (c *MockDBClientSubscriptionsCall) Return(arg0 SubscriptionCRUD) *MockDBClientSubscriptionsCall

Return rewrite *gomock.Call.Return

type MockDBClientUntypedCRUDCall 

type MockDBClientUntypedCRUDCall struct {
	*gomock.Call
}

MockDBClientUntypedCRUDCall wrap *gomock.Call

func (*MockDBClientUntypedCRUDCall) Do 

func (c *MockDBClientUntypedCRUDCall) Do(f func(arm.ResourceID) (UntypedResourceCRUD, error)) *MockDBClientUntypedCRUDCall

Do rewrite *gomock.Call.Do

func (*MockDBClientUntypedCRUDCall) DoAndReturn 

func (c *MockDBClientUntypedCRUDCall) DoAndReturn(f func(arm.ResourceID) (UntypedResourceCRUD, error)) *MockDBClientUntypedCRUDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBClientUntypedCRUDCall) Return 

func (c *MockDBClientUntypedCRUDCall) Return(arg0 UntypedResourceCRUD, arg1 error) *MockDBClientUntypedCRUDCall

Return rewrite *gomock.Call.Return

type MockDBTransaction 

type MockDBTransaction struct {
	// contains filtered or unexported fields
}

MockDBTransaction is a mock of DBTransaction interface.

func NewMockDBTransaction 

func NewMockDBTransaction(ctrl *gomock.Controller) *MockDBTransaction

NewMockDBTransaction creates a new mock instance.

func (*MockDBTransaction) AddStep 

func (m *MockDBTransaction) AddStep(arg0 CosmosDBTransactionStepDetails, arg1 CosmosDBTransactionStep)

AddStep mocks base method.

func (*MockDBTransaction) EXPECT 

func (m *MockDBTransaction) EXPECT() *MockDBTransactionMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDBTransaction) Execute 

func (m *MockDBTransaction) Execute(ctx context.Context, o *azcosmos.TransactionalBatchOptions) (DBTransactionResult, error)

Execute mocks base method.

func (*MockDBTransaction) GetPartitionKey 

func (m *MockDBTransaction) GetPartitionKey() string

GetPartitionKey mocks base method.

func (*MockDBTransaction) OnSuccess 

func (m *MockDBTransaction) OnSuccess(callback DBTransactionCallback)

OnSuccess mocks base method.

type MockDBTransactionAddStepCall 

type MockDBTransactionAddStepCall struct {
	*gomock.Call
}

MockDBTransactionAddStepCall wrap *gomock.Call

func (*MockDBTransactionAddStepCall) Do 

func (c *MockDBTransactionAddStepCall) Do(f func(CosmosDBTransactionStepDetails, CosmosDBTransactionStep)) *MockDBTransactionAddStepCall

Do rewrite *gomock.Call.Do

func (*MockDBTransactionAddStepCall) DoAndReturn 

func (c *MockDBTransactionAddStepCall) DoAndReturn(f func(CosmosDBTransactionStepDetails, CosmosDBTransactionStep)) *MockDBTransactionAddStepCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBTransactionAddStepCall) Return 

func (c *MockDBTransactionAddStepCall) Return() *MockDBTransactionAddStepCall

Return rewrite *gomock.Call.Return

type MockDBTransactionExecuteCall 

type MockDBTransactionExecuteCall struct {
	*gomock.Call
}

MockDBTransactionExecuteCall wrap *gomock.Call

func (*MockDBTransactionExecuteCall) Do 

func (c *MockDBTransactionExecuteCall) Do(f func(context.Context, *azcosmos.TransactionalBatchOptions) (DBTransactionResult, error)) *MockDBTransactionExecuteCall

Do rewrite *gomock.Call.Do

func (*MockDBTransactionExecuteCall) DoAndReturn 

func (c *MockDBTransactionExecuteCall) DoAndReturn(f func(context.Context, *azcosmos.TransactionalBatchOptions) (DBTransactionResult, error)) *MockDBTransactionExecuteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBTransactionExecuteCall) Return 

func (c *MockDBTransactionExecuteCall) Return(arg0 DBTransactionResult, arg1 error) *MockDBTransactionExecuteCall

Return rewrite *gomock.Call.Return

type MockDBTransactionGetPartitionKeyCall 

type MockDBTransactionGetPartitionKeyCall struct {
	*gomock.Call
}

MockDBTransactionGetPartitionKeyCall wrap *gomock.Call

func (*MockDBTransactionGetPartitionKeyCall) Do 

func (c *MockDBTransactionGetPartitionKeyCall) Do(f func() string) *MockDBTransactionGetPartitionKeyCall

Do rewrite *gomock.Call.Do

func (*MockDBTransactionGetPartitionKeyCall) DoAndReturn 

func (c *MockDBTransactionGetPartitionKeyCall) DoAndReturn(f func() string) *MockDBTransactionGetPartitionKeyCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBTransactionGetPartitionKeyCall) Return 

func (c *MockDBTransactionGetPartitionKeyCall) Return(arg0 string) *MockDBTransactionGetPartitionKeyCall

Return rewrite *gomock.Call.Return

type MockDBTransactionMockRecorder 

type MockDBTransactionMockRecorder struct {
	// contains filtered or unexported fields
}

MockDBTransactionMockRecorder is the mock recorder for MockDBTransaction.

func (*MockDBTransactionMockRecorder) AddStep 

func (mr *MockDBTransactionMockRecorder) AddStep(arg0, arg1 any) *MockDBTransactionAddStepCall

AddStep indicates an expected call of AddStep.

func (*MockDBTransactionMockRecorder) Execute 

func (mr *MockDBTransactionMockRecorder) Execute(ctx, o any) *MockDBTransactionExecuteCall

Execute indicates an expected call of Execute.

func (*MockDBTransactionMockRecorder) GetPartitionKey 

func (mr *MockDBTransactionMockRecorder) GetPartitionKey() *MockDBTransactionGetPartitionKeyCall

GetPartitionKey indicates an expected call of GetPartitionKey.

func (*MockDBTransactionMockRecorder) OnSuccess 

func (mr *MockDBTransactionMockRecorder) OnSuccess(callback any) *MockDBTransactionOnSuccessCall

OnSuccess indicates an expected call of OnSuccess.

type MockDBTransactionOnSuccessCall 

type MockDBTransactionOnSuccessCall struct {
	*gomock.Call
}

MockDBTransactionOnSuccessCall wrap *gomock.Call

func (*MockDBTransactionOnSuccessCall) Do 

func (c *MockDBTransactionOnSuccessCall) Do(f func(DBTransactionCallback)) *MockDBTransactionOnSuccessCall

Do rewrite *gomock.Call.Do

func (*MockDBTransactionOnSuccessCall) DoAndReturn 

func (c *MockDBTransactionOnSuccessCall) DoAndReturn(f func(DBTransactionCallback)) *MockDBTransactionOnSuccessCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBTransactionOnSuccessCall) Return 

func (c *MockDBTransactionOnSuccessCall) Return() *MockDBTransactionOnSuccessCall

Return rewrite *gomock.Call.Return

type MockDBTransactionResult 

type MockDBTransactionResult struct {
	// contains filtered or unexported fields
}

MockDBTransactionResult is a mock of DBTransactionResult interface.

func NewMockDBTransactionResult 

func NewMockDBTransactionResult(ctrl *gomock.Controller) *MockDBTransactionResult

NewMockDBTransactionResult creates a new mock instance.

func (*MockDBTransactionResult) EXPECT 

func (m *MockDBTransactionResult) EXPECT() *MockDBTransactionResultMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDBTransactionResult) GetItem 

func (m *MockDBTransactionResult) GetItem(cosmosUID string) (any, error)

GetItem mocks base method.

type MockDBTransactionResultGetItemCall 

type MockDBTransactionResultGetItemCall struct {
	*gomock.Call
}

MockDBTransactionResultGetItemCall wrap *gomock.Call

func (*MockDBTransactionResultGetItemCall) Do 

func (c *MockDBTransactionResultGetItemCall) Do(f func(string) (any, error)) *MockDBTransactionResultGetItemCall

Do rewrite *gomock.Call.Do

func (*MockDBTransactionResultGetItemCall) DoAndReturn 

func (c *MockDBTransactionResultGetItemCall) DoAndReturn(f func(string) (any, error)) *MockDBTransactionResultGetItemCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockDBTransactionResultGetItemCall) Return 

func (c *MockDBTransactionResultGetItemCall) Return(arg0 any, arg1 error) *MockDBTransactionResultGetItemCall

Return rewrite *gomock.Call.Return

type MockDBTransactionResultMockRecorder 

type MockDBTransactionResultMockRecorder struct {
	// contains filtered or unexported fields
}

MockDBTransactionResultMockRecorder is the mock recorder for MockDBTransactionResult.

func (*MockDBTransactionResultMockRecorder) GetItem 

func (mr *MockDBTransactionResultMockRecorder) GetItem(cosmosUID any) *MockDBTransactionResultGetItemCall

GetItem indicates an expected call of GetItem.

type MockExternalAuthsCRUD 

type MockExternalAuthsCRUD struct {
	// contains filtered or unexported fields
}

MockExternalAuthsCRUD is a mock of ExternalAuthsCRUD interface.

func NewMockExternalAuthsCRUD 

func NewMockExternalAuthsCRUD(ctrl *gomock.Controller) *MockExternalAuthsCRUD

NewMockExternalAuthsCRUD creates a new mock instance.

func (*MockExternalAuthsCRUD) AddCreateToTransaction 

func (m *MockExternalAuthsCRUD) AddCreateToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.HCPOpenShiftClusterExternalAuth, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddCreateToTransaction mocks base method.

func (*MockExternalAuthsCRUD) AddReplaceToTransaction 

func (m *MockExternalAuthsCRUD) AddReplaceToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.HCPOpenShiftClusterExternalAuth, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddReplaceToTransaction mocks base method.

func (*MockExternalAuthsCRUD) Controllers 

func (m *MockExternalAuthsCRUD) Controllers(hcpClusterID string) ResourceCRUD[api.Controller]

Controllers mocks base method.

func (*MockExternalAuthsCRUD) Create 

func (m *MockExternalAuthsCRUD) Create(ctx context.Context, newObj *api.HCPOpenShiftClusterExternalAuth, options *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterExternalAuth, error)

Create mocks base method.

func (*MockExternalAuthsCRUD) Delete 

func (m *MockExternalAuthsCRUD) Delete(ctx context.Context, resourceID string) error

Delete mocks base method.

func (*MockExternalAuthsCRUD) EXPECT 

func (m *MockExternalAuthsCRUD) EXPECT() *MockExternalAuthsCRUDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockExternalAuthsCRUD) Get 

func (m *MockExternalAuthsCRUD) Get(ctx context.Context, resourceID string) (*api.HCPOpenShiftClusterExternalAuth, error)

Get mocks base method.

func (*MockExternalAuthsCRUD) GetByID 

func (m *MockExternalAuthsCRUD) GetByID(ctx context.Context, cosmosID string) (*api.HCPOpenShiftClusterExternalAuth, error)

GetByID mocks base method.

func (*MockExternalAuthsCRUD) List 

func (m *MockExternalAuthsCRUD) List(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[api.HCPOpenShiftClusterExternalAuth], error)

List mocks base method.

func (*MockExternalAuthsCRUD) Replace 

func (m *MockExternalAuthsCRUD) Replace(ctx context.Context, newObj *api.HCPOpenShiftClusterExternalAuth, options *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterExternalAuth, error)

Replace mocks base method.

type MockExternalAuthsCRUDAddCreateToTransactionCall 

type MockExternalAuthsCRUDAddCreateToTransactionCall struct {
	*gomock.Call
}

MockExternalAuthsCRUDAddCreateToTransactionCall wrap *gomock.Call

func (*MockExternalAuthsCRUDAddCreateToTransactionCall) Do 

func (c *MockExternalAuthsCRUDAddCreateToTransactionCall) Do(f func(context.Context, DBTransaction, *api.HCPOpenShiftClusterExternalAuth, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockExternalAuthsCRUDAddCreateToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockExternalAuthsCRUDAddCreateToTransactionCall) DoAndReturn 

func (c *MockExternalAuthsCRUDAddCreateToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.HCPOpenShiftClusterExternalAuth, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockExternalAuthsCRUDAddCreateToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockExternalAuthsCRUDAddCreateToTransactionCall) Return 

func (c *MockExternalAuthsCRUDAddCreateToTransactionCall) Return(arg0 string, arg1 error) *MockExternalAuthsCRUDAddCreateToTransactionCall

Return rewrite *gomock.Call.Return

type MockExternalAuthsCRUDAddReplaceToTransactionCall 

type MockExternalAuthsCRUDAddReplaceToTransactionCall struct {
	*gomock.Call
}

MockExternalAuthsCRUDAddReplaceToTransactionCall wrap *gomock.Call

func (*MockExternalAuthsCRUDAddReplaceToTransactionCall) Do 

func (c *MockExternalAuthsCRUDAddReplaceToTransactionCall) Do(f func(context.Context, DBTransaction, *api.HCPOpenShiftClusterExternalAuth, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockExternalAuthsCRUDAddReplaceToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockExternalAuthsCRUDAddReplaceToTransactionCall) DoAndReturn 

func (c *MockExternalAuthsCRUDAddReplaceToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.HCPOpenShiftClusterExternalAuth, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockExternalAuthsCRUDAddReplaceToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockExternalAuthsCRUDAddReplaceToTransactionCall) Return 

func (c *MockExternalAuthsCRUDAddReplaceToTransactionCall) Return(arg0 string, arg1 error) *MockExternalAuthsCRUDAddReplaceToTransactionCall

Return rewrite *gomock.Call.Return

type MockExternalAuthsCRUDControllersCall 

type MockExternalAuthsCRUDControllersCall struct {
	*gomock.Call
}

MockExternalAuthsCRUDControllersCall wrap *gomock.Call

func (*MockExternalAuthsCRUDControllersCall) Do 

func (c *MockExternalAuthsCRUDControllersCall) Do(f func(string) ResourceCRUD[api.Controller]) *MockExternalAuthsCRUDControllersCall

Do rewrite *gomock.Call.Do

func (*MockExternalAuthsCRUDControllersCall) DoAndReturn 

func (c *MockExternalAuthsCRUDControllersCall) DoAndReturn(f func(string) ResourceCRUD[api.Controller]) *MockExternalAuthsCRUDControllersCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockExternalAuthsCRUDControllersCall) Return 

func (c *MockExternalAuthsCRUDControllersCall) Return(arg0 ResourceCRUD[api.Controller]) *MockExternalAuthsCRUDControllersCall

Return rewrite *gomock.Call.Return

type MockExternalAuthsCRUDCreateCall 

type MockExternalAuthsCRUDCreateCall struct {
	*gomock.Call
}

MockExternalAuthsCRUDCreateCall wrap *gomock.Call

func (*MockExternalAuthsCRUDCreateCall) Do 

func (c *MockExternalAuthsCRUDCreateCall) Do(f func(context.Context, *api.HCPOpenShiftClusterExternalAuth, *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterExternalAuth, error)) *MockExternalAuthsCRUDCreateCall

Do rewrite *gomock.Call.Do

func (*MockExternalAuthsCRUDCreateCall) DoAndReturn 

func (c *MockExternalAuthsCRUDCreateCall) DoAndReturn(f func(context.Context, *api.HCPOpenShiftClusterExternalAuth, *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterExternalAuth, error)) *MockExternalAuthsCRUDCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockExternalAuthsCRUDCreateCall) Return 

func (c *MockExternalAuthsCRUDCreateCall) Return(arg0 *api.HCPOpenShiftClusterExternalAuth, arg1 error) *MockExternalAuthsCRUDCreateCall

Return rewrite *gomock.Call.Return

type MockExternalAuthsCRUDDeleteCall 

type MockExternalAuthsCRUDDeleteCall struct {
	*gomock.Call
}

MockExternalAuthsCRUDDeleteCall wrap *gomock.Call

func (*MockExternalAuthsCRUDDeleteCall) Do 

func (c *MockExternalAuthsCRUDDeleteCall) Do(f func(context.Context, string) error) *MockExternalAuthsCRUDDeleteCall

Do rewrite *gomock.Call.Do

func (*MockExternalAuthsCRUDDeleteCall) DoAndReturn 

func (c *MockExternalAuthsCRUDDeleteCall) DoAndReturn(f func(context.Context, string) error) *MockExternalAuthsCRUDDeleteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockExternalAuthsCRUDDeleteCall) Return 

func (c *MockExternalAuthsCRUDDeleteCall) Return(arg0 error) *MockExternalAuthsCRUDDeleteCall

Return rewrite *gomock.Call.Return

type MockExternalAuthsCRUDGetByIDCall 

type MockExternalAuthsCRUDGetByIDCall struct {
	*gomock.Call
}

MockExternalAuthsCRUDGetByIDCall wrap *gomock.Call

func (*MockExternalAuthsCRUDGetByIDCall) Do 

func (c *MockExternalAuthsCRUDGetByIDCall) Do(f func(context.Context, string) (*api.HCPOpenShiftClusterExternalAuth, error)) *MockExternalAuthsCRUDGetByIDCall

Do rewrite *gomock.Call.Do

func (*MockExternalAuthsCRUDGetByIDCall) DoAndReturn 

func (c *MockExternalAuthsCRUDGetByIDCall) DoAndReturn(f func(context.Context, string) (*api.HCPOpenShiftClusterExternalAuth, error)) *MockExternalAuthsCRUDGetByIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockExternalAuthsCRUDGetByIDCall) Return 

func (c *MockExternalAuthsCRUDGetByIDCall) Return(arg0 *api.HCPOpenShiftClusterExternalAuth, arg1 error) *MockExternalAuthsCRUDGetByIDCall

Return rewrite *gomock.Call.Return

type MockExternalAuthsCRUDGetCall 

type MockExternalAuthsCRUDGetCall struct {
	*gomock.Call
}

MockExternalAuthsCRUDGetCall wrap *gomock.Call

func (*MockExternalAuthsCRUDGetCall) Do 

func (c *MockExternalAuthsCRUDGetCall) Do(f func(context.Context, string) (*api.HCPOpenShiftClusterExternalAuth, error)) *MockExternalAuthsCRUDGetCall

Do rewrite *gomock.Call.Do

func (*MockExternalAuthsCRUDGetCall) DoAndReturn 

func (c *MockExternalAuthsCRUDGetCall) DoAndReturn(f func(context.Context, string) (*api.HCPOpenShiftClusterExternalAuth, error)) *MockExternalAuthsCRUDGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockExternalAuthsCRUDGetCall) Return 

func (c *MockExternalAuthsCRUDGetCall) Return(arg0 *api.HCPOpenShiftClusterExternalAuth, arg1 error) *MockExternalAuthsCRUDGetCall

Return rewrite *gomock.Call.Return

type MockExternalAuthsCRUDListCall 

type MockExternalAuthsCRUDListCall struct {
	*gomock.Call
}

MockExternalAuthsCRUDListCall wrap *gomock.Call

func (*MockExternalAuthsCRUDListCall) Do 

func (c *MockExternalAuthsCRUDListCall) Do(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.HCPOpenShiftClusterExternalAuth], error)) *MockExternalAuthsCRUDListCall

Do rewrite *gomock.Call.Do

func (*MockExternalAuthsCRUDListCall) DoAndReturn 

func (c *MockExternalAuthsCRUDListCall) DoAndReturn(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.HCPOpenShiftClusterExternalAuth], error)) *MockExternalAuthsCRUDListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockExternalAuthsCRUDListCall) Return 

func (c *MockExternalAuthsCRUDListCall) Return(arg0 DBClientIterator[api.HCPOpenShiftClusterExternalAuth], arg1 error) *MockExternalAuthsCRUDListCall

Return rewrite *gomock.Call.Return

type MockExternalAuthsCRUDMockRecorder 

type MockExternalAuthsCRUDMockRecorder struct {
	// contains filtered or unexported fields
}

MockExternalAuthsCRUDMockRecorder is the mock recorder for MockExternalAuthsCRUD.

func (*MockExternalAuthsCRUDMockRecorder) AddCreateToTransaction 

func (mr *MockExternalAuthsCRUDMockRecorder) AddCreateToTransaction(ctx, transaction, newObj, opts any) *MockExternalAuthsCRUDAddCreateToTransactionCall

AddCreateToTransaction indicates an expected call of AddCreateToTransaction.

func (*MockExternalAuthsCRUDMockRecorder) AddReplaceToTransaction 

func (mr *MockExternalAuthsCRUDMockRecorder) AddReplaceToTransaction(ctx, transaction, newObj, opts any) *MockExternalAuthsCRUDAddReplaceToTransactionCall

AddReplaceToTransaction indicates an expected call of AddReplaceToTransaction.

func (*MockExternalAuthsCRUDMockRecorder) Controllers 

func (mr *MockExternalAuthsCRUDMockRecorder) Controllers(hcpClusterID any) *MockExternalAuthsCRUDControllersCall

Controllers indicates an expected call of Controllers.

func (*MockExternalAuthsCRUDMockRecorder) Create 

func (mr *MockExternalAuthsCRUDMockRecorder) Create(ctx, newObj, options any) *MockExternalAuthsCRUDCreateCall

Create indicates an expected call of Create.

func (*MockExternalAuthsCRUDMockRecorder) Delete 

func (mr *MockExternalAuthsCRUDMockRecorder) Delete(ctx, resourceID any) *MockExternalAuthsCRUDDeleteCall

Delete indicates an expected call of Delete.

func (*MockExternalAuthsCRUDMockRecorder) Get 

func (mr *MockExternalAuthsCRUDMockRecorder) Get(ctx, resourceID any) *MockExternalAuthsCRUDGetCall

Get indicates an expected call of Get.

func (*MockExternalAuthsCRUDMockRecorder) GetByID 

func (mr *MockExternalAuthsCRUDMockRecorder) GetByID(ctx, cosmosID any) *MockExternalAuthsCRUDGetByIDCall

GetByID indicates an expected call of GetByID.

func (*MockExternalAuthsCRUDMockRecorder) List 

func (mr *MockExternalAuthsCRUDMockRecorder) List(ctx, opts any) *MockExternalAuthsCRUDListCall

List indicates an expected call of List.

func (*MockExternalAuthsCRUDMockRecorder) Replace 

func (mr *MockExternalAuthsCRUDMockRecorder) Replace(ctx, newObj, options any) *MockExternalAuthsCRUDReplaceCall

Replace indicates an expected call of Replace.

type MockExternalAuthsCRUDReplaceCall 

type MockExternalAuthsCRUDReplaceCall struct {
	*gomock.Call
}

MockExternalAuthsCRUDReplaceCall wrap *gomock.Call

func (*MockExternalAuthsCRUDReplaceCall) Do 

func (c *MockExternalAuthsCRUDReplaceCall) Do(f func(context.Context, *api.HCPOpenShiftClusterExternalAuth, *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterExternalAuth, error)) *MockExternalAuthsCRUDReplaceCall

Do rewrite *gomock.Call.Do

func (*MockExternalAuthsCRUDReplaceCall) DoAndReturn 

func (c *MockExternalAuthsCRUDReplaceCall) DoAndReturn(f func(context.Context, *api.HCPOpenShiftClusterExternalAuth, *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterExternalAuth, error)) *MockExternalAuthsCRUDReplaceCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockExternalAuthsCRUDReplaceCall) Return 

func (c *MockExternalAuthsCRUDReplaceCall) Return(arg0 *api.HCPOpenShiftClusterExternalAuth, arg1 error) *MockExternalAuthsCRUDReplaceCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUD 

type MockHCPClusterCRUD struct {
	// contains filtered or unexported fields
}

MockHCPClusterCRUD is a mock of HCPClusterCRUD interface.

func NewMockHCPClusterCRUD 

func NewMockHCPClusterCRUD(ctrl *gomock.Controller) *MockHCPClusterCRUD

NewMockHCPClusterCRUD creates a new mock instance.

func (*MockHCPClusterCRUD) AddCreateToTransaction 

func (m *MockHCPClusterCRUD) AddCreateToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.HCPOpenShiftCluster, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddCreateToTransaction mocks base method.

func (*MockHCPClusterCRUD) AddReplaceToTransaction 

func (m *MockHCPClusterCRUD) AddReplaceToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.HCPOpenShiftCluster, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddReplaceToTransaction mocks base method.

func (*MockHCPClusterCRUD) Controllers 

func (m *MockHCPClusterCRUD) Controllers(hcpClusterID string) ResourceCRUD[api.Controller]

Controllers mocks base method.

func (*MockHCPClusterCRUD) Create 

func (m *MockHCPClusterCRUD) Create(ctx context.Context, newObj *api.HCPOpenShiftCluster, options *azcosmos.ItemOptions) (*api.HCPOpenShiftCluster, error)

Create mocks base method.

func (*MockHCPClusterCRUD) Delete 

func (m *MockHCPClusterCRUD) Delete(ctx context.Context, resourceID string) error

Delete mocks base method.

func (*MockHCPClusterCRUD) EXPECT 

func (m *MockHCPClusterCRUD) EXPECT() *MockHCPClusterCRUDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockHCPClusterCRUD) ExternalAuth 

func (m *MockHCPClusterCRUD) ExternalAuth(hcpClusterID string) ExternalAuthsCRUD

ExternalAuth mocks base method.

func (*MockHCPClusterCRUD) Get 

func (m *MockHCPClusterCRUD) Get(ctx context.Context, resourceID string) (*api.HCPOpenShiftCluster, error)

Get mocks base method.

func (*MockHCPClusterCRUD) GetByID 

func (m *MockHCPClusterCRUD) GetByID(ctx context.Context, cosmosID string) (*api.HCPOpenShiftCluster, error)

GetByID mocks base method.

func (*MockHCPClusterCRUD) List 

func (m *MockHCPClusterCRUD) List(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[api.HCPOpenShiftCluster], error)

List mocks base method.

func (*MockHCPClusterCRUD) NodePools 

func (m *MockHCPClusterCRUD) NodePools(hcpClusterID string) NodePoolsCRUD

NodePools mocks base method.

func (*MockHCPClusterCRUD) Replace 

func (m *MockHCPClusterCRUD) Replace(ctx context.Context, newObj *api.HCPOpenShiftCluster, options *azcosmos.ItemOptions) (*api.HCPOpenShiftCluster, error)

Replace mocks base method.

type MockHCPClusterCRUDAddCreateToTransactionCall 

type MockHCPClusterCRUDAddCreateToTransactionCall struct {
	*gomock.Call
}

MockHCPClusterCRUDAddCreateToTransactionCall wrap *gomock.Call

func (*MockHCPClusterCRUDAddCreateToTransactionCall) Do 

func (c *MockHCPClusterCRUDAddCreateToTransactionCall) Do(f func(context.Context, DBTransaction, *api.HCPOpenShiftCluster, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockHCPClusterCRUDAddCreateToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDAddCreateToTransactionCall) DoAndReturn 

func (c *MockHCPClusterCRUDAddCreateToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.HCPOpenShiftCluster, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockHCPClusterCRUDAddCreateToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDAddCreateToTransactionCall) Return 

func (c *MockHCPClusterCRUDAddCreateToTransactionCall) Return(arg0 string, arg1 error) *MockHCPClusterCRUDAddCreateToTransactionCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUDAddReplaceToTransactionCall 

type MockHCPClusterCRUDAddReplaceToTransactionCall struct {
	*gomock.Call
}

MockHCPClusterCRUDAddReplaceToTransactionCall wrap *gomock.Call

func (*MockHCPClusterCRUDAddReplaceToTransactionCall) Do 

func (c *MockHCPClusterCRUDAddReplaceToTransactionCall) Do(f func(context.Context, DBTransaction, *api.HCPOpenShiftCluster, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockHCPClusterCRUDAddReplaceToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDAddReplaceToTransactionCall) DoAndReturn 

func (c *MockHCPClusterCRUDAddReplaceToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.HCPOpenShiftCluster, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockHCPClusterCRUDAddReplaceToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDAddReplaceToTransactionCall) Return 

func (c *MockHCPClusterCRUDAddReplaceToTransactionCall) Return(arg0 string, arg1 error) *MockHCPClusterCRUDAddReplaceToTransactionCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUDControllersCall 

type MockHCPClusterCRUDControllersCall struct {
	*gomock.Call
}

MockHCPClusterCRUDControllersCall wrap *gomock.Call

func (*MockHCPClusterCRUDControllersCall) Do 

func (c *MockHCPClusterCRUDControllersCall) Do(f func(string) ResourceCRUD[api.Controller]) *MockHCPClusterCRUDControllersCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDControllersCall) DoAndReturn 

func (c *MockHCPClusterCRUDControllersCall) DoAndReturn(f func(string) ResourceCRUD[api.Controller]) *MockHCPClusterCRUDControllersCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDControllersCall) Return 

func (c *MockHCPClusterCRUDControllersCall) Return(arg0 ResourceCRUD[api.Controller]) *MockHCPClusterCRUDControllersCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUDCreateCall 

type MockHCPClusterCRUDCreateCall struct {
	*gomock.Call
}

MockHCPClusterCRUDCreateCall wrap *gomock.Call

func (*MockHCPClusterCRUDCreateCall) Do 

func (c *MockHCPClusterCRUDCreateCall) Do(f func(context.Context, *api.HCPOpenShiftCluster, *azcosmos.ItemOptions) (*api.HCPOpenShiftCluster, error)) *MockHCPClusterCRUDCreateCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDCreateCall) DoAndReturn 

func (c *MockHCPClusterCRUDCreateCall) DoAndReturn(f func(context.Context, *api.HCPOpenShiftCluster, *azcosmos.ItemOptions) (*api.HCPOpenShiftCluster, error)) *MockHCPClusterCRUDCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDCreateCall) Return 

func (c *MockHCPClusterCRUDCreateCall) Return(arg0 *api.HCPOpenShiftCluster, arg1 error) *MockHCPClusterCRUDCreateCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUDDeleteCall 

type MockHCPClusterCRUDDeleteCall struct {
	*gomock.Call
}

MockHCPClusterCRUDDeleteCall wrap *gomock.Call

func (*MockHCPClusterCRUDDeleteCall) Do 

func (c *MockHCPClusterCRUDDeleteCall) Do(f func(context.Context, string) error) *MockHCPClusterCRUDDeleteCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDDeleteCall) DoAndReturn 

func (c *MockHCPClusterCRUDDeleteCall) DoAndReturn(f func(context.Context, string) error) *MockHCPClusterCRUDDeleteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDDeleteCall) Return 

func (c *MockHCPClusterCRUDDeleteCall) Return(arg0 error) *MockHCPClusterCRUDDeleteCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUDExternalAuthCall 

type MockHCPClusterCRUDExternalAuthCall struct {
	*gomock.Call
}

MockHCPClusterCRUDExternalAuthCall wrap *gomock.Call

func (*MockHCPClusterCRUDExternalAuthCall) Do 

func (c *MockHCPClusterCRUDExternalAuthCall) Do(f func(string) ExternalAuthsCRUD) *MockHCPClusterCRUDExternalAuthCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDExternalAuthCall) DoAndReturn 

func (c *MockHCPClusterCRUDExternalAuthCall) DoAndReturn(f func(string) ExternalAuthsCRUD) *MockHCPClusterCRUDExternalAuthCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDExternalAuthCall) Return 

func (c *MockHCPClusterCRUDExternalAuthCall) Return(arg0 ExternalAuthsCRUD) *MockHCPClusterCRUDExternalAuthCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUDGetByIDCall 

type MockHCPClusterCRUDGetByIDCall struct {
	*gomock.Call
}

MockHCPClusterCRUDGetByIDCall wrap *gomock.Call

func (*MockHCPClusterCRUDGetByIDCall) Do 

func (c *MockHCPClusterCRUDGetByIDCall) Do(f func(context.Context, string) (*api.HCPOpenShiftCluster, error)) *MockHCPClusterCRUDGetByIDCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDGetByIDCall) DoAndReturn 

func (c *MockHCPClusterCRUDGetByIDCall) DoAndReturn(f func(context.Context, string) (*api.HCPOpenShiftCluster, error)) *MockHCPClusterCRUDGetByIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDGetByIDCall) Return 

func (c *MockHCPClusterCRUDGetByIDCall) Return(arg0 *api.HCPOpenShiftCluster, arg1 error) *MockHCPClusterCRUDGetByIDCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUDGetCall 

type MockHCPClusterCRUDGetCall struct {
	*gomock.Call
}

MockHCPClusterCRUDGetCall wrap *gomock.Call

func (*MockHCPClusterCRUDGetCall) Do 

func (c *MockHCPClusterCRUDGetCall) Do(f func(context.Context, string) (*api.HCPOpenShiftCluster, error)) *MockHCPClusterCRUDGetCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDGetCall) DoAndReturn 

func (c *MockHCPClusterCRUDGetCall) DoAndReturn(f func(context.Context, string) (*api.HCPOpenShiftCluster, error)) *MockHCPClusterCRUDGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDGetCall) Return 

func (c *MockHCPClusterCRUDGetCall) Return(arg0 *api.HCPOpenShiftCluster, arg1 error) *MockHCPClusterCRUDGetCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUDListCall 

type MockHCPClusterCRUDListCall struct {
	*gomock.Call
}

MockHCPClusterCRUDListCall wrap *gomock.Call

func (*MockHCPClusterCRUDListCall) Do 

func (c *MockHCPClusterCRUDListCall) Do(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.HCPOpenShiftCluster], error)) *MockHCPClusterCRUDListCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDListCall) DoAndReturn 

func (c *MockHCPClusterCRUDListCall) DoAndReturn(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.HCPOpenShiftCluster], error)) *MockHCPClusterCRUDListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDListCall) Return 

func (c *MockHCPClusterCRUDListCall) Return(arg0 DBClientIterator[api.HCPOpenShiftCluster], arg1 error) *MockHCPClusterCRUDListCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUDMockRecorder 

type MockHCPClusterCRUDMockRecorder struct {
	// contains filtered or unexported fields
}

MockHCPClusterCRUDMockRecorder is the mock recorder for MockHCPClusterCRUD.

func (*MockHCPClusterCRUDMockRecorder) AddCreateToTransaction 

func (mr *MockHCPClusterCRUDMockRecorder) AddCreateToTransaction(ctx, transaction, newObj, opts any) *MockHCPClusterCRUDAddCreateToTransactionCall

AddCreateToTransaction indicates an expected call of AddCreateToTransaction.

func (*MockHCPClusterCRUDMockRecorder) AddReplaceToTransaction 

func (mr *MockHCPClusterCRUDMockRecorder) AddReplaceToTransaction(ctx, transaction, newObj, opts any) *MockHCPClusterCRUDAddReplaceToTransactionCall

AddReplaceToTransaction indicates an expected call of AddReplaceToTransaction.

func (*MockHCPClusterCRUDMockRecorder) Controllers 

func (mr *MockHCPClusterCRUDMockRecorder) Controllers(hcpClusterID any) *MockHCPClusterCRUDControllersCall

Controllers indicates an expected call of Controllers.

func (*MockHCPClusterCRUDMockRecorder) Create 

func (mr *MockHCPClusterCRUDMockRecorder) Create(ctx, newObj, options any) *MockHCPClusterCRUDCreateCall

Create indicates an expected call of Create.

func (*MockHCPClusterCRUDMockRecorder) Delete 

func (mr *MockHCPClusterCRUDMockRecorder) Delete(ctx, resourceID any) *MockHCPClusterCRUDDeleteCall

Delete indicates an expected call of Delete.

func (*MockHCPClusterCRUDMockRecorder) ExternalAuth 

func (mr *MockHCPClusterCRUDMockRecorder) ExternalAuth(hcpClusterID any) *MockHCPClusterCRUDExternalAuthCall

ExternalAuth indicates an expected call of ExternalAuth.

func (*MockHCPClusterCRUDMockRecorder) Get 

func (mr *MockHCPClusterCRUDMockRecorder) Get(ctx, resourceID any) *MockHCPClusterCRUDGetCall

Get indicates an expected call of Get.

func (*MockHCPClusterCRUDMockRecorder) GetByID 

func (mr *MockHCPClusterCRUDMockRecorder) GetByID(ctx, cosmosID any) *MockHCPClusterCRUDGetByIDCall

GetByID indicates an expected call of GetByID.

func (*MockHCPClusterCRUDMockRecorder) List 

func (mr *MockHCPClusterCRUDMockRecorder) List(ctx, opts any) *MockHCPClusterCRUDListCall

List indicates an expected call of List.

func (*MockHCPClusterCRUDMockRecorder) NodePools 

func (mr *MockHCPClusterCRUDMockRecorder) NodePools(hcpClusterID any) *MockHCPClusterCRUDNodePoolsCall

NodePools indicates an expected call of NodePools.

func (*MockHCPClusterCRUDMockRecorder) Replace 

func (mr *MockHCPClusterCRUDMockRecorder) Replace(ctx, newObj, options any) *MockHCPClusterCRUDReplaceCall

Replace indicates an expected call of Replace.

type MockHCPClusterCRUDNodePoolsCall 

type MockHCPClusterCRUDNodePoolsCall struct {
	*gomock.Call
}

MockHCPClusterCRUDNodePoolsCall wrap *gomock.Call

func (*MockHCPClusterCRUDNodePoolsCall) Do 

func (c *MockHCPClusterCRUDNodePoolsCall) Do(f func(string) NodePoolsCRUD) *MockHCPClusterCRUDNodePoolsCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDNodePoolsCall) DoAndReturn 

func (c *MockHCPClusterCRUDNodePoolsCall) DoAndReturn(f func(string) NodePoolsCRUD) *MockHCPClusterCRUDNodePoolsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDNodePoolsCall) Return 

func (c *MockHCPClusterCRUDNodePoolsCall) Return(arg0 NodePoolsCRUD) *MockHCPClusterCRUDNodePoolsCall

Return rewrite *gomock.Call.Return

type MockHCPClusterCRUDReplaceCall 

type MockHCPClusterCRUDReplaceCall struct {
	*gomock.Call
}

MockHCPClusterCRUDReplaceCall wrap *gomock.Call

func (*MockHCPClusterCRUDReplaceCall) Do 

func (c *MockHCPClusterCRUDReplaceCall) Do(f func(context.Context, *api.HCPOpenShiftCluster, *azcosmos.ItemOptions) (*api.HCPOpenShiftCluster, error)) *MockHCPClusterCRUDReplaceCall

Do rewrite *gomock.Call.Do

func (*MockHCPClusterCRUDReplaceCall) DoAndReturn 

func (c *MockHCPClusterCRUDReplaceCall) DoAndReturn(f func(context.Context, *api.HCPOpenShiftCluster, *azcosmos.ItemOptions) (*api.HCPOpenShiftCluster, error)) *MockHCPClusterCRUDReplaceCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHCPClusterCRUDReplaceCall) Return 

func (c *MockHCPClusterCRUDReplaceCall) Return(arg0 *api.HCPOpenShiftCluster, arg1 error) *MockHCPClusterCRUDReplaceCall

Return rewrite *gomock.Call.Return

type MockLockClientInterface 

type MockLockClientInterface struct {
	// contains filtered or unexported fields
}

MockLockClientInterface is a mock of LockClientInterface interface.

func NewMockLockClientInterface 

func NewMockLockClientInterface(ctrl *gomock.Controller) *MockLockClientInterface

NewMockLockClientInterface creates a new mock instance.

func (*MockLockClientInterface) AcquireLock 

func (m *MockLockClientInterface) AcquireLock(ctx context.Context, id string, timeout *time.Duration) (*azcosmos.ItemResponse, error)

AcquireLock mocks base method.

func (*MockLockClientInterface) EXPECT 

func (m *MockLockClientInterface) EXPECT() *MockLockClientInterfaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLockClientInterface) GetDefaultTimeToLive 

func (m *MockLockClientInterface) GetDefaultTimeToLive() time.Duration

GetDefaultTimeToLive mocks base method.

func (*MockLockClientInterface) HoldLock 

func (m *MockLockClientInterface) HoldLock(ctx context.Context, item *azcosmos.ItemResponse) (context.Context, StopHoldLock)

HoldLock mocks base method.

func (*MockLockClientInterface) ReleaseLock 

func (m *MockLockClientInterface) ReleaseLock(ctx context.Context, item *azcosmos.ItemResponse) error

ReleaseLock mocks base method.

func (*MockLockClientInterface) RenewLock 

func (m *MockLockClientInterface) RenewLock(ctx context.Context, item *azcosmos.ItemResponse) (*azcosmos.ItemResponse, error)

RenewLock mocks base method.

func (*MockLockClientInterface) SetRetryAfterHeader 

func (m *MockLockClientInterface) SetRetryAfterHeader(header http.Header)

SetRetryAfterHeader mocks base method.

func (*MockLockClientInterface) TryAcquireLock 

func (m *MockLockClientInterface) TryAcquireLock(ctx context.Context, id string) (*azcosmos.ItemResponse, error)

TryAcquireLock mocks base method.

type MockLockClientInterfaceAcquireLockCall 

type MockLockClientInterfaceAcquireLockCall struct {
	*gomock.Call
}

MockLockClientInterfaceAcquireLockCall wrap *gomock.Call

func (*MockLockClientInterfaceAcquireLockCall) Do 

func (c *MockLockClientInterfaceAcquireLockCall) Do(f func(context.Context, string, *time.Duration) (*azcosmos.ItemResponse, error)) *MockLockClientInterfaceAcquireLockCall

Do rewrite *gomock.Call.Do

func (*MockLockClientInterfaceAcquireLockCall) DoAndReturn 

func (c *MockLockClientInterfaceAcquireLockCall) DoAndReturn(f func(context.Context, string, *time.Duration) (*azcosmos.ItemResponse, error)) *MockLockClientInterfaceAcquireLockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockLockClientInterfaceAcquireLockCall) Return 

func (c *MockLockClientInterfaceAcquireLockCall) Return(arg0 *azcosmos.ItemResponse, arg1 error) *MockLockClientInterfaceAcquireLockCall

Return rewrite *gomock.Call.Return

type MockLockClientInterfaceGetDefaultTimeToLiveCall 

type MockLockClientInterfaceGetDefaultTimeToLiveCall struct {
	*gomock.Call
}

MockLockClientInterfaceGetDefaultTimeToLiveCall wrap *gomock.Call

func (*MockLockClientInterfaceGetDefaultTimeToLiveCall) Do 

func (c *MockLockClientInterfaceGetDefaultTimeToLiveCall) Do(f func() time.Duration) *MockLockClientInterfaceGetDefaultTimeToLiveCall

Do rewrite *gomock.Call.Do

func (*MockLockClientInterfaceGetDefaultTimeToLiveCall) DoAndReturn 

func (c *MockLockClientInterfaceGetDefaultTimeToLiveCall) DoAndReturn(f func() time.Duration) *MockLockClientInterfaceGetDefaultTimeToLiveCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockLockClientInterfaceGetDefaultTimeToLiveCall) Return 

func (c *MockLockClientInterfaceGetDefaultTimeToLiveCall) Return(arg0 time.Duration) *MockLockClientInterfaceGetDefaultTimeToLiveCall

Return rewrite *gomock.Call.Return

type MockLockClientInterfaceHoldLockCall 

type MockLockClientInterfaceHoldLockCall struct {
	*gomock.Call
}

MockLockClientInterfaceHoldLockCall wrap *gomock.Call

func (*MockLockClientInterfaceHoldLockCall) Do 

func (c *MockLockClientInterfaceHoldLockCall) Do(f func(context.Context, *azcosmos.ItemResponse) (context.Context, StopHoldLock)) *MockLockClientInterfaceHoldLockCall

Do rewrite *gomock.Call.Do

func (*MockLockClientInterfaceHoldLockCall) DoAndReturn 

func (c *MockLockClientInterfaceHoldLockCall) DoAndReturn(f func(context.Context, *azcosmos.ItemResponse) (context.Context, StopHoldLock)) *MockLockClientInterfaceHoldLockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockLockClientInterfaceHoldLockCall) Return 

func (c *MockLockClientInterfaceHoldLockCall) Return(arg0 context.Context, arg1 StopHoldLock) *MockLockClientInterfaceHoldLockCall

Return rewrite *gomock.Call.Return

type MockLockClientInterfaceMockRecorder 

type MockLockClientInterfaceMockRecorder struct {
	// contains filtered or unexported fields
}

MockLockClientInterfaceMockRecorder is the mock recorder for MockLockClientInterface.

func (*MockLockClientInterfaceMockRecorder) AcquireLock 

func (mr *MockLockClientInterfaceMockRecorder) AcquireLock(ctx, id, timeout any) *MockLockClientInterfaceAcquireLockCall

AcquireLock indicates an expected call of AcquireLock.

func (*MockLockClientInterfaceMockRecorder) GetDefaultTimeToLive 

func (mr *MockLockClientInterfaceMockRecorder) GetDefaultTimeToLive() *MockLockClientInterfaceGetDefaultTimeToLiveCall

GetDefaultTimeToLive indicates an expected call of GetDefaultTimeToLive.

func (*MockLockClientInterfaceMockRecorder) HoldLock 

func (mr *MockLockClientInterfaceMockRecorder) HoldLock(ctx, item any) *MockLockClientInterfaceHoldLockCall

HoldLock indicates an expected call of HoldLock.

func (*MockLockClientInterfaceMockRecorder) ReleaseLock 

func (mr *MockLockClientInterfaceMockRecorder) ReleaseLock(ctx, item any) *MockLockClientInterfaceReleaseLockCall

ReleaseLock indicates an expected call of ReleaseLock.

func (*MockLockClientInterfaceMockRecorder) RenewLock 

func (mr *MockLockClientInterfaceMockRecorder) RenewLock(ctx, item any) *MockLockClientInterfaceRenewLockCall

RenewLock indicates an expected call of RenewLock.

func (*MockLockClientInterfaceMockRecorder) SetRetryAfterHeader 

func (mr *MockLockClientInterfaceMockRecorder) SetRetryAfterHeader(header any) *MockLockClientInterfaceSetRetryAfterHeaderCall

SetRetryAfterHeader indicates an expected call of SetRetryAfterHeader.

func (*MockLockClientInterfaceMockRecorder) TryAcquireLock 

func (mr *MockLockClientInterfaceMockRecorder) TryAcquireLock(ctx, id any) *MockLockClientInterfaceTryAcquireLockCall

TryAcquireLock indicates an expected call of TryAcquireLock.

type MockLockClientInterfaceReleaseLockCall 

type MockLockClientInterfaceReleaseLockCall struct {
	*gomock.Call
}

MockLockClientInterfaceReleaseLockCall wrap *gomock.Call

func (*MockLockClientInterfaceReleaseLockCall) Do 

func (c *MockLockClientInterfaceReleaseLockCall) Do(f func(context.Context, *azcosmos.ItemResponse) error) *MockLockClientInterfaceReleaseLockCall

Do rewrite *gomock.Call.Do

func (*MockLockClientInterfaceReleaseLockCall) DoAndReturn 

func (c *MockLockClientInterfaceReleaseLockCall) DoAndReturn(f func(context.Context, *azcosmos.ItemResponse) error) *MockLockClientInterfaceReleaseLockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockLockClientInterfaceReleaseLockCall) Return 

func (c *MockLockClientInterfaceReleaseLockCall) Return(arg0 error) *MockLockClientInterfaceReleaseLockCall

Return rewrite *gomock.Call.Return

type MockLockClientInterfaceRenewLockCall 

type MockLockClientInterfaceRenewLockCall struct {
	*gomock.Call
}

MockLockClientInterfaceRenewLockCall wrap *gomock.Call

func (*MockLockClientInterfaceRenewLockCall) Do 

func (c *MockLockClientInterfaceRenewLockCall) Do(f func(context.Context, *azcosmos.ItemResponse) (*azcosmos.ItemResponse, error)) *MockLockClientInterfaceRenewLockCall

Do rewrite *gomock.Call.Do

func (*MockLockClientInterfaceRenewLockCall) DoAndReturn 

func (c *MockLockClientInterfaceRenewLockCall) DoAndReturn(f func(context.Context, *azcosmos.ItemResponse) (*azcosmos.ItemResponse, error)) *MockLockClientInterfaceRenewLockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockLockClientInterfaceRenewLockCall) Return 

func (c *MockLockClientInterfaceRenewLockCall) Return(arg0 *azcosmos.ItemResponse, arg1 error) *MockLockClientInterfaceRenewLockCall

Return rewrite *gomock.Call.Return

type MockLockClientInterfaceSetRetryAfterHeaderCall 

type MockLockClientInterfaceSetRetryAfterHeaderCall struct {
	*gomock.Call
}

MockLockClientInterfaceSetRetryAfterHeaderCall wrap *gomock.Call

func (*MockLockClientInterfaceSetRetryAfterHeaderCall) Do 

func (c *MockLockClientInterfaceSetRetryAfterHeaderCall) Do(f func(http.Header)) *MockLockClientInterfaceSetRetryAfterHeaderCall

Do rewrite *gomock.Call.Do

func (*MockLockClientInterfaceSetRetryAfterHeaderCall) DoAndReturn 

func (c *MockLockClientInterfaceSetRetryAfterHeaderCall) DoAndReturn(f func(http.Header)) *MockLockClientInterfaceSetRetryAfterHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockLockClientInterfaceSetRetryAfterHeaderCall) Return 

func (c *MockLockClientInterfaceSetRetryAfterHeaderCall) Return() *MockLockClientInterfaceSetRetryAfterHeaderCall

Return rewrite *gomock.Call.Return

type MockLockClientInterfaceTryAcquireLockCall 

type MockLockClientInterfaceTryAcquireLockCall struct {
	*gomock.Call
}

MockLockClientInterfaceTryAcquireLockCall wrap *gomock.Call

func (*MockLockClientInterfaceTryAcquireLockCall) Do 

func (c *MockLockClientInterfaceTryAcquireLockCall) Do(f func(context.Context, string) (*azcosmos.ItemResponse, error)) *MockLockClientInterfaceTryAcquireLockCall

Do rewrite *gomock.Call.Do

func (*MockLockClientInterfaceTryAcquireLockCall) DoAndReturn 

func (c *MockLockClientInterfaceTryAcquireLockCall) DoAndReturn(f func(context.Context, string) (*azcosmos.ItemResponse, error)) *MockLockClientInterfaceTryAcquireLockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockLockClientInterfaceTryAcquireLockCall) Return 

func (c *MockLockClientInterfaceTryAcquireLockCall) Return(arg0 *azcosmos.ItemResponse, arg1 error) *MockLockClientInterfaceTryAcquireLockCall

Return rewrite *gomock.Call.Return

type MockManagementClusterContentCRUD 

type MockManagementClusterContentCRUD struct {
	// contains filtered or unexported fields
}

MockManagementClusterContentCRUD is a mock of ManagementClusterContentCRUD interface.

func NewMockManagementClusterContentCRUD 

func NewMockManagementClusterContentCRUD(ctrl *gomock.Controller) *MockManagementClusterContentCRUD

NewMockManagementClusterContentCRUD creates a new mock instance.

func (*MockManagementClusterContentCRUD) AddCreateToTransaction 

func (m *MockManagementClusterContentCRUD) AddCreateToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.ManagementClusterContent, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddCreateToTransaction mocks base method.

func (*MockManagementClusterContentCRUD) AddReplaceToTransaction 

func (m *MockManagementClusterContentCRUD) AddReplaceToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.ManagementClusterContent, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddReplaceToTransaction mocks base method.

func (*MockManagementClusterContentCRUD) Create 

func (m *MockManagementClusterContentCRUD) Create(ctx context.Context, newObj *api.ManagementClusterContent, options *azcosmos.ItemOptions) (*api.ManagementClusterContent, error)

Create mocks base method.

func (*MockManagementClusterContentCRUD) Delete 

func (m *MockManagementClusterContentCRUD) Delete(ctx context.Context, resourceID string) error

Delete mocks base method.

func (*MockManagementClusterContentCRUD) EXPECT 

func (m *MockManagementClusterContentCRUD) EXPECT() *MockManagementClusterContentCRUDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockManagementClusterContentCRUD) Get 

func (m *MockManagementClusterContentCRUD) Get(ctx context.Context, resourceID string) (*api.ManagementClusterContent, error)

Get mocks base method.

func (*MockManagementClusterContentCRUD) GetByID 

func (m *MockManagementClusterContentCRUD) GetByID(ctx context.Context, cosmosID string) (*api.ManagementClusterContent, error)

GetByID mocks base method.

func (*MockManagementClusterContentCRUD) List 

func (m *MockManagementClusterContentCRUD) List(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[api.ManagementClusterContent], error)

List mocks base method.

func (*MockManagementClusterContentCRUD) Replace 

func (m *MockManagementClusterContentCRUD) Replace(ctx context.Context, newObj *api.ManagementClusterContent, options *azcosmos.ItemOptions) (*api.ManagementClusterContent, error)

Replace mocks base method.

type MockManagementClusterContentCRUDAddCreateToTransactionCall 

type MockManagementClusterContentCRUDAddCreateToTransactionCall struct {
	*gomock.Call
}

MockManagementClusterContentCRUDAddCreateToTransactionCall wrap *gomock.Call

func (*MockManagementClusterContentCRUDAddCreateToTransactionCall) Do 

func (c *MockManagementClusterContentCRUDAddCreateToTransactionCall) Do(f func(context.Context, DBTransaction, *api.ManagementClusterContent, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockManagementClusterContentCRUDAddCreateToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockManagementClusterContentCRUDAddCreateToTransactionCall) DoAndReturn 

func (c *MockManagementClusterContentCRUDAddCreateToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.ManagementClusterContent, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockManagementClusterContentCRUDAddCreateToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockManagementClusterContentCRUDAddCreateToTransactionCall) Return 

func (c *MockManagementClusterContentCRUDAddCreateToTransactionCall) Return(arg0 string, arg1 error) *MockManagementClusterContentCRUDAddCreateToTransactionCall

Return rewrite *gomock.Call.Return

type MockManagementClusterContentCRUDAddReplaceToTransactionCall 

type MockManagementClusterContentCRUDAddReplaceToTransactionCall struct {
	*gomock.Call
}

MockManagementClusterContentCRUDAddReplaceToTransactionCall wrap *gomock.Call

func (*MockManagementClusterContentCRUDAddReplaceToTransactionCall) Do 

func (c *MockManagementClusterContentCRUDAddReplaceToTransactionCall) Do(f func(context.Context, DBTransaction, *api.ManagementClusterContent, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockManagementClusterContentCRUDAddReplaceToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockManagementClusterContentCRUDAddReplaceToTransactionCall) DoAndReturn 

func (c *MockManagementClusterContentCRUDAddReplaceToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.ManagementClusterContent, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockManagementClusterContentCRUDAddReplaceToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockManagementClusterContentCRUDAddReplaceToTransactionCall) Return 

func (c *MockManagementClusterContentCRUDAddReplaceToTransactionCall) Return(arg0 string, arg1 error) *MockManagementClusterContentCRUDAddReplaceToTransactionCall

Return rewrite *gomock.Call.Return

type MockManagementClusterContentCRUDCreateCall 

type MockManagementClusterContentCRUDCreateCall struct {
	*gomock.Call
}

MockManagementClusterContentCRUDCreateCall wrap *gomock.Call

func (*MockManagementClusterContentCRUDCreateCall) Do 

func (c *MockManagementClusterContentCRUDCreateCall) Do(f func(context.Context, *api.ManagementClusterContent, *azcosmos.ItemOptions) (*api.ManagementClusterContent, error)) *MockManagementClusterContentCRUDCreateCall

Do rewrite *gomock.Call.Do

func (*MockManagementClusterContentCRUDCreateCall) DoAndReturn 

func (c *MockManagementClusterContentCRUDCreateCall) DoAndReturn(f func(context.Context, *api.ManagementClusterContent, *azcosmos.ItemOptions) (*api.ManagementClusterContent, error)) *MockManagementClusterContentCRUDCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockManagementClusterContentCRUDCreateCall) Return 

func (c *MockManagementClusterContentCRUDCreateCall) Return(arg0 *api.ManagementClusterContent, arg1 error) *MockManagementClusterContentCRUDCreateCall

Return rewrite *gomock.Call.Return

type MockManagementClusterContentCRUDDeleteCall 

type MockManagementClusterContentCRUDDeleteCall struct {
	*gomock.Call
}

MockManagementClusterContentCRUDDeleteCall wrap *gomock.Call

func (*MockManagementClusterContentCRUDDeleteCall) Do 

func (c *MockManagementClusterContentCRUDDeleteCall) Do(f func(context.Context, string) error) *MockManagementClusterContentCRUDDeleteCall

Do rewrite *gomock.Call.Do

func (*MockManagementClusterContentCRUDDeleteCall) DoAndReturn 

func (c *MockManagementClusterContentCRUDDeleteCall) DoAndReturn(f func(context.Context, string) error) *MockManagementClusterContentCRUDDeleteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockManagementClusterContentCRUDDeleteCall) Return 

func (c *MockManagementClusterContentCRUDDeleteCall) Return(arg0 error) *MockManagementClusterContentCRUDDeleteCall

Return rewrite *gomock.Call.Return

type MockManagementClusterContentCRUDGetByIDCall 

type MockManagementClusterContentCRUDGetByIDCall struct {
	*gomock.Call
}

MockManagementClusterContentCRUDGetByIDCall wrap *gomock.Call

func (*MockManagementClusterContentCRUDGetByIDCall) Do 

func (c *MockManagementClusterContentCRUDGetByIDCall) Do(f func(context.Context, string) (*api.ManagementClusterContent, error)) *MockManagementClusterContentCRUDGetByIDCall

Do rewrite *gomock.Call.Do

func (*MockManagementClusterContentCRUDGetByIDCall) DoAndReturn 

func (c *MockManagementClusterContentCRUDGetByIDCall) DoAndReturn(f func(context.Context, string) (*api.ManagementClusterContent, error)) *MockManagementClusterContentCRUDGetByIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockManagementClusterContentCRUDGetByIDCall) Return 

func (c *MockManagementClusterContentCRUDGetByIDCall) Return(arg0 *api.ManagementClusterContent, arg1 error) *MockManagementClusterContentCRUDGetByIDCall

Return rewrite *gomock.Call.Return

type MockManagementClusterContentCRUDGetCall 

type MockManagementClusterContentCRUDGetCall struct {
	*gomock.Call
}

MockManagementClusterContentCRUDGetCall wrap *gomock.Call

func (*MockManagementClusterContentCRUDGetCall) Do 

func (c *MockManagementClusterContentCRUDGetCall) Do(f func(context.Context, string) (*api.ManagementClusterContent, error)) *MockManagementClusterContentCRUDGetCall

Do rewrite *gomock.Call.Do

func (*MockManagementClusterContentCRUDGetCall) DoAndReturn 

func (c *MockManagementClusterContentCRUDGetCall) DoAndReturn(f func(context.Context, string) (*api.ManagementClusterContent, error)) *MockManagementClusterContentCRUDGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockManagementClusterContentCRUDGetCall) Return 

func (c *MockManagementClusterContentCRUDGetCall) Return(arg0 *api.ManagementClusterContent, arg1 error) *MockManagementClusterContentCRUDGetCall

Return rewrite *gomock.Call.Return

type MockManagementClusterContentCRUDListCall 

type MockManagementClusterContentCRUDListCall struct {
	*gomock.Call
}

MockManagementClusterContentCRUDListCall wrap *gomock.Call

func (*MockManagementClusterContentCRUDListCall) Do 

func (c *MockManagementClusterContentCRUDListCall) Do(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.ManagementClusterContent], error)) *MockManagementClusterContentCRUDListCall

Do rewrite *gomock.Call.Do

func (*MockManagementClusterContentCRUDListCall) DoAndReturn 

func (c *MockManagementClusterContentCRUDListCall) DoAndReturn(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.ManagementClusterContent], error)) *MockManagementClusterContentCRUDListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockManagementClusterContentCRUDListCall) Return 

func (c *MockManagementClusterContentCRUDListCall) Return(arg0 DBClientIterator[api.ManagementClusterContent], arg1 error) *MockManagementClusterContentCRUDListCall

Return rewrite *gomock.Call.Return

type MockManagementClusterContentCRUDMockRecorder 

type MockManagementClusterContentCRUDMockRecorder struct {
	// contains filtered or unexported fields
}

MockManagementClusterContentCRUDMockRecorder is the mock recorder for MockManagementClusterContentCRUD.

func (*MockManagementClusterContentCRUDMockRecorder) AddCreateToTransaction 

func (mr *MockManagementClusterContentCRUDMockRecorder) AddCreateToTransaction(ctx, transaction, newObj, opts any) *MockManagementClusterContentCRUDAddCreateToTransactionCall

AddCreateToTransaction indicates an expected call of AddCreateToTransaction.

func (*MockManagementClusterContentCRUDMockRecorder) AddReplaceToTransaction 

func (mr *MockManagementClusterContentCRUDMockRecorder) AddReplaceToTransaction(ctx, transaction, newObj, opts any) *MockManagementClusterContentCRUDAddReplaceToTransactionCall

AddReplaceToTransaction indicates an expected call of AddReplaceToTransaction.

func (*MockManagementClusterContentCRUDMockRecorder) Create 

func (mr *MockManagementClusterContentCRUDMockRecorder) Create(ctx, newObj, options any) *MockManagementClusterContentCRUDCreateCall

Create indicates an expected call of Create.

func (*MockManagementClusterContentCRUDMockRecorder) Delete 

func (mr *MockManagementClusterContentCRUDMockRecorder) Delete(ctx, resourceID any) *MockManagementClusterContentCRUDDeleteCall

Delete indicates an expected call of Delete.

func (*MockManagementClusterContentCRUDMockRecorder) Get 

func (mr *MockManagementClusterContentCRUDMockRecorder) Get(ctx, resourceID any) *MockManagementClusterContentCRUDGetCall

Get indicates an expected call of Get.

func (*MockManagementClusterContentCRUDMockRecorder) GetByID 

func (mr *MockManagementClusterContentCRUDMockRecorder) GetByID(ctx, cosmosID any) *MockManagementClusterContentCRUDGetByIDCall

GetByID indicates an expected call of GetByID.

func (*MockManagementClusterContentCRUDMockRecorder) List 

func (mr *MockManagementClusterContentCRUDMockRecorder) List(ctx, opts any) *MockManagementClusterContentCRUDListCall

List indicates an expected call of List.

func (*MockManagementClusterContentCRUDMockRecorder) Replace 

func (mr *MockManagementClusterContentCRUDMockRecorder) Replace(ctx, newObj, options any) *MockManagementClusterContentCRUDReplaceCall

Replace indicates an expected call of Replace.

type MockManagementClusterContentCRUDReplaceCall 

type MockManagementClusterContentCRUDReplaceCall struct {
	*gomock.Call
}

MockManagementClusterContentCRUDReplaceCall wrap *gomock.Call

func (*MockManagementClusterContentCRUDReplaceCall) Do 

func (c *MockManagementClusterContentCRUDReplaceCall) Do(f func(context.Context, *api.ManagementClusterContent, *azcosmos.ItemOptions) (*api.ManagementClusterContent, error)) *MockManagementClusterContentCRUDReplaceCall

Do rewrite *gomock.Call.Do

func (*MockManagementClusterContentCRUDReplaceCall) DoAndReturn 

func (c *MockManagementClusterContentCRUDReplaceCall) DoAndReturn(f func(context.Context, *api.ManagementClusterContent, *azcosmos.ItemOptions) (*api.ManagementClusterContent, error)) *MockManagementClusterContentCRUDReplaceCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockManagementClusterContentCRUDReplaceCall) Return 

func (c *MockManagementClusterContentCRUDReplaceCall) Return(arg0 *api.ManagementClusterContent, arg1 error) *MockManagementClusterContentCRUDReplaceCall

Return rewrite *gomock.Call.Return

type MockNodePoolsCRUD 

type MockNodePoolsCRUD struct {
	// contains filtered or unexported fields
}

MockNodePoolsCRUD is a mock of NodePoolsCRUD interface.

func NewMockNodePoolsCRUD 

func NewMockNodePoolsCRUD(ctrl *gomock.Controller) *MockNodePoolsCRUD

NewMockNodePoolsCRUD creates a new mock instance.

func (*MockNodePoolsCRUD) AddCreateToTransaction 

func (m *MockNodePoolsCRUD) AddCreateToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.HCPOpenShiftClusterNodePool, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddCreateToTransaction mocks base method.

func (*MockNodePoolsCRUD) AddReplaceToTransaction 

func (m *MockNodePoolsCRUD) AddReplaceToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.HCPOpenShiftClusterNodePool, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddReplaceToTransaction mocks base method.

func (*MockNodePoolsCRUD) Controllers 

func (m *MockNodePoolsCRUD) Controllers(hcpClusterID string) ResourceCRUD[api.Controller]

Controllers mocks base method.

func (*MockNodePoolsCRUD) Create 

func (m *MockNodePoolsCRUD) Create(ctx context.Context, newObj *api.HCPOpenShiftClusterNodePool, options *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterNodePool, error)

Create mocks base method.

func (*MockNodePoolsCRUD) Delete 

func (m *MockNodePoolsCRUD) Delete(ctx context.Context, resourceID string) error

Delete mocks base method.

func (*MockNodePoolsCRUD) EXPECT 

func (m *MockNodePoolsCRUD) EXPECT() *MockNodePoolsCRUDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNodePoolsCRUD) Get 

func (m *MockNodePoolsCRUD) Get(ctx context.Context, resourceID string) (*api.HCPOpenShiftClusterNodePool, error)

Get mocks base method.

func (*MockNodePoolsCRUD) GetByID 

func (m *MockNodePoolsCRUD) GetByID(ctx context.Context, cosmosID string) (*api.HCPOpenShiftClusterNodePool, error)

GetByID mocks base method.

func (*MockNodePoolsCRUD) List 

func (m *MockNodePoolsCRUD) List(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[api.HCPOpenShiftClusterNodePool], error)

List mocks base method.

func (*MockNodePoolsCRUD) Replace 

func (m *MockNodePoolsCRUD) Replace(ctx context.Context, newObj *api.HCPOpenShiftClusterNodePool, options *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterNodePool, error)

Replace mocks base method.

type MockNodePoolsCRUDAddCreateToTransactionCall 

type MockNodePoolsCRUDAddCreateToTransactionCall struct {
	*gomock.Call
}

MockNodePoolsCRUDAddCreateToTransactionCall wrap *gomock.Call

func (*MockNodePoolsCRUDAddCreateToTransactionCall) Do 

func (c *MockNodePoolsCRUDAddCreateToTransactionCall) Do(f func(context.Context, DBTransaction, *api.HCPOpenShiftClusterNodePool, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockNodePoolsCRUDAddCreateToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockNodePoolsCRUDAddCreateToTransactionCall) DoAndReturn 

func (c *MockNodePoolsCRUDAddCreateToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.HCPOpenShiftClusterNodePool, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockNodePoolsCRUDAddCreateToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockNodePoolsCRUDAddCreateToTransactionCall) Return 

func (c *MockNodePoolsCRUDAddCreateToTransactionCall) Return(arg0 string, arg1 error) *MockNodePoolsCRUDAddCreateToTransactionCall

Return rewrite *gomock.Call.Return

type MockNodePoolsCRUDAddReplaceToTransactionCall 

type MockNodePoolsCRUDAddReplaceToTransactionCall struct {
	*gomock.Call
}

MockNodePoolsCRUDAddReplaceToTransactionCall wrap *gomock.Call

func (*MockNodePoolsCRUDAddReplaceToTransactionCall) Do 

func (c *MockNodePoolsCRUDAddReplaceToTransactionCall) Do(f func(context.Context, DBTransaction, *api.HCPOpenShiftClusterNodePool, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockNodePoolsCRUDAddReplaceToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockNodePoolsCRUDAddReplaceToTransactionCall) DoAndReturn 

func (c *MockNodePoolsCRUDAddReplaceToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.HCPOpenShiftClusterNodePool, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockNodePoolsCRUDAddReplaceToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockNodePoolsCRUDAddReplaceToTransactionCall) Return 

func (c *MockNodePoolsCRUDAddReplaceToTransactionCall) Return(arg0 string, arg1 error) *MockNodePoolsCRUDAddReplaceToTransactionCall

Return rewrite *gomock.Call.Return

type MockNodePoolsCRUDControllersCall 

type MockNodePoolsCRUDControllersCall struct {
	*gomock.Call
}

MockNodePoolsCRUDControllersCall wrap *gomock.Call

func (*MockNodePoolsCRUDControllersCall) Do 

func (c *MockNodePoolsCRUDControllersCall) Do(f func(string) ResourceCRUD[api.Controller]) *MockNodePoolsCRUDControllersCall

Do rewrite *gomock.Call.Do

func (*MockNodePoolsCRUDControllersCall) DoAndReturn 

func (c *MockNodePoolsCRUDControllersCall) DoAndReturn(f func(string) ResourceCRUD[api.Controller]) *MockNodePoolsCRUDControllersCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockNodePoolsCRUDControllersCall) Return 

func (c *MockNodePoolsCRUDControllersCall) Return(arg0 ResourceCRUD[api.Controller]) *MockNodePoolsCRUDControllersCall

Return rewrite *gomock.Call.Return

type MockNodePoolsCRUDCreateCall 

type MockNodePoolsCRUDCreateCall struct {
	*gomock.Call
}

MockNodePoolsCRUDCreateCall wrap *gomock.Call

func (*MockNodePoolsCRUDCreateCall) Do 

func (c *MockNodePoolsCRUDCreateCall) Do(f func(context.Context, *api.HCPOpenShiftClusterNodePool, *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterNodePool, error)) *MockNodePoolsCRUDCreateCall

Do rewrite *gomock.Call.Do

func (*MockNodePoolsCRUDCreateCall) DoAndReturn 

func (c *MockNodePoolsCRUDCreateCall) DoAndReturn(f func(context.Context, *api.HCPOpenShiftClusterNodePool, *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterNodePool, error)) *MockNodePoolsCRUDCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockNodePoolsCRUDCreateCall) Return 

func (c *MockNodePoolsCRUDCreateCall) Return(arg0 *api.HCPOpenShiftClusterNodePool, arg1 error) *MockNodePoolsCRUDCreateCall

Return rewrite *gomock.Call.Return

type MockNodePoolsCRUDDeleteCall 

type MockNodePoolsCRUDDeleteCall struct {
	*gomock.Call
}

MockNodePoolsCRUDDeleteCall wrap *gomock.Call

func (*MockNodePoolsCRUDDeleteCall) Do 

func (c *MockNodePoolsCRUDDeleteCall) Do(f func(context.Context, string) error) *MockNodePoolsCRUDDeleteCall

Do rewrite *gomock.Call.Do

func (*MockNodePoolsCRUDDeleteCall) DoAndReturn 

func (c *MockNodePoolsCRUDDeleteCall) DoAndReturn(f func(context.Context, string) error) *MockNodePoolsCRUDDeleteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockNodePoolsCRUDDeleteCall) Return 

func (c *MockNodePoolsCRUDDeleteCall) Return(arg0 error) *MockNodePoolsCRUDDeleteCall

Return rewrite *gomock.Call.Return

type MockNodePoolsCRUDGetByIDCall 

type MockNodePoolsCRUDGetByIDCall struct {
	*gomock.Call
}

MockNodePoolsCRUDGetByIDCall wrap *gomock.Call

func (*MockNodePoolsCRUDGetByIDCall) Do 

func (c *MockNodePoolsCRUDGetByIDCall) Do(f func(context.Context, string) (*api.HCPOpenShiftClusterNodePool, error)) *MockNodePoolsCRUDGetByIDCall

Do rewrite *gomock.Call.Do

func (*MockNodePoolsCRUDGetByIDCall) DoAndReturn 

func (c *MockNodePoolsCRUDGetByIDCall) DoAndReturn(f func(context.Context, string) (*api.HCPOpenShiftClusterNodePool, error)) *MockNodePoolsCRUDGetByIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockNodePoolsCRUDGetByIDCall) Return 

func (c *MockNodePoolsCRUDGetByIDCall) Return(arg0 *api.HCPOpenShiftClusterNodePool, arg1 error) *MockNodePoolsCRUDGetByIDCall

Return rewrite *gomock.Call.Return

type MockNodePoolsCRUDGetCall 

type MockNodePoolsCRUDGetCall struct {
	*gomock.Call
}

MockNodePoolsCRUDGetCall wrap *gomock.Call

func (*MockNodePoolsCRUDGetCall) Do 

func (c *MockNodePoolsCRUDGetCall) Do(f func(context.Context, string) (*api.HCPOpenShiftClusterNodePool, error)) *MockNodePoolsCRUDGetCall

Do rewrite *gomock.Call.Do

func (*MockNodePoolsCRUDGetCall) DoAndReturn 

func (c *MockNodePoolsCRUDGetCall) DoAndReturn(f func(context.Context, string) (*api.HCPOpenShiftClusterNodePool, error)) *MockNodePoolsCRUDGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockNodePoolsCRUDGetCall) Return 

func (c *MockNodePoolsCRUDGetCall) Return(arg0 *api.HCPOpenShiftClusterNodePool, arg1 error) *MockNodePoolsCRUDGetCall

Return rewrite *gomock.Call.Return

type MockNodePoolsCRUDListCall 

type MockNodePoolsCRUDListCall struct {
	*gomock.Call
}

MockNodePoolsCRUDListCall wrap *gomock.Call

func (*MockNodePoolsCRUDListCall) Do 

func (c *MockNodePoolsCRUDListCall) Do(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.HCPOpenShiftClusterNodePool], error)) *MockNodePoolsCRUDListCall

Do rewrite *gomock.Call.Do

func (*MockNodePoolsCRUDListCall) DoAndReturn 

func (c *MockNodePoolsCRUDListCall) DoAndReturn(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.HCPOpenShiftClusterNodePool], error)) *MockNodePoolsCRUDListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockNodePoolsCRUDListCall) Return 

func (c *MockNodePoolsCRUDListCall) Return(arg0 DBClientIterator[api.HCPOpenShiftClusterNodePool], arg1 error) *MockNodePoolsCRUDListCall

Return rewrite *gomock.Call.Return

type MockNodePoolsCRUDMockRecorder 

type MockNodePoolsCRUDMockRecorder struct {
	// contains filtered or unexported fields
}

MockNodePoolsCRUDMockRecorder is the mock recorder for MockNodePoolsCRUD.

func (*MockNodePoolsCRUDMockRecorder) AddCreateToTransaction 

func (mr *MockNodePoolsCRUDMockRecorder) AddCreateToTransaction(ctx, transaction, newObj, opts any) *MockNodePoolsCRUDAddCreateToTransactionCall

AddCreateToTransaction indicates an expected call of AddCreateToTransaction.

func (*MockNodePoolsCRUDMockRecorder) AddReplaceToTransaction 

func (mr *MockNodePoolsCRUDMockRecorder) AddReplaceToTransaction(ctx, transaction, newObj, opts any) *MockNodePoolsCRUDAddReplaceToTransactionCall

AddReplaceToTransaction indicates an expected call of AddReplaceToTransaction.

func (*MockNodePoolsCRUDMockRecorder) Controllers 

func (mr *MockNodePoolsCRUDMockRecorder) Controllers(hcpClusterID any) *MockNodePoolsCRUDControllersCall

Controllers indicates an expected call of Controllers.

func (*MockNodePoolsCRUDMockRecorder) Create 

func (mr *MockNodePoolsCRUDMockRecorder) Create(ctx, newObj, options any) *MockNodePoolsCRUDCreateCall

Create indicates an expected call of Create.

func (*MockNodePoolsCRUDMockRecorder) Delete 

func (mr *MockNodePoolsCRUDMockRecorder) Delete(ctx, resourceID any) *MockNodePoolsCRUDDeleteCall

Delete indicates an expected call of Delete.

func (*MockNodePoolsCRUDMockRecorder) Get 

func (mr *MockNodePoolsCRUDMockRecorder) Get(ctx, resourceID any) *MockNodePoolsCRUDGetCall

Get indicates an expected call of Get.

func (*MockNodePoolsCRUDMockRecorder) GetByID 

func (mr *MockNodePoolsCRUDMockRecorder) GetByID(ctx, cosmosID any) *MockNodePoolsCRUDGetByIDCall

GetByID indicates an expected call of GetByID.

func (*MockNodePoolsCRUDMockRecorder) List 

func (mr *MockNodePoolsCRUDMockRecorder) List(ctx, opts any) *MockNodePoolsCRUDListCall

List indicates an expected call of List.

func (*MockNodePoolsCRUDMockRecorder) Replace 

func (mr *MockNodePoolsCRUDMockRecorder) Replace(ctx, newObj, options any) *MockNodePoolsCRUDReplaceCall

Replace indicates an expected call of Replace.

type MockNodePoolsCRUDReplaceCall 

type MockNodePoolsCRUDReplaceCall struct {
	*gomock.Call
}

MockNodePoolsCRUDReplaceCall wrap *gomock.Call

func (*MockNodePoolsCRUDReplaceCall) Do 

func (c *MockNodePoolsCRUDReplaceCall) Do(f func(context.Context, *api.HCPOpenShiftClusterNodePool, *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterNodePool, error)) *MockNodePoolsCRUDReplaceCall

Do rewrite *gomock.Call.Do

func (*MockNodePoolsCRUDReplaceCall) DoAndReturn 

func (c *MockNodePoolsCRUDReplaceCall) DoAndReturn(f func(context.Context, *api.HCPOpenShiftClusterNodePool, *azcosmos.ItemOptions) (*api.HCPOpenShiftClusterNodePool, error)) *MockNodePoolsCRUDReplaceCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockNodePoolsCRUDReplaceCall) Return 

func (c *MockNodePoolsCRUDReplaceCall) Return(arg0 *api.HCPOpenShiftClusterNodePool, arg1 error) *MockNodePoolsCRUDReplaceCall

Return rewrite *gomock.Call.Return

type MockOperationCRUD 

type MockOperationCRUD struct {
	// contains filtered or unexported fields
}

MockOperationCRUD is a mock of OperationCRUD interface.

func NewMockOperationCRUD 

func NewMockOperationCRUD(ctrl *gomock.Controller) *MockOperationCRUD

NewMockOperationCRUD creates a new mock instance.

func (*MockOperationCRUD) AddCreateToTransaction 

func (m *MockOperationCRUD) AddCreateToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.Operation, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddCreateToTransaction mocks base method.

func (*MockOperationCRUD) AddReplaceToTransaction 

func (m *MockOperationCRUD) AddReplaceToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.Operation, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddReplaceToTransaction mocks base method.

func (*MockOperationCRUD) Create 

func (m *MockOperationCRUD) Create(ctx context.Context, newObj *api.Operation, options *azcosmos.ItemOptions) (*api.Operation, error)

Create mocks base method.

func (*MockOperationCRUD) Delete 

func (m *MockOperationCRUD) Delete(ctx context.Context, resourceID string) error

Delete mocks base method.

func (*MockOperationCRUD) EXPECT 

func (m *MockOperationCRUD) EXPECT() *MockOperationCRUDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockOperationCRUD) Get 

func (m *MockOperationCRUD) Get(ctx context.Context, resourceID string) (*api.Operation, error)

Get mocks base method.

func (*MockOperationCRUD) GetByID 

func (m *MockOperationCRUD) GetByID(ctx context.Context, cosmosID string) (*api.Operation, error)

GetByID mocks base method.

func (*MockOperationCRUD) List 

func (m *MockOperationCRUD) List(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[api.Operation], error)

List mocks base method.

func (*MockOperationCRUD) ListActiveOperations 

func (m *MockOperationCRUD) ListActiveOperations(options *DBClientListActiveOperationDocsOptions) DBClientIterator[api.Operation]

ListActiveOperations mocks base method.

func (*MockOperationCRUD) Replace 

func (m *MockOperationCRUD) Replace(ctx context.Context, newObj *api.Operation, options *azcosmos.ItemOptions) (*api.Operation, error)

Replace mocks base method.

type MockOperationCRUDAddCreateToTransactionCall 

type MockOperationCRUDAddCreateToTransactionCall struct {
	*gomock.Call
}

MockOperationCRUDAddCreateToTransactionCall wrap *gomock.Call

func (*MockOperationCRUDAddCreateToTransactionCall) Do 

func (c *MockOperationCRUDAddCreateToTransactionCall) Do(f func(context.Context, DBTransaction, *api.Operation, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockOperationCRUDAddCreateToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockOperationCRUDAddCreateToTransactionCall) DoAndReturn 

func (c *MockOperationCRUDAddCreateToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.Operation, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockOperationCRUDAddCreateToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockOperationCRUDAddCreateToTransactionCall) Return 

func (c *MockOperationCRUDAddCreateToTransactionCall) Return(arg0 string, arg1 error) *MockOperationCRUDAddCreateToTransactionCall

Return rewrite *gomock.Call.Return

type MockOperationCRUDAddReplaceToTransactionCall 

type MockOperationCRUDAddReplaceToTransactionCall struct {
	*gomock.Call
}

MockOperationCRUDAddReplaceToTransactionCall wrap *gomock.Call

func (*MockOperationCRUDAddReplaceToTransactionCall) Do 

func (c *MockOperationCRUDAddReplaceToTransactionCall) Do(f func(context.Context, DBTransaction, *api.Operation, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockOperationCRUDAddReplaceToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockOperationCRUDAddReplaceToTransactionCall) DoAndReturn 

func (c *MockOperationCRUDAddReplaceToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.Operation, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockOperationCRUDAddReplaceToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockOperationCRUDAddReplaceToTransactionCall) Return 

func (c *MockOperationCRUDAddReplaceToTransactionCall) Return(arg0 string, arg1 error) *MockOperationCRUDAddReplaceToTransactionCall

Return rewrite *gomock.Call.Return

type MockOperationCRUDCreateCall 

type MockOperationCRUDCreateCall struct {
	*gomock.Call
}

MockOperationCRUDCreateCall wrap *gomock.Call

func (*MockOperationCRUDCreateCall) Do 

func (c *MockOperationCRUDCreateCall) Do(f func(context.Context, *api.Operation, *azcosmos.ItemOptions) (*api.Operation, error)) *MockOperationCRUDCreateCall

Do rewrite *gomock.Call.Do

func (*MockOperationCRUDCreateCall) DoAndReturn 

func (c *MockOperationCRUDCreateCall) DoAndReturn(f func(context.Context, *api.Operation, *azcosmos.ItemOptions) (*api.Operation, error)) *MockOperationCRUDCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockOperationCRUDCreateCall) Return 

func (c *MockOperationCRUDCreateCall) Return(arg0 *api.Operation, arg1 error) *MockOperationCRUDCreateCall

Return rewrite *gomock.Call.Return

type MockOperationCRUDDeleteCall 

type MockOperationCRUDDeleteCall struct {
	*gomock.Call
}

MockOperationCRUDDeleteCall wrap *gomock.Call

func (*MockOperationCRUDDeleteCall) Do 

func (c *MockOperationCRUDDeleteCall) Do(f func(context.Context, string) error) *MockOperationCRUDDeleteCall

Do rewrite *gomock.Call.Do

func (*MockOperationCRUDDeleteCall) DoAndReturn 

func (c *MockOperationCRUDDeleteCall) DoAndReturn(f func(context.Context, string) error) *MockOperationCRUDDeleteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockOperationCRUDDeleteCall) Return 

func (c *MockOperationCRUDDeleteCall) Return(arg0 error) *MockOperationCRUDDeleteCall

Return rewrite *gomock.Call.Return

type MockOperationCRUDGetByIDCall 

type MockOperationCRUDGetByIDCall struct {
	*gomock.Call
}

MockOperationCRUDGetByIDCall wrap *gomock.Call

func (*MockOperationCRUDGetByIDCall) Do 

func (c *MockOperationCRUDGetByIDCall) Do(f func(context.Context, string) (*api.Operation, error)) *MockOperationCRUDGetByIDCall

Do rewrite *gomock.Call.Do

func (*MockOperationCRUDGetByIDCall) DoAndReturn 

func (c *MockOperationCRUDGetByIDCall) DoAndReturn(f func(context.Context, string) (*api.Operation, error)) *MockOperationCRUDGetByIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockOperationCRUDGetByIDCall) Return 

func (c *MockOperationCRUDGetByIDCall) Return(arg0 *api.Operation, arg1 error) *MockOperationCRUDGetByIDCall

Return rewrite *gomock.Call.Return

type MockOperationCRUDGetCall 

type MockOperationCRUDGetCall struct {
	*gomock.Call
}

MockOperationCRUDGetCall wrap *gomock.Call

func (*MockOperationCRUDGetCall) Do 

func (c *MockOperationCRUDGetCall) Do(f func(context.Context, string) (*api.Operation, error)) *MockOperationCRUDGetCall

Do rewrite *gomock.Call.Do

func (*MockOperationCRUDGetCall) DoAndReturn 

func (c *MockOperationCRUDGetCall) DoAndReturn(f func(context.Context, string) (*api.Operation, error)) *MockOperationCRUDGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockOperationCRUDGetCall) Return 

func (c *MockOperationCRUDGetCall) Return(arg0 *api.Operation, arg1 error) *MockOperationCRUDGetCall

Return rewrite *gomock.Call.Return

type MockOperationCRUDListActiveOperationsCall 

type MockOperationCRUDListActiveOperationsCall struct {
	*gomock.Call
}

MockOperationCRUDListActiveOperationsCall wrap *gomock.Call

func (*MockOperationCRUDListActiveOperationsCall) Do 

func (c *MockOperationCRUDListActiveOperationsCall) Do(f func(*DBClientListActiveOperationDocsOptions) DBClientIterator[api.Operation]) *MockOperationCRUDListActiveOperationsCall

Do rewrite *gomock.Call.Do

func (*MockOperationCRUDListActiveOperationsCall) DoAndReturn 

func (c *MockOperationCRUDListActiveOperationsCall) DoAndReturn(f func(*DBClientListActiveOperationDocsOptions) DBClientIterator[api.Operation]) *MockOperationCRUDListActiveOperationsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockOperationCRUDListActiveOperationsCall) Return 

func (c *MockOperationCRUDListActiveOperationsCall) Return(arg0 DBClientIterator[api.Operation]) *MockOperationCRUDListActiveOperationsCall

Return rewrite *gomock.Call.Return

type MockOperationCRUDListCall 

type MockOperationCRUDListCall struct {
	*gomock.Call
}

MockOperationCRUDListCall wrap *gomock.Call

func (*MockOperationCRUDListCall) Do 

func (c *MockOperationCRUDListCall) Do(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.Operation], error)) *MockOperationCRUDListCall

Do rewrite *gomock.Call.Do

func (*MockOperationCRUDListCall) DoAndReturn 

func (c *MockOperationCRUDListCall) DoAndReturn(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.Operation], error)) *MockOperationCRUDListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockOperationCRUDListCall) Return 

func (c *MockOperationCRUDListCall) Return(arg0 DBClientIterator[api.Operation], arg1 error) *MockOperationCRUDListCall

Return rewrite *gomock.Call.Return

type MockOperationCRUDMockRecorder 

type MockOperationCRUDMockRecorder struct {
	// contains filtered or unexported fields
}

MockOperationCRUDMockRecorder is the mock recorder for MockOperationCRUD.

func (*MockOperationCRUDMockRecorder) AddCreateToTransaction 

func (mr *MockOperationCRUDMockRecorder) AddCreateToTransaction(ctx, transaction, newObj, opts any) *MockOperationCRUDAddCreateToTransactionCall

AddCreateToTransaction indicates an expected call of AddCreateToTransaction.

func (*MockOperationCRUDMockRecorder) AddReplaceToTransaction 

func (mr *MockOperationCRUDMockRecorder) AddReplaceToTransaction(ctx, transaction, newObj, opts any) *MockOperationCRUDAddReplaceToTransactionCall

AddReplaceToTransaction indicates an expected call of AddReplaceToTransaction.

func (*MockOperationCRUDMockRecorder) Create 

func (mr *MockOperationCRUDMockRecorder) Create(ctx, newObj, options any) *MockOperationCRUDCreateCall

Create indicates an expected call of Create.

func (*MockOperationCRUDMockRecorder) Delete 

func (mr *MockOperationCRUDMockRecorder) Delete(ctx, resourceID any) *MockOperationCRUDDeleteCall

Delete indicates an expected call of Delete.

func (*MockOperationCRUDMockRecorder) Get 

func (mr *MockOperationCRUDMockRecorder) Get(ctx, resourceID any) *MockOperationCRUDGetCall

Get indicates an expected call of Get.

func (*MockOperationCRUDMockRecorder) GetByID 

func (mr *MockOperationCRUDMockRecorder) GetByID(ctx, cosmosID any) *MockOperationCRUDGetByIDCall

GetByID indicates an expected call of GetByID.

func (*MockOperationCRUDMockRecorder) List 

func (mr *MockOperationCRUDMockRecorder) List(ctx, opts any) *MockOperationCRUDListCall

List indicates an expected call of List.

func (*MockOperationCRUDMockRecorder) ListActiveOperations 

func (mr *MockOperationCRUDMockRecorder) ListActiveOperations(options any) *MockOperationCRUDListActiveOperationsCall

ListActiveOperations indicates an expected call of ListActiveOperations.

func (*MockOperationCRUDMockRecorder) Replace 

func (mr *MockOperationCRUDMockRecorder) Replace(ctx, newObj, options any) *MockOperationCRUDReplaceCall

Replace indicates an expected call of Replace.

type MockOperationCRUDReplaceCall 

type MockOperationCRUDReplaceCall struct {
	*gomock.Call
}

MockOperationCRUDReplaceCall wrap *gomock.Call

func (*MockOperationCRUDReplaceCall) Do 

func (c *MockOperationCRUDReplaceCall) Do(f func(context.Context, *api.Operation, *azcosmos.ItemOptions) (*api.Operation, error)) *MockOperationCRUDReplaceCall

Do rewrite *gomock.Call.Do

func (*MockOperationCRUDReplaceCall) DoAndReturn 

func (c *MockOperationCRUDReplaceCall) DoAndReturn(f func(context.Context, *api.Operation, *azcosmos.ItemOptions) (*api.Operation, error)) *MockOperationCRUDReplaceCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockOperationCRUDReplaceCall) Return 

func (c *MockOperationCRUDReplaceCall) Return(arg0 *api.Operation, arg1 error) *MockOperationCRUDReplaceCall

Return rewrite *gomock.Call.Return

type MockServiceProviderClusterCRUD 

type MockServiceProviderClusterCRUD struct {
	// contains filtered or unexported fields
}

MockServiceProviderClusterCRUD is a mock of ServiceProviderClusterCRUD interface.

func NewMockServiceProviderClusterCRUD 

func NewMockServiceProviderClusterCRUD(ctrl *gomock.Controller) *MockServiceProviderClusterCRUD

NewMockServiceProviderClusterCRUD creates a new mock instance.

func (*MockServiceProviderClusterCRUD) AddCreateToTransaction 

func (m *MockServiceProviderClusterCRUD) AddCreateToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.ServiceProviderCluster, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddCreateToTransaction mocks base method.

func (*MockServiceProviderClusterCRUD) AddReplaceToTransaction 

func (m *MockServiceProviderClusterCRUD) AddReplaceToTransaction(ctx context.Context, transaction DBTransaction, newObj *api.ServiceProviderCluster, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddReplaceToTransaction mocks base method.

func (*MockServiceProviderClusterCRUD) Create 

func (m *MockServiceProviderClusterCRUD) Create(ctx context.Context, newObj *api.ServiceProviderCluster, options *azcosmos.ItemOptions) (*api.ServiceProviderCluster, error)

Create mocks base method.

func (*MockServiceProviderClusterCRUD) Delete 

func (m *MockServiceProviderClusterCRUD) Delete(ctx context.Context, resourceID string) error

Delete mocks base method.

func (*MockServiceProviderClusterCRUD) EXPECT 

func (m *MockServiceProviderClusterCRUD) EXPECT() *MockServiceProviderClusterCRUDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockServiceProviderClusterCRUD) Get 

func (m *MockServiceProviderClusterCRUD) Get(ctx context.Context, resourceID string) (*api.ServiceProviderCluster, error)

Get mocks base method.

func (*MockServiceProviderClusterCRUD) GetByID 

func (m *MockServiceProviderClusterCRUD) GetByID(ctx context.Context, cosmosID string) (*api.ServiceProviderCluster, error)

GetByID mocks base method.

func (*MockServiceProviderClusterCRUD) List 

func (m *MockServiceProviderClusterCRUD) List(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[api.ServiceProviderCluster], error)

List mocks base method.

func (*MockServiceProviderClusterCRUD) Replace 

func (m *MockServiceProviderClusterCRUD) Replace(ctx context.Context, newObj *api.ServiceProviderCluster, options *azcosmos.ItemOptions) (*api.ServiceProviderCluster, error)

Replace mocks base method.

type MockServiceProviderClusterCRUDAddCreateToTransactionCall 

type MockServiceProviderClusterCRUDAddCreateToTransactionCall struct {
	*gomock.Call
}

MockServiceProviderClusterCRUDAddCreateToTransactionCall wrap *gomock.Call

func (*MockServiceProviderClusterCRUDAddCreateToTransactionCall) Do 

func (c *MockServiceProviderClusterCRUDAddCreateToTransactionCall) Do(f func(context.Context, DBTransaction, *api.ServiceProviderCluster, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockServiceProviderClusterCRUDAddCreateToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockServiceProviderClusterCRUDAddCreateToTransactionCall) DoAndReturn 

func (c *MockServiceProviderClusterCRUDAddCreateToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.ServiceProviderCluster, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockServiceProviderClusterCRUDAddCreateToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServiceProviderClusterCRUDAddCreateToTransactionCall) Return 

func (c *MockServiceProviderClusterCRUDAddCreateToTransactionCall) Return(arg0 string, arg1 error) *MockServiceProviderClusterCRUDAddCreateToTransactionCall

Return rewrite *gomock.Call.Return

type MockServiceProviderClusterCRUDAddReplaceToTransactionCall 

type MockServiceProviderClusterCRUDAddReplaceToTransactionCall struct {
	*gomock.Call
}

MockServiceProviderClusterCRUDAddReplaceToTransactionCall wrap *gomock.Call

func (*MockServiceProviderClusterCRUDAddReplaceToTransactionCall) Do 

func (c *MockServiceProviderClusterCRUDAddReplaceToTransactionCall) Do(f func(context.Context, DBTransaction, *api.ServiceProviderCluster, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockServiceProviderClusterCRUDAddReplaceToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockServiceProviderClusterCRUDAddReplaceToTransactionCall) DoAndReturn 

func (c *MockServiceProviderClusterCRUDAddReplaceToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *api.ServiceProviderCluster, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockServiceProviderClusterCRUDAddReplaceToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServiceProviderClusterCRUDAddReplaceToTransactionCall) Return 

func (c *MockServiceProviderClusterCRUDAddReplaceToTransactionCall) Return(arg0 string, arg1 error) *MockServiceProviderClusterCRUDAddReplaceToTransactionCall

Return rewrite *gomock.Call.Return

type MockServiceProviderClusterCRUDCreateCall 

type MockServiceProviderClusterCRUDCreateCall struct {
	*gomock.Call
}

MockServiceProviderClusterCRUDCreateCall wrap *gomock.Call

func (*MockServiceProviderClusterCRUDCreateCall) Do 

func (c *MockServiceProviderClusterCRUDCreateCall) Do(f func(context.Context, *api.ServiceProviderCluster, *azcosmos.ItemOptions) (*api.ServiceProviderCluster, error)) *MockServiceProviderClusterCRUDCreateCall

Do rewrite *gomock.Call.Do

func (*MockServiceProviderClusterCRUDCreateCall) DoAndReturn 

func (c *MockServiceProviderClusterCRUDCreateCall) DoAndReturn(f func(context.Context, *api.ServiceProviderCluster, *azcosmos.ItemOptions) (*api.ServiceProviderCluster, error)) *MockServiceProviderClusterCRUDCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServiceProviderClusterCRUDCreateCall) Return 

func (c *MockServiceProviderClusterCRUDCreateCall) Return(arg0 *api.ServiceProviderCluster, arg1 error) *MockServiceProviderClusterCRUDCreateCall

Return rewrite *gomock.Call.Return

type MockServiceProviderClusterCRUDDeleteCall 

type MockServiceProviderClusterCRUDDeleteCall struct {
	*gomock.Call
}

MockServiceProviderClusterCRUDDeleteCall wrap *gomock.Call

func (*MockServiceProviderClusterCRUDDeleteCall) Do 

func (c *MockServiceProviderClusterCRUDDeleteCall) Do(f func(context.Context, string) error) *MockServiceProviderClusterCRUDDeleteCall

Do rewrite *gomock.Call.Do

func (*MockServiceProviderClusterCRUDDeleteCall) DoAndReturn 

func (c *MockServiceProviderClusterCRUDDeleteCall) DoAndReturn(f func(context.Context, string) error) *MockServiceProviderClusterCRUDDeleteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServiceProviderClusterCRUDDeleteCall) Return 

func (c *MockServiceProviderClusterCRUDDeleteCall) Return(arg0 error) *MockServiceProviderClusterCRUDDeleteCall

Return rewrite *gomock.Call.Return

type MockServiceProviderClusterCRUDGetByIDCall 

type MockServiceProviderClusterCRUDGetByIDCall struct {
	*gomock.Call
}

MockServiceProviderClusterCRUDGetByIDCall wrap *gomock.Call

func (*MockServiceProviderClusterCRUDGetByIDCall) Do 

func (c *MockServiceProviderClusterCRUDGetByIDCall) Do(f func(context.Context, string) (*api.ServiceProviderCluster, error)) *MockServiceProviderClusterCRUDGetByIDCall

Do rewrite *gomock.Call.Do

func (*MockServiceProviderClusterCRUDGetByIDCall) DoAndReturn 

func (c *MockServiceProviderClusterCRUDGetByIDCall) DoAndReturn(f func(context.Context, string) (*api.ServiceProviderCluster, error)) *MockServiceProviderClusterCRUDGetByIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServiceProviderClusterCRUDGetByIDCall) Return 

func (c *MockServiceProviderClusterCRUDGetByIDCall) Return(arg0 *api.ServiceProviderCluster, arg1 error) *MockServiceProviderClusterCRUDGetByIDCall

Return rewrite *gomock.Call.Return

type MockServiceProviderClusterCRUDGetCall 

type MockServiceProviderClusterCRUDGetCall struct {
	*gomock.Call
}

MockServiceProviderClusterCRUDGetCall wrap *gomock.Call

func (*MockServiceProviderClusterCRUDGetCall) Do 

func (c *MockServiceProviderClusterCRUDGetCall) Do(f func(context.Context, string) (*api.ServiceProviderCluster, error)) *MockServiceProviderClusterCRUDGetCall

Do rewrite *gomock.Call.Do

func (*MockServiceProviderClusterCRUDGetCall) DoAndReturn 

func (c *MockServiceProviderClusterCRUDGetCall) DoAndReturn(f func(context.Context, string) (*api.ServiceProviderCluster, error)) *MockServiceProviderClusterCRUDGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServiceProviderClusterCRUDGetCall) Return 

func (c *MockServiceProviderClusterCRUDGetCall) Return(arg0 *api.ServiceProviderCluster, arg1 error) *MockServiceProviderClusterCRUDGetCall

Return rewrite *gomock.Call.Return

type MockServiceProviderClusterCRUDListCall 

type MockServiceProviderClusterCRUDListCall struct {
	*gomock.Call
}

MockServiceProviderClusterCRUDListCall wrap *gomock.Call

func (*MockServiceProviderClusterCRUDListCall) Do 

func (c *MockServiceProviderClusterCRUDListCall) Do(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.ServiceProviderCluster], error)) *MockServiceProviderClusterCRUDListCall

Do rewrite *gomock.Call.Do

func (*MockServiceProviderClusterCRUDListCall) DoAndReturn 

func (c *MockServiceProviderClusterCRUDListCall) DoAndReturn(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[api.ServiceProviderCluster], error)) *MockServiceProviderClusterCRUDListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServiceProviderClusterCRUDListCall) Return 

func (c *MockServiceProviderClusterCRUDListCall) Return(arg0 DBClientIterator[api.ServiceProviderCluster], arg1 error) *MockServiceProviderClusterCRUDListCall

Return rewrite *gomock.Call.Return

type MockServiceProviderClusterCRUDMockRecorder 

type MockServiceProviderClusterCRUDMockRecorder struct {
	// contains filtered or unexported fields
}

MockServiceProviderClusterCRUDMockRecorder is the mock recorder for MockServiceProviderClusterCRUD.

func (*MockServiceProviderClusterCRUDMockRecorder) AddCreateToTransaction 

func (mr *MockServiceProviderClusterCRUDMockRecorder) AddCreateToTransaction(ctx, transaction, newObj, opts any) *MockServiceProviderClusterCRUDAddCreateToTransactionCall

AddCreateToTransaction indicates an expected call of AddCreateToTransaction.

func (*MockServiceProviderClusterCRUDMockRecorder) AddReplaceToTransaction 

func (mr *MockServiceProviderClusterCRUDMockRecorder) AddReplaceToTransaction(ctx, transaction, newObj, opts any) *MockServiceProviderClusterCRUDAddReplaceToTransactionCall

AddReplaceToTransaction indicates an expected call of AddReplaceToTransaction.

func (*MockServiceProviderClusterCRUDMockRecorder) Create 

func (mr *MockServiceProviderClusterCRUDMockRecorder) Create(ctx, newObj, options any) *MockServiceProviderClusterCRUDCreateCall

Create indicates an expected call of Create.

func (*MockServiceProviderClusterCRUDMockRecorder) Delete 

func (mr *MockServiceProviderClusterCRUDMockRecorder) Delete(ctx, resourceID any) *MockServiceProviderClusterCRUDDeleteCall

Delete indicates an expected call of Delete.

func (*MockServiceProviderClusterCRUDMockRecorder) Get 

func (mr *MockServiceProviderClusterCRUDMockRecorder) Get(ctx, resourceID any) *MockServiceProviderClusterCRUDGetCall

Get indicates an expected call of Get.

func (*MockServiceProviderClusterCRUDMockRecorder) GetByID 

func (mr *MockServiceProviderClusterCRUDMockRecorder) GetByID(ctx, cosmosID any) *MockServiceProviderClusterCRUDGetByIDCall

GetByID indicates an expected call of GetByID.

func (*MockServiceProviderClusterCRUDMockRecorder) List 

func (mr *MockServiceProviderClusterCRUDMockRecorder) List(ctx, opts any) *MockServiceProviderClusterCRUDListCall

List indicates an expected call of List.

func (*MockServiceProviderClusterCRUDMockRecorder) Replace 

func (mr *MockServiceProviderClusterCRUDMockRecorder) Replace(ctx, newObj, options any) *MockServiceProviderClusterCRUDReplaceCall

Replace indicates an expected call of Replace.

type MockServiceProviderClusterCRUDReplaceCall 

type MockServiceProviderClusterCRUDReplaceCall struct {
	*gomock.Call
}

MockServiceProviderClusterCRUDReplaceCall wrap *gomock.Call

func (*MockServiceProviderClusterCRUDReplaceCall) Do 

func (c *MockServiceProviderClusterCRUDReplaceCall) Do(f func(context.Context, *api.ServiceProviderCluster, *azcosmos.ItemOptions) (*api.ServiceProviderCluster, error)) *MockServiceProviderClusterCRUDReplaceCall

Do rewrite *gomock.Call.Do

func (*MockServiceProviderClusterCRUDReplaceCall) DoAndReturn 

func (c *MockServiceProviderClusterCRUDReplaceCall) DoAndReturn(f func(context.Context, *api.ServiceProviderCluster, *azcosmos.ItemOptions) (*api.ServiceProviderCluster, error)) *MockServiceProviderClusterCRUDReplaceCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServiceProviderClusterCRUDReplaceCall) Return 

func (c *MockServiceProviderClusterCRUDReplaceCall) Return(arg0 *api.ServiceProviderCluster, arg1 error) *MockServiceProviderClusterCRUDReplaceCall

Return rewrite *gomock.Call.Return

type MockSubscriptionCRUD 

type MockSubscriptionCRUD struct {
	// contains filtered or unexported fields
}

MockSubscriptionCRUD is a mock of SubscriptionCRUD interface.

func NewMockSubscriptionCRUD 

func NewMockSubscriptionCRUD(ctrl *gomock.Controller) *MockSubscriptionCRUD

NewMockSubscriptionCRUD creates a new mock instance.

func (*MockSubscriptionCRUD) AddCreateToTransaction 

func (m *MockSubscriptionCRUD) AddCreateToTransaction(ctx context.Context, transaction DBTransaction, newObj *arm.Subscription, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddCreateToTransaction mocks base method.

func (*MockSubscriptionCRUD) AddReplaceToTransaction 

func (m *MockSubscriptionCRUD) AddReplaceToTransaction(ctx context.Context, transaction DBTransaction, newObj *arm.Subscription, opts *azcosmos.TransactionalBatchItemOptions) (string, error)

AddReplaceToTransaction mocks base method.

func (*MockSubscriptionCRUD) Create 

func (m *MockSubscriptionCRUD) Create(ctx context.Context, newObj *arm.Subscription, options *azcosmos.ItemOptions) (*arm.Subscription, error)

Create mocks base method.

func (*MockSubscriptionCRUD) Delete 

func (m *MockSubscriptionCRUD) Delete(ctx context.Context, resourceID string) error

Delete mocks base method.

func (*MockSubscriptionCRUD) EXPECT 

func (m *MockSubscriptionCRUD) EXPECT() *MockSubscriptionCRUDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSubscriptionCRUD) Get 

func (m *MockSubscriptionCRUD) Get(ctx context.Context, resourceID string) (*arm.Subscription, error)

Get mocks base method.

func (*MockSubscriptionCRUD) GetByID 

func (m *MockSubscriptionCRUD) GetByID(ctx context.Context, cosmosID string) (*arm.Subscription, error)

GetByID mocks base method.

func (*MockSubscriptionCRUD) List 

func (m *MockSubscriptionCRUD) List(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[arm.Subscription], error)

List mocks base method.

func (*MockSubscriptionCRUD) Replace 

func (m *MockSubscriptionCRUD) Replace(ctx context.Context, newObj *arm.Subscription, options *azcosmos.ItemOptions) (*arm.Subscription, error)

Replace mocks base method.

type MockSubscriptionCRUDAddCreateToTransactionCall 

type MockSubscriptionCRUDAddCreateToTransactionCall struct {
	*gomock.Call
}

MockSubscriptionCRUDAddCreateToTransactionCall wrap *gomock.Call

func (*MockSubscriptionCRUDAddCreateToTransactionCall) Do 

func (c *MockSubscriptionCRUDAddCreateToTransactionCall) Do(f func(context.Context, DBTransaction, *arm.Subscription, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockSubscriptionCRUDAddCreateToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockSubscriptionCRUDAddCreateToTransactionCall) DoAndReturn 

func (c *MockSubscriptionCRUDAddCreateToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *arm.Subscription, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockSubscriptionCRUDAddCreateToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSubscriptionCRUDAddCreateToTransactionCall) Return 

func (c *MockSubscriptionCRUDAddCreateToTransactionCall) Return(arg0 string, arg1 error) *MockSubscriptionCRUDAddCreateToTransactionCall

Return rewrite *gomock.Call.Return

type MockSubscriptionCRUDAddReplaceToTransactionCall 

type MockSubscriptionCRUDAddReplaceToTransactionCall struct {
	*gomock.Call
}

MockSubscriptionCRUDAddReplaceToTransactionCall wrap *gomock.Call

func (*MockSubscriptionCRUDAddReplaceToTransactionCall) Do 

func (c *MockSubscriptionCRUDAddReplaceToTransactionCall) Do(f func(context.Context, DBTransaction, *arm.Subscription, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockSubscriptionCRUDAddReplaceToTransactionCall

Do rewrite *gomock.Call.Do

func (*MockSubscriptionCRUDAddReplaceToTransactionCall) DoAndReturn 

func (c *MockSubscriptionCRUDAddReplaceToTransactionCall) DoAndReturn(f func(context.Context, DBTransaction, *arm.Subscription, *azcosmos.TransactionalBatchItemOptions) (string, error)) *MockSubscriptionCRUDAddReplaceToTransactionCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSubscriptionCRUDAddReplaceToTransactionCall) Return 

func (c *MockSubscriptionCRUDAddReplaceToTransactionCall) Return(arg0 string, arg1 error) *MockSubscriptionCRUDAddReplaceToTransactionCall

Return rewrite *gomock.Call.Return

type MockSubscriptionCRUDCreateCall 

type MockSubscriptionCRUDCreateCall struct {
	*gomock.Call
}

MockSubscriptionCRUDCreateCall wrap *gomock.Call

func (*MockSubscriptionCRUDCreateCall) Do 

func (c *MockSubscriptionCRUDCreateCall) Do(f func(context.Context, *arm.Subscription, *azcosmos.ItemOptions) (*arm.Subscription, error)) *MockSubscriptionCRUDCreateCall

Do rewrite *gomock.Call.Do

func (*MockSubscriptionCRUDCreateCall) DoAndReturn 

func (c *MockSubscriptionCRUDCreateCall) DoAndReturn(f func(context.Context, *arm.Subscription, *azcosmos.ItemOptions) (*arm.Subscription, error)) *MockSubscriptionCRUDCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSubscriptionCRUDCreateCall) Return 

func (c *MockSubscriptionCRUDCreateCall) Return(arg0 *arm.Subscription, arg1 error) *MockSubscriptionCRUDCreateCall

Return rewrite *gomock.Call.Return

type MockSubscriptionCRUDDeleteCall 

type MockSubscriptionCRUDDeleteCall struct {
	*gomock.Call
}

MockSubscriptionCRUDDeleteCall wrap *gomock.Call

func (*MockSubscriptionCRUDDeleteCall) Do 

func (c *MockSubscriptionCRUDDeleteCall) Do(f func(context.Context, string) error) *MockSubscriptionCRUDDeleteCall

Do rewrite *gomock.Call.Do

func (*MockSubscriptionCRUDDeleteCall) DoAndReturn 

func (c *MockSubscriptionCRUDDeleteCall) DoAndReturn(f func(context.Context, string) error) *MockSubscriptionCRUDDeleteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSubscriptionCRUDDeleteCall) Return 

func (c *MockSubscriptionCRUDDeleteCall) Return(arg0 error) *MockSubscriptionCRUDDeleteCall

Return rewrite *gomock.Call.Return

type MockSubscriptionCRUDGetByIDCall 

type MockSubscriptionCRUDGetByIDCall struct {
	*gomock.Call
}

MockSubscriptionCRUDGetByIDCall wrap *gomock.Call

func (*MockSubscriptionCRUDGetByIDCall) Do 

func (c *MockSubscriptionCRUDGetByIDCall) Do(f func(context.Context, string) (*arm.Subscription, error)) *MockSubscriptionCRUDGetByIDCall

Do rewrite *gomock.Call.Do

func (*MockSubscriptionCRUDGetByIDCall) DoAndReturn 

func (c *MockSubscriptionCRUDGetByIDCall) DoAndReturn(f func(context.Context, string) (*arm.Subscription, error)) *MockSubscriptionCRUDGetByIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSubscriptionCRUDGetByIDCall) Return 

func (c *MockSubscriptionCRUDGetByIDCall) Return(arg0 *arm.Subscription, arg1 error) *MockSubscriptionCRUDGetByIDCall

Return rewrite *gomock.Call.Return

type MockSubscriptionCRUDGetCall 

type MockSubscriptionCRUDGetCall struct {
	*gomock.Call
}

MockSubscriptionCRUDGetCall wrap *gomock.Call

func (*MockSubscriptionCRUDGetCall) Do 

func (c *MockSubscriptionCRUDGetCall) Do(f func(context.Context, string) (*arm.Subscription, error)) *MockSubscriptionCRUDGetCall

Do rewrite *gomock.Call.Do

func (*MockSubscriptionCRUDGetCall) DoAndReturn 

func (c *MockSubscriptionCRUDGetCall) DoAndReturn(f func(context.Context, string) (*arm.Subscription, error)) *MockSubscriptionCRUDGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSubscriptionCRUDGetCall) Return 

func (c *MockSubscriptionCRUDGetCall) Return(arg0 *arm.Subscription, arg1 error) *MockSubscriptionCRUDGetCall

Return rewrite *gomock.Call.Return

type MockSubscriptionCRUDListCall 

type MockSubscriptionCRUDListCall struct {
	*gomock.Call
}

MockSubscriptionCRUDListCall wrap *gomock.Call

func (*MockSubscriptionCRUDListCall) Do 

func (c *MockSubscriptionCRUDListCall) Do(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[arm.Subscription], error)) *MockSubscriptionCRUDListCall

Do rewrite *gomock.Call.Do

func (*MockSubscriptionCRUDListCall) DoAndReturn 

func (c *MockSubscriptionCRUDListCall) DoAndReturn(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[arm.Subscription], error)) *MockSubscriptionCRUDListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSubscriptionCRUDListCall) Return 

func (c *MockSubscriptionCRUDListCall) Return(arg0 DBClientIterator[arm.Subscription], arg1 error) *MockSubscriptionCRUDListCall

Return rewrite *gomock.Call.Return

type MockSubscriptionCRUDMockRecorder 

type MockSubscriptionCRUDMockRecorder struct {
	// contains filtered or unexported fields
}

MockSubscriptionCRUDMockRecorder is the mock recorder for MockSubscriptionCRUD.

func (*MockSubscriptionCRUDMockRecorder) AddCreateToTransaction 

func (mr *MockSubscriptionCRUDMockRecorder) AddCreateToTransaction(ctx, transaction, newObj, opts any) *MockSubscriptionCRUDAddCreateToTransactionCall

AddCreateToTransaction indicates an expected call of AddCreateToTransaction.

func (*MockSubscriptionCRUDMockRecorder) AddReplaceToTransaction 

func (mr *MockSubscriptionCRUDMockRecorder) AddReplaceToTransaction(ctx, transaction, newObj, opts any) *MockSubscriptionCRUDAddReplaceToTransactionCall

AddReplaceToTransaction indicates an expected call of AddReplaceToTransaction.

func (*MockSubscriptionCRUDMockRecorder) Create 

func (mr *MockSubscriptionCRUDMockRecorder) Create(ctx, newObj, options any) *MockSubscriptionCRUDCreateCall

Create indicates an expected call of Create.

func (*MockSubscriptionCRUDMockRecorder) Delete 

func (mr *MockSubscriptionCRUDMockRecorder) Delete(ctx, resourceID any) *MockSubscriptionCRUDDeleteCall

Delete indicates an expected call of Delete.

func (*MockSubscriptionCRUDMockRecorder) Get 

func (mr *MockSubscriptionCRUDMockRecorder) Get(ctx, resourceID any) *MockSubscriptionCRUDGetCall

Get indicates an expected call of Get.

func (*MockSubscriptionCRUDMockRecorder) GetByID 

func (mr *MockSubscriptionCRUDMockRecorder) GetByID(ctx, cosmosID any) *MockSubscriptionCRUDGetByIDCall

GetByID indicates an expected call of GetByID.

func (*MockSubscriptionCRUDMockRecorder) List 

func (mr *MockSubscriptionCRUDMockRecorder) List(ctx, opts any) *MockSubscriptionCRUDListCall

List indicates an expected call of List.

func (*MockSubscriptionCRUDMockRecorder) Replace 

func (mr *MockSubscriptionCRUDMockRecorder) Replace(ctx, newObj, options any) *MockSubscriptionCRUDReplaceCall

Replace indicates an expected call of Replace.

type MockSubscriptionCRUDReplaceCall 

type MockSubscriptionCRUDReplaceCall struct {
	*gomock.Call
}

MockSubscriptionCRUDReplaceCall wrap *gomock.Call

func (*MockSubscriptionCRUDReplaceCall) Do 

func (c *MockSubscriptionCRUDReplaceCall) Do(f func(context.Context, *arm.Subscription, *azcosmos.ItemOptions) (*arm.Subscription, error)) *MockSubscriptionCRUDReplaceCall

Do rewrite *gomock.Call.Do

func (*MockSubscriptionCRUDReplaceCall) DoAndReturn 

func (c *MockSubscriptionCRUDReplaceCall) DoAndReturn(f func(context.Context, *arm.Subscription, *azcosmos.ItemOptions) (*arm.Subscription, error)) *MockSubscriptionCRUDReplaceCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSubscriptionCRUDReplaceCall) Return 

func (c *MockSubscriptionCRUDReplaceCall) Return(arg0 *arm.Subscription, arg1 error) *MockSubscriptionCRUDReplaceCall

Return rewrite *gomock.Call.Return

type MockUntypedResourceCRUD 

type MockUntypedResourceCRUD struct {
	// contains filtered or unexported fields
}

MockUntypedResourceCRUD is a mock of UntypedResourceCRUD interface.

func NewMockUntypedResourceCRUD 

func NewMockUntypedResourceCRUD(ctrl *gomock.Controller) *MockUntypedResourceCRUD

NewMockUntypedResourceCRUD creates a new mock instance.

func (*MockUntypedResourceCRUD) Child 

func (m *MockUntypedResourceCRUD) Child(resourceType arm.ResourceType, resourceName string) (UntypedResourceCRUD, error)

Child mocks base method.

func (*MockUntypedResourceCRUD) Delete 

func (m *MockUntypedResourceCRUD) Delete(ctx context.Context, resourceID *arm.ResourceID) error

Delete mocks base method.

func (*MockUntypedResourceCRUD) DeleteByCosmosID 

func (m *MockUntypedResourceCRUD) DeleteByCosmosID(ctx context.Context, partitionKey, cosmosID string) error

DeleteByCosmosID mocks base method.

func (*MockUntypedResourceCRUD) EXPECT 

func (m *MockUntypedResourceCRUD) EXPECT() *MockUntypedResourceCRUDMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockUntypedResourceCRUD) Get 

func (m *MockUntypedResourceCRUD) Get(ctx context.Context, resourceID *arm.ResourceID) (*TypedDocument, error)

Get mocks base method.

func (*MockUntypedResourceCRUD) List 

func (m *MockUntypedResourceCRUD) List(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[TypedDocument], error)

List mocks base method.

func (*MockUntypedResourceCRUD) ListRecursive 

func (m *MockUntypedResourceCRUD) ListRecursive(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[TypedDocument], error)

ListRecursive mocks base method.

type MockUntypedResourceCRUDChildCall 

type MockUntypedResourceCRUDChildCall struct {
	*gomock.Call
}

MockUntypedResourceCRUDChildCall wrap *gomock.Call

func (*MockUntypedResourceCRUDChildCall) Do 

func (c *MockUntypedResourceCRUDChildCall) Do(f func(arm.ResourceType, string) (UntypedResourceCRUD, error)) *MockUntypedResourceCRUDChildCall

Do rewrite *gomock.Call.Do

func (*MockUntypedResourceCRUDChildCall) DoAndReturn 

func (c *MockUntypedResourceCRUDChildCall) DoAndReturn(f func(arm.ResourceType, string) (UntypedResourceCRUD, error)) *MockUntypedResourceCRUDChildCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockUntypedResourceCRUDChildCall) Return 

func (c *MockUntypedResourceCRUDChildCall) Return(arg0 UntypedResourceCRUD, arg1 error) *MockUntypedResourceCRUDChildCall

Return rewrite *gomock.Call.Return

type MockUntypedResourceCRUDDeleteByCosmosIDCall 

type MockUntypedResourceCRUDDeleteByCosmosIDCall struct {
	*gomock.Call
}

MockUntypedResourceCRUDDeleteByCosmosIDCall wrap *gomock.Call

func (*MockUntypedResourceCRUDDeleteByCosmosIDCall) Do 

func (c *MockUntypedResourceCRUDDeleteByCosmosIDCall) Do(f func(context.Context, string, string) error) *MockUntypedResourceCRUDDeleteByCosmosIDCall

Do rewrite *gomock.Call.Do

func (*MockUntypedResourceCRUDDeleteByCosmosIDCall) DoAndReturn 

func (c *MockUntypedResourceCRUDDeleteByCosmosIDCall) DoAndReturn(f func(context.Context, string, string) error) *MockUntypedResourceCRUDDeleteByCosmosIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockUntypedResourceCRUDDeleteByCosmosIDCall) Return 

func (c *MockUntypedResourceCRUDDeleteByCosmosIDCall) Return(arg0 error) *MockUntypedResourceCRUDDeleteByCosmosIDCall

Return rewrite *gomock.Call.Return

type MockUntypedResourceCRUDDeleteCall 

type MockUntypedResourceCRUDDeleteCall struct {
	*gomock.Call
}

MockUntypedResourceCRUDDeleteCall wrap *gomock.Call

func (*MockUntypedResourceCRUDDeleteCall) Do 

func (c *MockUntypedResourceCRUDDeleteCall) Do(f func(context.Context, *arm.ResourceID) error) *MockUntypedResourceCRUDDeleteCall

Do rewrite *gomock.Call.Do

func (*MockUntypedResourceCRUDDeleteCall) DoAndReturn 

func (c *MockUntypedResourceCRUDDeleteCall) DoAndReturn(f func(context.Context, *arm.ResourceID) error) *MockUntypedResourceCRUDDeleteCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockUntypedResourceCRUDDeleteCall) Return 

func (c *MockUntypedResourceCRUDDeleteCall) Return(arg0 error) *MockUntypedResourceCRUDDeleteCall

Return rewrite *gomock.Call.Return

type MockUntypedResourceCRUDGetCall 

type MockUntypedResourceCRUDGetCall struct {
	*gomock.Call
}

MockUntypedResourceCRUDGetCall wrap *gomock.Call

func (*MockUntypedResourceCRUDGetCall) Do 

func (c *MockUntypedResourceCRUDGetCall) Do(f func(context.Context, *arm.ResourceID) (*TypedDocument, error)) *MockUntypedResourceCRUDGetCall

Do rewrite *gomock.Call.Do

func (*MockUntypedResourceCRUDGetCall) DoAndReturn 

func (c *MockUntypedResourceCRUDGetCall) DoAndReturn(f func(context.Context, *arm.ResourceID) (*TypedDocument, error)) *MockUntypedResourceCRUDGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockUntypedResourceCRUDGetCall) Return 

func (c *MockUntypedResourceCRUDGetCall) Return(arg0 *TypedDocument, arg1 error) *MockUntypedResourceCRUDGetCall

Return rewrite *gomock.Call.Return

type MockUntypedResourceCRUDListCall 

type MockUntypedResourceCRUDListCall struct {
	*gomock.Call
}

MockUntypedResourceCRUDListCall wrap *gomock.Call

func (*MockUntypedResourceCRUDListCall) Do 

func (c *MockUntypedResourceCRUDListCall) Do(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[TypedDocument], error)) *MockUntypedResourceCRUDListCall

Do rewrite *gomock.Call.Do

func (*MockUntypedResourceCRUDListCall) DoAndReturn 

func (c *MockUntypedResourceCRUDListCall) DoAndReturn(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[TypedDocument], error)) *MockUntypedResourceCRUDListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockUntypedResourceCRUDListCall) Return 

func (c *MockUntypedResourceCRUDListCall) Return(arg0 DBClientIterator[TypedDocument], arg1 error) *MockUntypedResourceCRUDListCall

Return rewrite *gomock.Call.Return

type MockUntypedResourceCRUDListRecursiveCall 

type MockUntypedResourceCRUDListRecursiveCall struct {
	*gomock.Call
}

MockUntypedResourceCRUDListRecursiveCall wrap *gomock.Call

func (*MockUntypedResourceCRUDListRecursiveCall) Do 

func (c *MockUntypedResourceCRUDListRecursiveCall) Do(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[TypedDocument], error)) *MockUntypedResourceCRUDListRecursiveCall

Do rewrite *gomock.Call.Do

func (*MockUntypedResourceCRUDListRecursiveCall) DoAndReturn 

func (c *MockUntypedResourceCRUDListRecursiveCall) DoAndReturn(f func(context.Context, *DBClientListResourceDocsOptions) (DBClientIterator[TypedDocument], error)) *MockUntypedResourceCRUDListRecursiveCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockUntypedResourceCRUDListRecursiveCall) Return 

func (c *MockUntypedResourceCRUDListRecursiveCall) Return(arg0 DBClientIterator[TypedDocument], arg1 error) *MockUntypedResourceCRUDListRecursiveCall

Return rewrite *gomock.Call.Return

type MockUntypedResourceCRUDMockRecorder 

type MockUntypedResourceCRUDMockRecorder struct {
	// contains filtered or unexported fields
}

MockUntypedResourceCRUDMockRecorder is the mock recorder for MockUntypedResourceCRUD.

func (*MockUntypedResourceCRUDMockRecorder) Child 

func (mr *MockUntypedResourceCRUDMockRecorder) Child(resourceType, resourceName any) *MockUntypedResourceCRUDChildCall

Child indicates an expected call of Child.

func (*MockUntypedResourceCRUDMockRecorder) Delete 

func (mr *MockUntypedResourceCRUDMockRecorder) Delete(ctx, resourceID any) *MockUntypedResourceCRUDDeleteCall

Delete indicates an expected call of Delete.

func (*MockUntypedResourceCRUDMockRecorder) DeleteByCosmosID 

func (mr *MockUntypedResourceCRUDMockRecorder) DeleteByCosmosID(ctx, partitionKey, cosmosID any) *MockUntypedResourceCRUDDeleteByCosmosIDCall

DeleteByCosmosID indicates an expected call of DeleteByCosmosID.

func (*MockUntypedResourceCRUDMockRecorder) Get 

func (mr *MockUntypedResourceCRUDMockRecorder) Get(ctx, resourceID any) *MockUntypedResourceCRUDGetCall

Get indicates an expected call of Get.

func (*MockUntypedResourceCRUDMockRecorder) List 

func (mr *MockUntypedResourceCRUDMockRecorder) List(ctx, opts any) *MockUntypedResourceCRUDListCall

List indicates an expected call of List.

func (*MockUntypedResourceCRUDMockRecorder) ListRecursive 

func (mr *MockUntypedResourceCRUDMockRecorder) ListRecursive(ctx, opts any) *MockUntypedResourceCRUDListRecursiveCall

ListRecursive indicates an expected call of ListRecursive.

type NodePool 

type NodePool struct {
	TypedDocument `json:",inline"`

	NodePoolProperties `json:"properties"`
}

func InternalToCosmosNodePool 

func InternalToCosmosNodePool(internalObj *api.HCPOpenShiftClusterNodePool) (*NodePool, error)

func (*NodePool) GetTypedDocument 

func (o *NodePool) GetTypedDocument() *TypedDocument

type NodePoolInternalState 

type NodePoolInternalState struct {
	InternalAPI api.HCPOpenShiftClusterNodePool `json:"internalAPI"`
}

type NodePoolProperties 

type NodePoolProperties struct {
	*ResourceDocument `json:",inline"`

	// when we switch to inlining the internalObj, this will be in the right spot.  We add it now so that we can switch our
	// queries to select on cosmosMetata.ResourceID instead of resourceId
	CosmosMetadata api.CosmosMetadata `json:"cosmosMetadata"`

	// IntermediateResourceDoc exists so that we can stop inlining the resource document so that we can directly
	// embed the InternalAPIType which has colliding serialization fields.
	IntermediateResourceDoc *ResourceDocument `json:"intermediateResourceDoc"`

	// TODO we may need look-aside data that we want to store in the same place.  Build the nesting to allow it
	InternalState NodePoolInternalState `json:"internalState"`
}

type NodePoolsCRUD 

type NodePoolsCRUD interface {
	ResourceCRUD[api.HCPOpenShiftClusterNodePool]
	ControllerContainer
}

type OperationCRUD 

type OperationCRUD interface {
	ResourceCRUD[api.Operation]

	// ListActiveOperations returns an iterator that searches for asynchronous operation documents
	// with a non-terminal status in the "Resources" container under the given partition key. The
	// options argument can further limit the search to documents that match the provided values.
	//
	// Note that ListActiveOperations does not perform the search, but merely prepares an iterator
	// to do so. Hence the lack of a Context argument. The search is performed by calling Items() on
	// the iterator in a ranged for loop.
	ListActiveOperations(options *DBClientListActiveOperationDocsOptions) DBClientIterator[api.Operation]
}

func NewOperationCRUD 

func NewOperationCRUD(containerClient *azcosmos.ContainerClient, subscriptionID string) OperationCRUD

type OperationRequest 

type OperationRequest = api.OperationRequest
const (
	OperationRequestCreate OperationRequest = "Create"
	OperationRequestUpdate OperationRequest = "Update"
	OperationRequestDelete OperationRequest = "Delete"

	// These are for POST actions on resources.
	OperationRequestRequestCredential OperationRequest = "RequestCredential"
	OperationRequestRevokeCredentials OperationRequest = "RevokeCredentials"
)

type PostAsyncNotificationFunc 

type PostAsyncNotificationFunc func(ctx context.Context, operation *api.Operation) error

type ResourceCRUD 

type ResourceCRUD[InternalAPIType any] interface {
	GetByID(ctx context.Context, cosmosID string) (*InternalAPIType, error)
	Get(ctx context.Context, resourceID string) (*InternalAPIType, error)
	List(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[InternalAPIType], error)
	Create(ctx context.Context, newObj *InternalAPIType, options *azcosmos.ItemOptions) (*InternalAPIType, error)
	Replace(ctx context.Context, newObj *InternalAPIType, options *azcosmos.ItemOptions) (*InternalAPIType, error)
	Delete(ctx context.Context, resourceID string) error

	AddCreateToTransaction(ctx context.Context, transaction DBTransaction, newObj *InternalAPIType, opts *azcosmos.TransactionalBatchItemOptions) (string, error)
	AddReplaceToTransaction(ctx context.Context, transaction DBTransaction, newObj *InternalAPIType, opts *azcosmos.TransactionalBatchItemOptions) (string, error)
}

func NewControllerCRUD 

func NewControllerCRUD(
	containerClient *azcosmos.ContainerClient, parentResourceID *azcorearm.ResourceID, resourceType azcorearm.ResourceType) ResourceCRUD[api.Controller]

type ResourceDocument 

type ResourceDocument struct {
	ResourceID        *azcorearm.ResourceID       `json:"resourceId,omitempty"`
	InternalID        ocm.InternalID              `json:"internalId,omitempty"`
	ActiveOperationID string                      `json:"activeOperationId,omitempty"`
	ProvisioningState arm.ProvisioningState       `json:"provisioningState,omitempty"`
	Identity          *arm.ManagedServiceIdentity `json:"identity,omitempty"`
	SystemData        *arm.SystemData             `json:"systemData,omitempty"`
	Tags              map[string]string           `json:"tags,omitempty"`

	InternalState map[string]any `json:"internalState,omitempty"`
}

ResourceDocument captures the mapping of an Azure resource ID to an internal resource ID (the OCM API path), as well as any ARM-specific metadata for the resource.

func NewResourceDocument 

func NewResourceDocument(resourceID *azcorearm.ResourceID) *ResourceDocument

func (*ResourceDocument) SetResourceID 

func (o *ResourceDocument) SetResourceID(newResourceID *azcorearm.ResourceID)

type ResourceDocumentStateFilter 

type ResourceDocumentStateFilter interface {
	// RemoveUnknownFields checks the customerDesiredState and serviceProviderState and removes unknown fields.
	// The simplest implementation is "remove everything" and the next simplest is round-tripping through JSON.
	RemoveUnknownFields(*ResourceDocument) error
}

ResourceDocumentStateFilter is used to remove unknown fields from ResourceDocumentProperties. Long-term, we want to reach a point where we store different types so we have full type-safety throughout the stack. Short-term, we want a low-touch modification that makes it safe to store new fields.

type ServiceProviderClusterCRUD 

type ServiceProviderClusterCRUD interface {
	ResourceCRUD[api.ServiceProviderCluster]
}

type ServiceProviderNodePoolCRUD 

type ServiceProviderNodePoolCRUD interface {
	ResourceCRUD[api.ServiceProviderNodePool]
}

type StopHoldLock 

type StopHoldLock func() *azcosmos.ItemResponse

type SubscriptionCRUD 

type SubscriptionCRUD interface {
	ResourceCRUD[arm.Subscription]
}

type TypedDocument 

type TypedDocument struct {
	BaseDocument
	PartitionKey string                `json:"partitionKey"`
	ResourceID   *azcorearm.ResourceID `json:"resourceID"`
	ResourceType string                `json:"resourceType"`
	Properties   json.RawMessage       `json:"properties"`
}

TypedDocument is a BaseDocument with a ResourceType field to help distinguish heterogeneous items in a Cosmos DB container. The Properties field can be unmarshalled to any type that implements the DocumentProperties interface.

func (*TypedDocument) GetTypedDocument 

func (td *TypedDocument) GetTypedDocument() *TypedDocument

type TypedDocumentAccessor 

type TypedDocumentAccessor interface {
	GetTypedDocument() *TypedDocument
}

type UntypedResourceCRUD 

type UntypedResourceCRUD interface {
	Get(ctx context.Context, resourceID *azcorearm.ResourceID) (*TypedDocument, error)
	// List returns back only direct descendents from the parent.
	List(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[TypedDocument], error)
	// ListRecursive returns back every descendent from the parent.  For instance, if you ListRecursive on a cluster,
	// you will get the controllers for the cluster, the nodepools, the controllers for each nodepool, the external auths,
	// the controllers for the external auths, etc.
	ListRecursive(ctx context.Context, opts *DBClientListResourceDocsOptions) (DBClientIterator[TypedDocument], error)
	Delete(ctx context.Context, resourceID *azcorearm.ResourceID) error
	DeleteByCosmosID(ctx context.Context, partitionKey, cosmosID string) error

	Child(resourceType azcorearm.ResourceType, resourceName string) (UntypedResourceCRUD, error)
}

func NewUntypedCRUD 

func NewUntypedCRUD(containerClient *azcosmos.ContainerClient, parentResourceID azcorearm.ResourceID) UntypedResourceCRUD

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.