Documentation ¶
Overview ¶
Package statusmanager is a generated GoMock package.
Index ¶
- type MockStatusManager
- func (m *MockStatusManager) Delete(arg0 context.Context, arg1 resources.ID, arg2 uuid.UUID) error
- func (m *MockStatusManager) EXPECT() *MockStatusManagerMockRecorder
- func (m *MockStatusManager) Get(arg0 context.Context, arg1 resources.ID, arg2 uuid.UUID) (*Status, error)
- func (m *MockStatusManager) QueueAsyncOperation(arg0 context.Context, arg1 *v1.ARMRequestContext, arg2 QueueOperationOptions) error
- func (m *MockStatusManager) Update(arg0 context.Context, arg1 resources.ID, arg2 uuid.UUID, ...) error
- type MockStatusManagerMockRecorder
- func (mr *MockStatusManagerMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStatusManagerMockRecorder) Get(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStatusManagerMockRecorder) QueueAsyncOperation(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStatusManagerMockRecorder) Update(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
- type QueueOperationOptions
- type Status
- type StatusManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockStatusManager ¶
type MockStatusManager struct {
// contains filtered or unexported fields
}
MockStatusManager is a mock of StatusManager interface.
func NewMockStatusManager ¶
func NewMockStatusManager(ctrl *gomock.Controller) *MockStatusManager
NewMockStatusManager creates a new mock instance.
func (*MockStatusManager) EXPECT ¶
func (m *MockStatusManager) EXPECT() *MockStatusManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStatusManager) Get ¶
func (m *MockStatusManager) Get(arg0 context.Context, arg1 resources.ID, arg2 uuid.UUID) (*Status, error)
Get mocks base method.
func (*MockStatusManager) QueueAsyncOperation ¶
func (m *MockStatusManager) QueueAsyncOperation(arg0 context.Context, arg1 *v1.ARMRequestContext, arg2 QueueOperationOptions) error
QueueAsyncOperation mocks base method.
type MockStatusManagerMockRecorder ¶
type MockStatusManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockStatusManagerMockRecorder is the mock recorder for MockStatusManager.
func (*MockStatusManagerMockRecorder) Delete ¶
func (mr *MockStatusManagerMockRecorder) Delete(arg0, arg1, arg2 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockStatusManagerMockRecorder) Get ¶
func (mr *MockStatusManagerMockRecorder) Get(arg0, arg1, arg2 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockStatusManagerMockRecorder) QueueAsyncOperation ¶
func (mr *MockStatusManagerMockRecorder) QueueAsyncOperation(arg0, arg1, arg2 interface{}) *gomock.Call
QueueAsyncOperation indicates an expected call of QueueAsyncOperation.
func (*MockStatusManagerMockRecorder) Update ¶
func (mr *MockStatusManagerMockRecorder) Update(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call
Update indicates an expected call of Update.
type QueueOperationOptions ¶
type QueueOperationOptions struct { // OperationTimeout specifies the timeout duration for the async operation. OperationTimeout time.Duration // RetryAfter specifies the value of the Retry-After header that will be used for async operations. RetryAfter time.Duration }
QueueOperationOptions is the options type provided when queueing an async operation.
type Status ¶
type Status struct { v1.AsyncOperationStatus // LinkedResourceID is the resource id associated with operation status. LinkedResourceID string `json:"resourceID"` // Location represents the location of operationstatus. Location string `json:"location"` // RetryAfter is the value of the Retry-After header that will be used for async operations. RetryAfter time.Duration `json:"retryAfter"` // HomeTenantID is async operation caller's tenant id such as the value from x-ms-home-tenant-id header. HomeTenantID string `json:"clientTenantID,omitempty"` // ClientObjectID is async operation caller's client id such as the value from x-ms-client-object-id header. ClientObjectID string `json:"clientObjectID,omitempty"` // LastUpdatedTime represents the async operation last updated time. LastUpdatedTime time.Time `json:"lastUpdatedTime,omitempty"` }
Status is the datamodel for Async operation statuses.
type StatusManager ¶
type StatusManager interface { // Get gets an async operation status object. Get(ctx context.Context, id resources.ID, operationID uuid.UUID) (*Status, error) // QueueAsyncOperation creates an async operation status object and queue async operation. QueueAsyncOperation(ctx context.Context, sCtx *v1.ARMRequestContext, options QueueOperationOptions) error // Update updates an async operation status. Update(ctx context.Context, id resources.ID, operationID uuid.UUID, state v1.ProvisioningState, endTime *time.Time, opError *v1.ErrorDetails) error // Delete deletes an async operation status. Delete(ctx context.Context, id resources.ID, operationID uuid.UUID) error }
StatusManager is an interface to manage async operation status.
func New ¶
func New(dataProvider dataprovider.DataStorageProvider, q queue.Client, location string) StatusManager
New creates statusManager instance.