本文整理汇总了Golang中github.com/golang/protobuf/proto.Equal函数的典型用法代码示例。如果您正苦于以下问题:Golang Equal函数的具体用法?Golang Equal怎么用?Golang Equal使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Equal函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: TestController2UpdateActiveBreakpoint
func TestController2UpdateActiveBreakpoint(t *testing.T) {
var expectedResponse *clouddebuggerpb.UpdateActiveBreakpointResponse = &clouddebuggerpb.UpdateActiveBreakpointResponse{}
mockController2.err = nil
mockController2.reqs = nil
mockController2.resps = append(mockController2.resps[:0], expectedResponse)
var debuggeeId string = "debuggeeId-997255898"
var breakpoint *clouddebuggerpb.Breakpoint = &clouddebuggerpb.Breakpoint{}
var request = &clouddebuggerpb.UpdateActiveBreakpointRequest{
DebuggeeId: debuggeeId,
Breakpoint: breakpoint,
}
c, err := NewController2Client(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.UpdateActiveBreakpoint(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockController2.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:trythings,项目名称:trythings,代码行数:34,代码来源:mock_test.go
示例2: TestReportErrorsServiceReportErrorEvent
func TestReportErrorsServiceReportErrorEvent(t *testing.T) {
var expectedResponse *clouderrorreportingpb.ReportErrorEventResponse = &clouderrorreportingpb.ReportErrorEventResponse{}
mockReportErrors.err = nil
mockReportErrors.reqs = nil
mockReportErrors.resps = append(mockReportErrors.resps[:0], expectedResponse)
var formattedProjectName string = ReportErrorsProjectPath("[PROJECT]")
var event *clouderrorreportingpb.ReportedErrorEvent = &clouderrorreportingpb.ReportedErrorEvent{}
var request = &clouderrorreportingpb.ReportErrorEventRequest{
ProjectName: formattedProjectName,
Event: event,
}
c, err := NewReportErrorsClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.ReportErrorEvent(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockReportErrors.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:trythings,项目名称:trythings,代码行数:34,代码来源:mock_test.go
示例3: TestDebugger2ListDebuggees
func TestDebugger2ListDebuggees(t *testing.T) {
var expectedResponse *clouddebuggerpb.ListDebuggeesResponse = &clouddebuggerpb.ListDebuggeesResponse{}
mockDebugger2.err = nil
mockDebugger2.reqs = nil
mockDebugger2.resps = append(mockDebugger2.resps[:0], expectedResponse)
var project string = "project-309310695"
var clientVersion string = "clientVersion-1506231196"
var request = &clouddebuggerpb.ListDebuggeesRequest{
Project: project,
ClientVersion: clientVersion,
}
c, err := NewDebugger2Client(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.ListDebuggees(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockDebugger2.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:trythings,项目名称:trythings,代码行数:34,代码来源:mock_test.go
示例4: TestSubscriberPull
func TestSubscriberPull(t *testing.T) {
var expectedResponse *pubsubpb.PullResponse = &pubsubpb.PullResponse{}
mockSubscriber.err = nil
mockSubscriber.reqs = nil
mockSubscriber.resps = append(mockSubscriber.resps[:0], expectedResponse)
var formattedSubscription string = SubscriberSubscriptionPath("[PROJECT]", "[SUBSCRIPTION]")
var maxMessages int32 = 496131527
var request = &pubsubpb.PullRequest{
Subscription: formattedSubscription,
MaxMessages: maxMessages,
}
c, err := NewSubscriberClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.Pull(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockSubscriber.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:trythings,项目名称:trythings,代码行数:34,代码来源:mock_test.go
示例5: TestClone
func TestClone(t *testing.T) {
m := proto.Clone(cloneTestMessage).(*pb.MyMessage)
if !proto.Equal(m, cloneTestMessage) {
t.Errorf("Clone(%v) = %v", cloneTestMessage, m)
}
// Verify it was a deep copy.
*m.Inner.Port++
if proto.Equal(m, cloneTestMessage) {
t.Error("Mutating clone changed the original")
}
// Byte fields and repeated fields should be copied.
if &m.Pet[0] == &cloneTestMessage.Pet[0] {
t.Error("Pet: repeated field not copied")
}
if &m.Others[0] == &cloneTestMessage.Others[0] {
t.Error("Others: repeated field not copied")
}
if &m.Others[0].Value[0] == &cloneTestMessage.Others[0].Value[0] {
t.Error("Others[0].Value: bytes field not copied")
}
if &m.RepBytes[0] == &cloneTestMessage.RepBytes[0] {
t.Error("RepBytes: repeated field not copied")
}
if &m.RepBytes[0][0] == &cloneTestMessage.RepBytes[0][0] {
t.Error("RepBytes[0]: bytes field not copied")
}
}
开发者ID:zhangcunli,项目名称:go-demo,代码行数:28,代码来源:clone_test.go
示例6: TestIamQueryGrantableRoles
func TestIamQueryGrantableRoles(t *testing.T) {
var expectedResponse *adminpb.QueryGrantableRolesResponse = &adminpb.QueryGrantableRolesResponse{}
mockIam.err = nil
mockIam.reqs = nil
mockIam.resps = append(mockIam.resps[:0], expectedResponse)
var fullResourceName string = "fullResourceName1300993644"
var request = &adminpb.QueryGrantableRolesRequest{
FullResourceName: fullResourceName,
}
c, err := NewIamClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.QueryGrantableRoles(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockIam.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:GoogleCloudPlatform,项目名称:gcloud-golang,代码行数:32,代码来源:mock_test.go
示例7: TestController2RegisterDebuggee
func TestController2RegisterDebuggee(t *testing.T) {
var expectedResponse *clouddebuggerpb.RegisterDebuggeeResponse = &clouddebuggerpb.RegisterDebuggeeResponse{}
mockController2.err = nil
mockController2.reqs = nil
mockController2.resps = append(mockController2.resps[:0], expectedResponse)
var debuggee *clouddebuggerpb.Debuggee = &clouddebuggerpb.Debuggee{}
var request = &clouddebuggerpb.RegisterDebuggeeRequest{
Debuggee: debuggee,
}
c, err := NewController2Client(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.RegisterDebuggee(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockController2.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:trythings,项目名称:trythings,代码行数:32,代码来源:mock_test.go
示例8: TestImageAnnotatorBatchAnnotateImages
func TestImageAnnotatorBatchAnnotateImages(t *testing.T) {
var expectedResponse *visionpb.BatchAnnotateImagesResponse = &visionpb.BatchAnnotateImagesResponse{}
mockImageAnnotator.err = nil
mockImageAnnotator.reqs = nil
mockImageAnnotator.resps = append(mockImageAnnotator.resps[:0], expectedResponse)
var requests []*visionpb.AnnotateImageRequest = nil
var request = &visionpb.BatchAnnotateImagesRequest{
Requests: requests,
}
c, err := NewImageAnnotatorClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.BatchAnnotateImages(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockImageAnnotator.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:GoogleCloudPlatform,项目名称:gcloud-golang,代码行数:32,代码来源:mock_test.go
示例9: TestIamListServiceAccountKeys
func TestIamListServiceAccountKeys(t *testing.T) {
var expectedResponse *adminpb.ListServiceAccountKeysResponse = &adminpb.ListServiceAccountKeysResponse{}
mockIam.err = nil
mockIam.reqs = nil
mockIam.resps = append(mockIam.resps[:0], expectedResponse)
var formattedName string = IamServiceAccountPath("[PROJECT]", "[SERVICE_ACCOUNT]")
var request = &adminpb.ListServiceAccountKeysRequest{
Name: formattedName,
}
c, err := NewIamClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.ListServiceAccountKeys(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockIam.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:GoogleCloudPlatform,项目名称:gcloud-golang,代码行数:32,代码来源:mock_test.go
示例10: TestLoggingServiceV2WriteLogEntries
func TestLoggingServiceV2WriteLogEntries(t *testing.T) {
var expectedResponse *loggingpb.WriteLogEntriesResponse = &loggingpb.WriteLogEntriesResponse{}
mockLogging.err = nil
mockLogging.reqs = nil
mockLogging.resps = append(mockLogging.resps[:0], expectedResponse)
var entries []*loggingpb.LogEntry = nil
var request = &loggingpb.WriteLogEntriesRequest{
Entries: entries,
}
c, err := NewClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.WriteLogEntries(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockLogging.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:GoogleCloudPlatform,项目名称:gcloud-golang,代码行数:32,代码来源:mock_test.go
示例11: TestIamTestIamPermissions
func TestIamTestIamPermissions(t *testing.T) {
var expectedResponse *iampb.TestIamPermissionsResponse = &iampb.TestIamPermissionsResponse{}
mockIam.err = nil
mockIam.reqs = nil
mockIam.resps = append(mockIam.resps[:0], expectedResponse)
var formattedResource string = IamServiceAccountPath("[PROJECT]", "[SERVICE_ACCOUNT]")
var permissions []string = nil
var request = &iampb.TestIamPermissionsRequest{
Resource: formattedResource,
Permissions: permissions,
}
c, err := NewIamClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.TestIamPermissions(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockIam.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:GoogleCloudPlatform,项目名称:gcloud-golang,代码行数:34,代码来源:mock_test.go
示例12: TestSpeechSyncRecognize
func TestSpeechSyncRecognize(t *testing.T) {
var expectedResponse *speechpb.SyncRecognizeResponse = &speechpb.SyncRecognizeResponse{}
mockSpeech.err = nil
mockSpeech.reqs = nil
mockSpeech.resps = append(mockSpeech.resps[:0], expectedResponse)
var config *speechpb.RecognitionConfig = &speechpb.RecognitionConfig{}
var audio *speechpb.RecognitionAudio = &speechpb.RecognitionAudio{}
var request = &speechpb.SyncRecognizeRequest{
Config: config,
Audio: audio,
}
c, err := NewClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.SyncRecognize(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockSpeech.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:trythings,项目名称:trythings,代码行数:34,代码来源:mock_test.go
示例13: TestLanguageServiceAnalyzeSentiment
func TestLanguageServiceAnalyzeSentiment(t *testing.T) {
var language string = "language-1613589672"
var expectedResponse = &languagepb.AnalyzeSentimentResponse{
Language: language,
}
mockLanguage.err = nil
mockLanguage.reqs = nil
mockLanguage.resps = append(mockLanguage.resps[:0], expectedResponse)
var document *languagepb.Document = &languagepb.Document{}
var request = &languagepb.AnalyzeSentimentRequest{
Document: document,
}
c, err := NewClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.AnalyzeSentiment(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockLanguage.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:trythings,项目名称:trythings,代码行数:35,代码来源:mock_test.go
示例14: TestGetSrvKeyspace
// TestGetSrvKeyspace will test we properly return updated SrvKeyspace.
func TestGetSrvKeyspace(t *testing.T) {
ft := &fakeTopo{keyspace: "test_ks"}
rsts := NewResilientSrvTopoServer(topo.Server{Impl: ft}, "TestGetSrvKeyspace")
// ask for the known keyspace, that populates the cache
_, err := rsts.GetSrvKeyspace(context.Background(), "", "test_ks")
if err != nil {
t.Fatalf("GetSrvKeyspace got unexpected error: %v", err)
}
// update srvkeyspace with new value
want := &topodatapb.SrvKeyspace{
ShardingColumnName: "id",
ShardingColumnType: topodatapb.KeyspaceIdType_UINT64,
}
ft.UpdateSrvKeyspace(context.Background(), "", "test_ks", want)
var got *topodatapb.SrvKeyspace
expiry := time.Now().Add(5 * time.Second)
for i := time.Now(); i.Before(expiry); {
got, err = rsts.GetSrvKeyspace(context.Background(), "", "test_ks")
if err != nil {
t.Fatalf("GetSrvKeyspace got unexpected error: %v", err)
}
if proto.Equal(want, got) {
break
}
time.Sleep(10 * time.Millisecond)
}
if !proto.Equal(want, got) {
t.Fatalf("GetSrvKeyspace() = %+v, want %+v", got, want)
}
}
开发者ID:Rastusik,项目名称:vitess,代码行数:34,代码来源:resilient_srv_topo_server_test.go
示例15: TestPublisherGetTopic
func TestPublisherGetTopic(t *testing.T) {
var name string = "name3373707"
var expectedResponse = &pubsubpb.Topic{
Name: name,
}
mockPublisher.err = nil
mockPublisher.reqs = nil
mockPublisher.resps = append(mockPublisher.resps[:0], expectedResponse)
var formattedTopic string = PublisherTopicPath("[PROJECT]", "[TOPIC]")
var request = &pubsubpb.GetTopicRequest{
Topic: formattedTopic,
}
c, err := NewPublisherClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.GetTopic(context.Background(), request)
if err != nil {
t.Fatal(err)
}
if want, got := request, mockPublisher.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
if want, got := expectedResponse, resp; !proto.Equal(want, got) {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:trythings,项目名称:trythings,代码行数:35,代码来源:mock_test.go
示例16: TestMetricServiceListTimeSeries
func TestMetricServiceListTimeSeries(t *testing.T) {
var nextPageToken string = ""
var timeSeriesElement *monitoringpb.TimeSeries = &monitoringpb.TimeSeries{}
var timeSeries = []*monitoringpb.TimeSeries{timeSeriesElement}
var expectedResponse = &monitoringpb.ListTimeSeriesResponse{
NextPageToken: nextPageToken,
TimeSeries: timeSeries,
}
mockMetric.err = nil
mockMetric.reqs = nil
mockMetric.resps = append(mockMetric.resps[:0], expectedResponse)
var formattedName string = MetricProjectPath("[PROJECT]")
var filter string = "filter-1274492040"
var interval *monitoringpb.TimeInterval = &monitoringpb.TimeInterval{}
var view monitoringpb.ListTimeSeriesRequest_TimeSeriesView = 0
var request = &monitoringpb.ListTimeSeriesRequest{
Name: formattedName,
Filter: filter,
Interval: interval,
View: view,
}
c, err := NewMetricClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.ListTimeSeries(context.Background(), request).Next()
if err != nil {
t.Fatal(err)
}
if want, got := request, mockMetric.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
want := (interface{})(expectedResponse.TimeSeries[0])
got := (interface{})(resp)
var ok bool
switch want := (want).(type) {
case proto.Message:
ok = proto.Equal(want, got.(proto.Message))
default:
ok = want == got
}
if !ok {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:GoogleCloudPlatform,项目名称:gcloud-golang,代码行数:54,代码来源:mock_test.go
示例17: TestWatchSrvKeyspaceCancel
func TestWatchSrvKeyspaceCancel(t *testing.T) {
cell := "cell1"
keyspace := "ks1"
ctx := context.Background()
mt := memorytopo.NewMemoryTopo([]string{"global", cell})
ts := topo.Server{Impl: mt}
// No SrvKeyspace -> ErrNoNode
current, changes, cancel := ts.WatchSrvKeyspace(ctx, cell, keyspace)
if current.Err != topo.ErrNoNode {
t.Errorf("Got invalid result from WatchSrvKeyspace(not there): %v", current.Err)
}
// Create initial value
wanted := &topodatapb.SrvKeyspace{
ShardingColumnName: "scn2",
}
contents, err := proto.Marshal(wanted)
if err != nil {
t.Fatalf("proto.Marshal(wanted) failed: %v", err)
}
if _, err := mt.Create(ctx, cell, "/keyspaces/"+keyspace+"/SrvKeyspace", contents); err != nil {
t.Fatalf("Update(/keyspaces/ks1/SrvKeyspace) failed: %v", err)
}
// Starting the watch should now work.
current, changes, cancel = waitForInitialSrvKeyspace(t, ts, cell, keyspace)
if !proto.Equal(current.Value, wanted) {
t.Fatalf("got bad data: %v expected: %v", current.Value, wanted)
}
// Cancel watch, wait for error.
cancel()
for {
wd, ok := <-changes
if !ok {
t.Fatalf("watch channel unexpectedly closed")
}
if wd.Err == topo.ErrInterrupted {
break
}
if wd.Err != nil {
t.Fatalf("watch channel unexpectedly got unknown error: %v", wd.Err)
}
if !proto.Equal(wd.Value, wanted) {
t.Fatalf("got bad data: %v expected: %v", wd.Value, wanted)
}
t.Log("got duplicate right value, skipping.")
}
// Cancel should still work here, although it does nothing.
cancel()
}
开发者ID:erzel,项目名称:vitess,代码行数:53,代码来源:srv_keyspace_test.go
示例18: TestCreateTablet
// TestCreateTablet tests all the logic in the topo.CreateTablet method.
func TestCreateTablet(t *testing.T) {
cell := "cell1"
keyspace := "ks1"
shard := "shard1"
ctx := context.Background()
ts := zktestserver.New(t, []string{cell})
// Create a tablet.
alias := &topodatapb.TabletAlias{
Cell: cell,
Uid: 1,
}
tablet := &topodatapb.Tablet{
Keyspace: keyspace,
Shard: shard,
Alias: alias,
}
if err := ts.CreateTablet(ctx, tablet); err != nil {
t.Fatalf("CreateTablet failed: %v", err)
}
// Get the tablet, make sure it's good. Also check ShardReplication.
ti, err := ts.GetTablet(ctx, alias)
if err != nil || !proto.Equal(ti.Tablet, tablet) {
t.Fatalf("Created Tablet doesn't match: %v %v", ti, err)
}
sri, err := ts.GetShardReplication(ctx, cell, keyspace, shard)
if err != nil || len(sri.Nodes) != 1 || !proto.Equal(sri.Nodes[0].TabletAlias, alias) {
t.Fatalf("Created ShardReplication doesn't match: %v %v", sri, err)
}
// Create the same tablet again, make sure it fails with ErrNodeExists.
if err := ts.CreateTablet(ctx, tablet); err != topo.ErrNodeExists {
t.Fatalf("CreateTablet(again) returned: %v", err)
}
// Remove the ShardReplication record, try to create the
// tablets again, make sure it's fixed.
if err := topo.RemoveShardReplicationRecord(ctx, ts, cell, keyspace, shard, alias); err != nil {
t.Fatalf("RemoveShardReplicationRecord failed: %v", err)
}
sri, err = ts.GetShardReplication(ctx, cell, keyspace, shard)
if err != nil || len(sri.Nodes) != 0 {
t.Fatalf("Modifed ShardReplication doesn't match: %v %v", sri, err)
}
if err := ts.CreateTablet(ctx, tablet); err != topo.ErrNodeExists {
t.Fatalf("CreateTablet(again and again) returned: %v", err)
}
sri, err = ts.GetShardReplication(ctx, cell, keyspace, shard)
if err != nil || len(sri.Nodes) != 1 || !proto.Equal(sri.Nodes[0].TabletAlias, alias) {
t.Fatalf("Created ShardReplication doesn't match: %v %v", sri, err)
}
}
开发者ID:dumbunny,项目名称:vitess,代码行数:54,代码来源:tablet_test.go
示例19: TestProtoCopy
func TestProtoCopy(t *testing.T) {
person := InitData("ronaflx", 195936, "[email protected]")
copyPerson := person
if !proto.Equal(person, copyPerson) {
t.Errorf("expect:\n%s\nactual:\n%s\n", proto.MarshalTextString(person), proto.MarshalTextString(
copyPerson))
}
msg := proto.Clone(person)
if !proto.Equal(person, msg) {
t.Errorf("expect:\n%s\nactual:\n%s\n", proto.MarshalTextString(person), proto.MarshalTextString(
msg))
}
}
开发者ID:ronaflx,项目名称:opensource-tutorial,代码行数:13,代码来源:proto_test.go
示例20: TestGroupServiceListGroupMembers
func TestGroupServiceListGroupMembers(t *testing.T) {
var nextPageToken string = ""
var totalSize int32 = -705419236
var membersElement *monitoredrespb.MonitoredResource = &monitoredrespb.MonitoredResource{}
var members = []*monitoredrespb.MonitoredResource{membersElement}
var expectedResponse = &monitoringpb.ListGroupMembersResponse{
NextPageToken: nextPageToken,
TotalSize: totalSize,
Members: members,
}
mockGroup.err = nil
mockGroup.reqs = nil
mockGroup.resps = append(mockGroup.resps[:0], expectedResponse)
var formattedName string = GroupGroupPath("[PROJECT]", "[GROUP]")
var request = &monitoringpb.ListGroupMembersRequest{
Name: formattedName,
}
c, err := NewGroupClient(context.Background(), clientOpt)
if err != nil {
t.Fatal(err)
}
resp, err := c.ListGroupMembers(context.Background(), request).Next()
if err != nil {
t.Fatal(err)
}
if want, got := request, mockGroup.reqs[0]; !proto.Equal(want, got) {
t.Errorf("wrong request %q, want %q", got, want)
}
want := (interface{})(expectedResponse.Members[0])
got := (interface{})(resp)
var ok bool
switch want := (want).(type) {
case proto.Message:
ok = proto.Equal(want, got.(proto.Message))
default:
ok = want == got
}
if !ok {
t.Errorf("wrong response %q, want %q)", got, want)
}
}
开发者ID:GoogleCloudPlatform,项目名称:gcloud-golang,代码行数:50,代码来源:mock_test.go
注:本文中的github.com/golang/protobuf/proto.Equal函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论