本文整理汇总了Golang中github.com/golang/mock/gomock.Any函数的典型用法代码示例。如果您正苦于以下问题:Golang Any函数的具体用法?Golang Any怎么用?Golang Any使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Any函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: TestKBPKIClientHasVerifyingKeyStaleCache
// Test that KBPKI forces a cache flush one time if it can't find a
// given verifying key.
func TestKBPKIClientHasVerifyingKeyStaleCache(t *testing.T) {
ctr := NewSafeTestReporter(t)
mockCtrl := gomock.NewController(ctr)
config := NewConfigMock(mockCtrl, ctr)
c := NewKBPKIClient(config)
config.SetKBPKI(c)
defer func() {
config.ctr.CheckForFailures()
mockCtrl.Finish()
}()
u := keybase1.MakeTestUID(1)
key1 := MakeLocalUserVerifyingKeyOrBust("u_1")
key2 := MakeLocalUserVerifyingKeyOrBust("u_2")
info1 := UserInfo{
VerifyingKeys: []VerifyingKey{key1},
}
config.mockKbd.EXPECT().LoadUserPlusKeys(gomock.Any(), u).
Return(info1, nil)
config.mockKbd.EXPECT().FlushUserFromLocalCache(gomock.Any(), u)
info2 := UserInfo{
VerifyingKeys: []VerifyingKey{key1, key2},
}
config.mockKbd.EXPECT().LoadUserPlusKeys(gomock.Any(), u).
Return(info2, nil)
err := c.HasVerifyingKey(context.Background(), u, key2, time.Now())
if err != nil {
t.Error(err)
}
}
开发者ID:keybase,项目名称:kbfs-beta,代码行数:34,代码来源:kbpki_client_test.go
示例2: TestCreateContainerMergesLabels
func TestCreateContainerMergesLabels(t *testing.T) {
ctrl, client, _, taskEngine, _ := mocks(t, &defaultConfig)
defer ctrl.Finish()
testTask := &api.Task{
Arn: "arn:aws:ecs:us-east-1:012345678910:task/c09f0188-7f87-4b0f-bfc3-16296622b6fe",
Family: "myFamily",
Version: "1",
Containers: []*api.Container{
&api.Container{
Name: "c1",
DockerConfig: api.DockerConfig{
Config: aws.String(`{"Labels":{"key":"value"}}`),
},
},
},
}
expectedConfig, err := testTask.DockerConfig(testTask.Containers[0])
if err != nil {
t.Fatal(err)
}
expectedConfig.Labels = map[string]string{
"com.amazonaws.ecs.task-arn": "arn:aws:ecs:us-east-1:012345678910:task/c09f0188-7f87-4b0f-bfc3-16296622b6fe",
"com.amazonaws.ecs.container-name": "c1",
"com.amazonaws.ecs.task-definition-family": "myFamily",
"com.amazonaws.ecs.task-definition-version": "1",
"com.amazonaws.ecs.cluster": "",
"key": "value",
}
client.EXPECT().CreateContainer(expectedConfig, gomock.Any(), gomock.Any())
taskEngine.(*DockerTaskEngine).createContainer(testTask, testTask.Containers[0])
}
开发者ID:witsoej,项目名称:amazon-ecs-agent,代码行数:32,代码来源:docker_task_engine_test.go
示例3: TestValidationError
func TestValidationError(t *testing.T) {
u, ctrl, _, mockfs, mockacs, mockhttp := mocks(t, nil)
defer ctrl.Finish()
var writtenFile bytes.Buffer
gomock.InOrder(
mockhttp.EXPECT().RoundTrip(mock_http.NewHTTPSimpleMatcher("GET", "https://s3.amazonaws.com/amazon-ecs-agent/update.tar")).Return(mock_http.SuccessResponse("update-tar-data"), nil),
mockfs.EXPECT().Create(gomock.Any()).Return(mock_os.NopReadWriteCloser(&writtenFile), nil),
mockfs.EXPECT().Remove(gomock.Any()),
mockacs.EXPECT().MakeRequest(&nackRequestMatcher{&ecsacs.NackRequest{
Cluster: ptr("cluster").(*string),
ContainerInstance: ptr("containerInstance").(*string),
MessageId: ptr("StageMID").(*string),
}}),
)
u.stageUpdateHandler()(&ecsacs.StageUpdateMessage{
ClusterArn: ptr("cluster").(*string),
ContainerInstanceArn: ptr("containerInstance").(*string),
MessageId: ptr("StageMID").(*string),
UpdateInfo: &ecsacs.UpdateInfo{
Location: ptr("https://s3.amazonaws.com/amazon-ecs-agent/update.tar").(*string),
Signature: ptr("Invalid signature").(*string),
},
})
if writtenFile.String() != "update-tar-data" {
t.Error("Incorrect data written")
}
}
开发者ID:dockerstack,项目名称:amazon-ecs-agent,代码行数:30,代码来源:updater_test.go
示例4: TestFunction_Rollback_latestVersion
func TestFunction_Rollback_latestVersion(t *testing.T) {
mockCtrl := gomock.NewController(t)
defer mockCtrl.Finish()
serviceMock := mock_lambdaiface.NewMockLambdaAPI(mockCtrl)
deployedVersions := []*lambda.FunctionConfiguration{
&lambda.FunctionConfiguration{Version: aws.String("$LATEST")},
&lambda.FunctionConfiguration{Version: aws.String("1")},
&lambda.FunctionConfiguration{Version: aws.String("2")},
}
currentVersion := aws.String("1")
afterRollbackVersion := aws.String("2")
serviceMock.EXPECT().GetAlias(gomock.Any()).Return(&lambda.AliasConfiguration{FunctionVersion: currentVersion}, nil)
serviceMock.EXPECT().ListVersionsByFunction(gomock.Any()).Return(&lambda.ListVersionsByFunctionOutput{Versions: deployedVersions}, nil)
serviceMock.EXPECT().UpdateAlias(&lambda.UpdateAliasInput{
FunctionName: aws.String("testfn"),
Name: aws.String("current"),
FunctionVersion: afterRollbackVersion,
})
fn := &function.Function{
FunctionName: "testfn",
Service: serviceMock,
Log: log.Log,
}
err := fn.Rollback()
assert.Nil(t, err)
}
开发者ID:kujohn,项目名称:apex,代码行数:29,代码来源:function_test.go
示例5: TestCreateVpcReturnCreatedInstanceIfSuccess
func TestCreateVpcReturnCreatedInstanceIfSuccess(t *testing.T) {
//given
ctrl := gomock.NewController(t)
defer ctrl.Finish()
mockEntityService := services_mocks.NewMockEntityService(ctrl)
vpcService := VpcApi{
entityService: mockEntityService,
}
vpcToCreate := Vpc{Name: "new_name",
Description: "new_description",
VpcOfferingId: "vpc_offering_id",
}
mockEntityService.EXPECT().Create(gomock.Any(), gomock.Any()).Return([]byte(`{"id":"new_id"}`), nil)
//when
createdVpc, _ := vpcService.Create(vpcToCreate)
//then
if assert.NotNil(t, createdVpc) {
assert.Equal(t, "new_id", createdVpc.Id)
}
}
开发者ID:cloud-ca,项目名称:go-cloudca,代码行数:26,代码来源:vpc_test.go
示例6: TestGCMConnector_GetErrorMessageFromGcm
func TestGCMConnector_GetErrorMessageFromGcm(t *testing.T) {
ctrl, finish := testutil.NewMockCtrl(t)
defer finish()
// defer testutil.EnableDebugForMethod()()
a := assert.New(t)
routerMock := NewMockRouter(ctrl)
routerMock.EXPECT().Subscribe(gomock.Any()).Do(func(route *server.Route) {
a.Equal("/gcm/broadcast", string(route.Path))
a.Equal("gcm_connector", route.UserID)
a.Equal("gcm_connector", route.ApplicationID)
})
// expect the route unsubscribed from removeSubscription
routerMock.EXPECT().Unsubscribe(gomock.Any()).Do(func(route *server.Route) {
a.Equal("/path", string(route.Path))
a.Equal("id", route.ApplicationID)
})
// expect the route subscribe with the new canonicalId from replaceSubscriptionWithCanonicalID
routerMock.EXPECT().Subscribe(gomock.Any()).Do(func(route *server.Route) {
a.Equal("/path", string(route.Path))
a.Equal("marvin", route.UserID)
a.Equal("gcmCanonicalID", route.ApplicationID)
})
kvStore := store.NewMemoryKVStore()
routerMock.EXPECT().KVStore().Return(kvStore, nil)
gcm, err := NewGCMConnector(routerMock, "/gcm/", "testApi", 1)
a.Nil(err)
err = gcm.Start()
a.Nil(err)
done := make(chan bool, 1)
mockSender := testutil.CreateGcmSender(
testutil.CreateRoundTripperWithJsonResponse(http.StatusOK, testutil.ErrorResponseMessageJSON, done))
gcm.Sender = mockSender
// put a dummy gcm message with minimum information
msg := &server.MessageForRoute{
Message: &protocol.Message{
ID: uint64(4),
Body: []byte("{id:id}"),
Time: 1405544146,
Path: "/gcm/marvin/gcm124/subscribe/stuff"},
Route: &server.Route{
ApplicationID: "id",
Path: "/path",
UserID: "marvin"}}
gcm.routerC <- msg
// expect that the Http Server gives us a malformed message
<-done
//wait before closing the gcm connector
time.Sleep(50 * time.Millisecond)
err = gcm.Stop()
a.NoError(err)
}
开发者ID:cosminrentea,项目名称:guble,代码行数:60,代码来源:gcm_connector_test.go
示例7: TestDownloadAgentMD5Mismatch
func TestDownloadAgentMD5Mismatch(t *testing.T) {
mockCtrl := gomock.NewController(t)
defer mockCtrl.Finish()
md5response := &http.Response{}
md5sum := "md5sum"
tarballResponse := &http.Response{
StatusCode: 200,
Body: ioutil.NopCloser(&bytes.Buffer{}),
}
mockFS := NewMockfileSystem(mockCtrl)
mockFS.EXPECT().MkdirAll(config.CacheDirectory(), os.ModeDir|0700)
mockGetter := NewMockhttpGetter(mockCtrl)
mockGetter.EXPECT().Get(config.AgentRemoteTarballMD5()).Return(md5response, nil)
mockFS.EXPECT().ReadAll(md5response.Body).Return([]byte(md5sum), nil)
mockGetter.EXPECT().Get(config.AgentRemoteTarball()).Return(tarballResponse, nil)
tempfile, err := ioutil.TempFile("", "test")
if err != nil {
t.Fail()
}
defer tempfile.Close()
mockFS.EXPECT().TempFile("", "ecs-agent.tar").Return(tempfile, nil)
mockFS.EXPECT().TeeReader(tarballResponse.Body, gomock.Any())
mockFS.EXPECT().Copy(tempfile, gomock.Any()).Return(int64(0), nil)
mockFS.EXPECT().Remove(tempfile.Name())
d := &Downloader{
getter: mockGetter,
fs: mockFS,
}
d.DownloadAgent()
}
开发者ID:ColBT,项目名称:amazon-ecs-init,代码行数:34,代码来源:cache_test.go
示例8: TestCreateInstanceReturnCreatedInstanceIfSuccess
func TestCreateInstanceReturnCreatedInstanceIfSuccess(t *testing.T) {
//given
ctrl := gomock.NewController(t)
defer ctrl.Finish()
mockEntityService := services_mocks.NewMockEntityService(ctrl)
instanceService := InstanceApi{
entityService: mockEntityService,
}
instanceToCreate := Instance{Id: "new_id",
Name: "new_name",
TemplateId: "templateId",
ComputeOfferingId: "computeOfferingId",
NetworkId: "networkId"}
mockEntityService.EXPECT().Create(gomock.Any(), gomock.Any()).Return([]byte(`{"id":"new_id", "password": "new_password"}`), nil)
//when
createdInstance, _ := instanceService.Create(instanceToCreate)
//then
if assert.NotNil(t, createdInstance) {
assert.Equal(t, "new_password", createdInstance.Password)
}
}
开发者ID:cloud-ca,项目名称:go-cloudca,代码行数:27,代码来源:instance_test.go
示例9: TestWaitExhaustRetries
func TestWaitExhaustRetries(t *testing.T) {
ctrl := gomock.NewController(t)
mockCfn := mock_cloudformationiface.NewMockCloudFormationAPI(ctrl)
cfnClient := NewCloudformationClient()
cfnClient.(*cloudformationClient).client = mockCfn
cfnClient.(*cloudformationClient).sleeper = &noopsleeper{}
defer ctrl.Finish()
eventCreateInProgress := createStackEvent(cloudformation.ResourceStatusCreateInProgress)
mockCfn.EXPECT().DescribeStackEvents(gomock.Any()).AnyTimes().Return(eventCreateInProgress, nil)
mockCfn.EXPECT().DescribeStacks(gomock.Any()).AnyTimes().Return(createDescribeStacksOutput(cloudformation.StackStatusCreateInProgress), nil)
err := cfnClient.(*cloudformationClient).waitUntilComplete("", failureInCreateEvent, "", createStackFailures, 10)
if err == nil {
t.Error("Expected error waiting for create completion")
}
err = cfnClient.(*cloudformationClient).waitUntilComplete("", failureInDeleteEvent, "", deleteStackFailures, 10)
if err == nil {
t.Error("Expected error waiting for delete completion")
}
err = cfnClient.(*cloudformationClient).waitUntilComplete("", failureInUpdateEvent, "", updateStackFailures, 10)
if err == nil {
t.Error("Expected error waiting for update completion")
}
}
开发者ID:uttarasridhar,项目名称:amazon-ecs-cli,代码行数:27,代码来源:client_test.go
示例10: TestWaitDescribeStackFailure
func TestWaitDescribeStackFailure(t *testing.T) {
ctrl := gomock.NewController(t)
mockCfn := mock_cloudformationiface.NewMockCloudFormationAPI(ctrl)
cfnClient := NewCloudformationClient()
cfnClient.(*cloudformationClient).client = mockCfn
cfnClient.(*cloudformationClient).sleeper = &noopsleeper{}
defer ctrl.Finish()
// Create some stack events for firstStackEventWithFailure() to process.
// latest event, no error.
eventsWithFailure := createStackEvent(cloudformation.ResourceStatusCreateInProgress)
eventsWithFailure.StackEvents = append(eventsWithFailure.StackEvents, &cloudformation.StackEvent{
ResourceStatus: aws.String(cloudformation.ResourceStatusCreateInProgress),
})
// second event. failure.
eventsWithFailure.StackEvents = append(eventsWithFailure.StackEvents, &cloudformation.StackEvent{
ResourceStatus: aws.String(cloudformation.ResourceStatusCreateFailed),
ResourceStatusReason: aws.String("do you really wanna know?"),
})
// oldest event, no error.
eventsWithFailure.StackEvents = append(eventsWithFailure.StackEvents, &cloudformation.StackEvent{
ResourceStatus: aws.String(cloudformation.ResourceStatusCreateInProgress),
})
mockCfn.EXPECT().DescribeStackEvents(gomock.Any()).AnyTimes().Return(eventsWithFailure, nil)
mockCfn.EXPECT().DescribeStacks(gomock.Any()).Return(createDescribeStacksOutput(cloudformation.StackStatusCreateFailed), nil)
err := cfnClient.(*cloudformationClient).waitUntilComplete("", failureInCreateEvent, "", createStackFailures, 10)
if err == nil {
t.Error("Expected error waiting for create completion")
}
}
开发者ID:uttarasridhar,项目名称:amazon-ecs-cli,代码行数:31,代码来源:client_test.go
示例11: TestCreateUser
func TestCreateUser(t *testing.T) {
testKey := []byte(`MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4f5wg5l2hKsTeNemV41`)
authenForTest := NewAuthenticator(testKey)
//-- params
userid := "salmon"
username := "the fish"
password := "password"
cred, _ := NewUserIDPassword(userid, []byte(password))
clientId := "ios"
otherFields := make(map[UserFieldName]interface{})
otherFields[UserField_Language] = "en"
ctrl := gomock.NewController(t)
defer ctrl.Finish()
mockUserDb := NewMockUserDb_I(ctrl)
mockUserDb.EXPECT().CreateUser(cred.UserId(), username, gomock.Any(), RegularUser, otherFields)
mockUserDb.EXPECT().SetRefreshToken(cred.UserId(), clientId, gomock.Any())
_, _, err := authenForTest.CreateUser(
userid, username, []byte(password), clientId, otherFields, mockUserDb)
if err != nil {
t.Error("create user failed:%v", err)
}
}
开发者ID:peiwenhu,项目名称:auth,代码行数:26,代码来源:5_ext_authenticator_test.go
示例12: TestQueueConsumerRunStopsGracefullyWhenCancelled
func TestQueueConsumerRunStopsGracefullyWhenCancelled(t *testing.T) {
// log to /dev/null because the deleter is chatty
log.SetOutput(ioutil.Discard)
defer func() {
log.SetOutput(os.Stderr)
}()
ctl := gomock.NewController(t)
defer ctl.Finish()
// delay so that the cancel occurs mid-receive
delay := func(x interface{}) {
time.Sleep(10 * time.Millisecond)
}
m := mock.NewMockSQSAPI(ctl)
m.EXPECT().ReceiveMessage(gomock.Any()).Do(delay).Return(&sqs.ReceiveMessageOutput{}, nil).AnyTimes()
m.EXPECT().DeleteMessageBatch(gomock.Any()).AnyTimes().Return(&sqs.DeleteMessageBatchOutput{}, nil)
m.EXPECT().ChangeMessageVisibilityBatch(gomock.Any()).AnyTimes()
s := &SQSService{Svc: m}
q := NewConsumer(s, noop)
q.delayAfterReceiveError = time.Millisecond
ngo := runtime.NumGoroutine()
// wait long enough to ensure ReceiveMessage is running
ctx, _ := context.WithTimeout(context.Background(), 5*time.Millisecond)
err := q.Run(ctx)
assert.Error(t, err)
time.Sleep(time.Millisecond) // time for goroutines to end
assert.InDelta(t, ngo, runtime.NumGoroutine(), 2, "Should not leak goroutines")
}
开发者ID:Wattpad,项目名称:sqsconsumer,代码行数:34,代码来源:queue_consumer_test.go
示例13: TestHandleActivation
func TestHandleActivation(t *testing.T) {
a := New(t)
gtwID := "eui-0102030405060708"
devEUI := types.DevEUI([8]byte{0, 1, 2, 3, 4, 5, 6, 7})
appEUI := types.AppEUI([8]byte{0, 1, 2, 3, 4, 5, 6, 7})
b := getTestBroker(t)
b.ns.EXPECT().PrepareActivation(gomock.Any(), gomock.Any()).Return(&pb_broker.DeduplicatedDeviceActivationRequest{
Payload: []byte{},
DevEui: &devEUI,
AppEui: &appEUI,
AppId: "appid",
DevId: "devid",
GatewayMetadata: []*gateway.RxMetadata{
&gateway.RxMetadata{Snr: 1.2, GatewayId: gtwID},
},
ProtocolMetadata: &protocol.RxMetadata{},
}, nil)
b.discovery.EXPECT().GetAllHandlersForAppID("appid").Return([]*pb_discovery.Announcement{}, nil)
res, err := b.HandleActivation(&pb_broker.DeviceActivationRequest{
Payload: []byte{},
DevEui: &devEUI,
AppEui: &appEUI,
GatewayMetadata: &gateway.RxMetadata{Snr: 1.2, GatewayId: gtwID},
ProtocolMetadata: &protocol.RxMetadata{},
})
a.So(err, ShouldNotBeNil)
a.So(res, ShouldBeNil)
b.ctrl.Finish()
// TODO: Integration test with Handler
}
开发者ID:TheThingsNetwork,项目名称:ttn,代码行数:35,代码来源:activation_test.go
示例14: TestClusterPSTaskGetInfoFail
func TestClusterPSTaskGetInfoFail(t *testing.T) {
newCliParams = func(context *cli.Context, rdwr config.ReadWriter) (*config.CliParams, error) {
return &config.CliParams{
Cluster: clusterName,
}, nil
}
ctrl := gomock.NewController(t)
defer ctrl.Finish()
mockEcs := mock_ecs.NewMockECSClient(ctrl)
mockEcs.EXPECT().Initialize(gomock.Any())
mockEcs.EXPECT().IsActiveCluster(gomock.Any()).Return(true, nil)
mockEcs.EXPECT().GetTasksPages(gomock.Any(), gomock.Any()).Do(func(x, y interface{}) {
}).Return(errors.New("error"))
globalSet := flag.NewFlagSet("ecs-cli", 0)
globalSet.String("region", "us-west-1", "")
globalContext := cli.NewContext(nil, globalSet, nil)
flagSet := flag.NewFlagSet("ecs-cli-down", 0)
context := cli.NewContext(nil, flagSet, globalContext)
_, err := clusterPS(context, &mockReadWriter{}, mockEcs)
if err == nil {
t.Fatal("Expected error in cluster ps")
}
}
开发者ID:jloper3,项目名称:amazon-ecs-cli,代码行数:27,代码来源:cluster_app_test.go
示例15: TestCreateInstanceReturnNilWithErrorIfError
func TestCreateInstanceReturnNilWithErrorIfError(t *testing.T) {
//given
ctrl := gomock.NewController(t)
defer ctrl.Finish()
mockEntityService := services_mocks.NewMockEntityService(ctrl)
instanceService := InstanceApi{
entityService: mockEntityService,
}
mockError := mocks.MockError{"some_create_instance_error"}
mockEntityService.EXPECT().Create(gomock.Any(), gomock.Any()).Return(nil, mockError)
instanceToCreate := Instance{Name: "new_name",
TemplateId: "templateId",
ComputeOfferingId: "computeOfferingId",
NetworkId: "networkId"}
//when
createdInstance, err := instanceService.Create(instanceToCreate)
//then
assert.Nil(t, createdInstance)
assert.Equal(t, mockError, err)
}
开发者ID:cloud-ca,项目名称:go-cloudca,代码行数:28,代码来源:instance_test.go
示例16: TestControllerWait
func TestControllerWait(t *testing.T) {
task := genTask(t)
ctx, client, ctlr, config, finish := genTestControllerEnv(t, task)
defer finish(t)
evs, errs := makeEvents(t, config, "create", "die")
gomock.InOrder(
client.EXPECT().ContainerInspect(gomock.Any(), config.name()).
Return(types.ContainerJSON{
ContainerJSONBase: &types.ContainerJSONBase{
State: &types.ContainerState{
Status: "running",
},
},
}, nil),
client.EXPECT().Events(gomock.Any(), types.EventsOptions{
Since: "0",
Filters: config.eventFilter(),
}).Return(evs, errs),
client.EXPECT().ContainerInspect(gomock.Any(), config.name()).
Return(types.ContainerJSON{
ContainerJSONBase: &types.ContainerJSONBase{
State: &types.ContainerState{
Status: "stopped", // can be anything but created
},
},
}, nil),
)
assert.NoError(t, ctlr.Wait(ctx))
}
开发者ID:docker,项目名称:swarmkit,代码行数:31,代码来源:controller_test.go
示例17: TestDescribeInstancesErrorCases
func TestDescribeInstancesErrorCases(t *testing.T) {
ctrl := gomock.NewController(t)
mockEC2 := mock_ec2iface.NewMockEC2API(ctrl)
client := NewEC2Client(&config.CliParams{})
client.(*ec2Client).client = mockEC2
defer ctrl.Finish()
expectedIds := []*string{aws.String("id1"), aws.String("id2")}
// Describe returned error
mockEC2.EXPECT().DescribeInstances(gomock.Any()).Return(nil, errors.New("something failed"))
_, err := client.DescribeInstances(expectedIds)
if err == nil {
t.Error("Expected error while Describing EC2 Instances, but got none")
}
// Describe returned nil reservations in the response
mockEC2.EXPECT().DescribeInstances(gomock.Any()).Return(&ec2.DescribeInstancesOutput{}, nil)
_, err = client.DescribeInstances(expectedIds)
if err == nil {
t.Error("Expected error for nil reservations, but got none")
}
// Describe returned empty reservations in the response
mockEC2.EXPECT().DescribeInstances(gomock.Any()).Return(
&ec2.DescribeInstancesOutput{Reservations: []*ec2.Reservation{}}, nil)
_, err = client.DescribeInstances(expectedIds)
if err == nil {
t.Error("Expected error for empty reservations, but got none")
}
}
开发者ID:jloper3,项目名称:amazon-ecs-cli,代码行数:31,代码来源:client_test.go
示例18: TestCreateVpcReturnNilWithErrorIfError
func TestCreateVpcReturnNilWithErrorIfError(t *testing.T) {
//given
ctrl := gomock.NewController(t)
defer ctrl.Finish()
mockEntityService := services_mocks.NewMockEntityService(ctrl)
vpcService := VpcApi{
entityService: mockEntityService,
}
mockError := mocks.MockError{"some_create_vpc_error"}
mockEntityService.EXPECT().Create(gomock.Any(), gomock.Any()).Return(nil, mockError)
vpcToCreate := Vpc{Name: "new_name",
Description: "new_description",
VpcOfferingId: "vpcOfferingId"}
//when
createdVpc, err := vpcService.Create(vpcToCreate)
//then
assert.Nil(t, createdVpc)
assert.Equal(t, mockError, err)
}
开发者ID:cloud-ca,项目名称:go-cloudca,代码行数:27,代码来源:vpc_test.go
示例19: TestCreateNetworkAclReturnCreatedNetworkAclIfSuccess
func TestCreateNetworkAclReturnCreatedNetworkAclIfSuccess(t *testing.T) {
//given
ctrl := gomock.NewController(t)
defer ctrl.Finish()
mockEntityService := services_mocks.NewMockEntityService(ctrl)
networkAclService := NetworkAclApi{
entityService: mockEntityService,
}
networkAclToCreate := NetworkAcl{Name: "new_name",
Description: "new_description",
VpcId: "new_vpc",
}
mockEntityService.EXPECT().Create(gomock.Any(), gomock.Any()).Return([]byte(`{"id":"new_id"}`), nil)
//when
createdNetworkAcl, _ := networkAclService.Create(networkAclToCreate)
//then
if assert.NotNil(t, createdNetworkAcl) {
assert.Equal(t, "new_id", createdNetworkAcl.Id)
}
}
开发者ID:cloud-ca,项目名称:go-cloudca,代码行数:26,代码来源:network_acl_test.go
示例20: TestRouter_SimpleMessageSending
func TestRouter_SimpleMessageSending(t *testing.T) {
ctrl, finish := testutil.NewMockCtrl(t)
defer finish()
a := assert.New(t)
// Given a Router with route
router, r := aRouterRoute(chanSize)
msMock := NewMockMessageStore(ctrl)
router.messageStore = msMock
id, ts := uint64(2), time.Now().Unix()
msMock.EXPECT().
StoreMessage(gomock.Any(), gomock.Any()).
Do(func(m *protocol.Message, nodeID uint8) (int, error) {
m.ID = id
m.Time = ts
m.NodeID = nodeID
return len(m.Bytes()), nil
})
// when i send a message to the route
router.HandleMessage(&protocol.Message{Path: r.Path, Body: aTestByteMessage})
// then I can receive it a short time later
assertChannelContainsMessage(a, r.MessagesChannel(), aTestByteMessage)
}
开发者ID:smancke,项目名称:guble,代码行数:26,代码来源:router_test.go
注:本文中的github.com/golang/mock/gomock.Any函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论