本文整理汇总了Golang中github.com/elleFlorio/gru/Godeps/_workspace/src/github.com/stretchr/testify/assert.NoError函数的典型用法代码示例。如果您正苦于以下问题:Golang NoError函数的具体用法?Golang NoError怎么用?Golang NoError使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了NoError函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: TestDoubleLoggingDoesntPrefixPreviousFields
func TestDoubleLoggingDoesntPrefixPreviousFields(t *testing.T) {
var buffer bytes.Buffer
var fields Fields
logger := New()
logger.Out = &buffer
logger.Formatter = new(JSONFormatter)
llog := logger.WithField("context", "eating raw fish")
llog.Info("looks delicious")
err := json.Unmarshal(buffer.Bytes(), &fields)
assert.NoError(t, err, "should have decoded first message")
assert.Equal(t, len(fields), 4, "should only have msg/time/level/context fields")
assert.Equal(t, fields["msg"], "looks delicious")
assert.Equal(t, fields["context"], "eating raw fish")
buffer.Reset()
llog.Warn("omg it is!")
err = json.Unmarshal(buffer.Bytes(), &fields)
assert.NoError(t, err, "should have decoded second message")
assert.Equal(t, len(fields), 4, "should only have msg/time/level/context fields")
assert.Equal(t, fields["msg"], "omg it is!")
assert.Equal(t, fields["context"], "eating raw fish")
assert.Nil(t, fields["fields.msg"], "should not have prefixed previous `msg` entry")
}
开发者ID:elleFlorio,项目名称:gru,代码行数:31,代码来源:logrus_test.go
示例2: TestDeleteData
func TestDeleteData(t *testing.T) {
intern := 0
key := "test"
data := []byte("pippo")
var value []byte
var err error
//INTERNAL
dataStore = intern
Initialize()
StoreData(key, data, enum.STATS)
StoreData(key, data, enum.ANALYTICS)
StoreData(key, data, enum.POLICIES)
StoreData(key, data, enum.SHARED)
err = DeleteData(key, enum.STATS)
assert.NoError(t, err)
value, _ = GetData(key, enum.STATS)
assert.Nil(t, value)
err = DeleteData(key, enum.ANALYTICS)
assert.NoError(t, err)
value, _ = GetData(key, enum.ANALYTICS)
assert.Nil(t, value)
err = DeleteData(key, enum.POLICIES)
assert.NoError(t, err)
value, _ = GetData(key, enum.POLICIES)
assert.Nil(t, value)
err = DeleteData(key, enum.SHARED)
assert.NoError(t, err)
value, _ = GetData(key, enum.SHARED)
assert.Nil(t, value)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:32,代码来源:datastore_test.go
示例3: TestAddServiceInstance
func TestAddServiceInstance(t *testing.T) {
defer cfg.CleanServices()
cfg.SetServices(CreateMockServices())
name := "service1"
service, _ := GetServiceByName(name)
instance_p := "instance1_100"
instance_ps := "instance1_101"
instance_s := "instance1_102"
var err error
var status enum.Status
status = enum.PENDING
err = AddServiceInstance(name, instance_p, status)
assert.NoError(t, err)
assert.Contains(t, service.Instances.All, instance_p)
assert.Contains(t, service.Instances.Pending, instance_p)
status = enum.PAUSED
err = AddServiceInstance(name, instance_ps, status)
assert.NoError(t, err)
assert.Contains(t, service.Instances.All, instance_ps)
assert.Contains(t, service.Instances.Paused, instance_ps)
status = enum.STOPPED
err = AddServiceInstance(name, instance_s, status)
assert.NoError(t, err)
assert.Contains(t, service.Instances.All, instance_s)
assert.Contains(t, service.Instances.Stopped, instance_s)
status = enum.PENDING
err = AddServiceInstance("pippo", "pippo", status)
assert.Error(t, err)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:33,代码来源:service_test.go
示例4: TestGetCompleteRange
func TestGetCompleteRange(t *testing.T) {
var err error
var result []string
invalid := "pippo"
invalidLimit := "pippo-10"
onveValue := "5"
valid := "0-10"
_, err = GetCompleteRange(invalid)
assert.Error(t, err)
_, err = GetCompleteRange(invalidLimit)
assert.Error(t, err)
result, err = GetCompleteRange(onveValue)
assert.NoError(t, err)
assert.Len(t, result, 1)
assert.Contains(t, result, "5")
result, err = GetCompleteRange(valid)
assert.NoError(t, err)
assert.Len(t, result, 11)
assert.Contains(t, result, "0")
assert.Contains(t, result, "10")
assert.NotContains(t, result, "11")
}
开发者ID:elleFlorio,项目名称:gru,代码行数:28,代码来源:range_test.go
示例5: TestChooseRandomFriends
func TestChooseRandomFriends(t *testing.T) {
cfg.SetNode(node.CreateMockNode())
mockPeers := createMockPeers(100)
nFriends := 10
test, err := chooseRandomFriends(mockPeers, nFriends)
assert.NoError(t, err, "(nFrineds > 0) Choose friends should produce no error")
nFriends = 150
test, err = chooseRandomFriends(mockPeers, nFriends)
friendsKeys := make([]string, 0, len(mockPeers)-1)
for key, _ := range test {
friendsKeys = append(friendsKeys, key)
}
assert.NoError(t, err, "(nFrineds > nPeers) Choose friends should produce no error")
nFriends = 0
test, err = chooseRandomFriends(mockPeers, nFriends)
assert.Error(t, err, "(nFriends < 0) Choose friends should produce an error")
mockPeers = createMockPeers(0)
nFriends = 10
_, err = chooseRandomFriends(mockPeers, nFriends)
assert.Error(t, err, "(peers = 0) Choose friend should produce an error")
mockPeers = createMockPeers(1)
nFriends = 10
_, err = chooseRandomFriends(mockPeers, nFriends)
assert.Error(t, err, "(peers = me) Choose friend should produce an error")
mockPeers = createMockPeers(2)
nFriends = 10
test, err = chooseRandomFriends(mockPeers, nFriends)
assert.NoError(t, err, "(nFrineds == 2) Choose friends should produce no error")
}
开发者ID:elleFlorio,项目名称:gru,代码行数:34,代码来源:communication_test.go
示例6: TestAssignSpecificPortsToService
func TestAssignSpecificPortsToService(t *testing.T) {
defer clearServicePorts()
var err error
createServicePorts()
service := "pippo"
id := "123456789"
port1 := "50100"
port2 := "50200"
bindings := map[string][]string{
port1: []string{"50100"},
port2: []string{"50200"},
}
err = AssignSpecifiPortsToService(service, id, bindings)
assert.NoError(t, err)
available1 := resources.Network.ServicePorts[service].Status[port1].Available
occupied1 := resources.Network.ServicePorts[service].Status[port1].Occupied
assert.Len(t, available1, 3)
assert.Len(t, occupied1, 1)
available2 := resources.Network.ServicePorts[service].Status[port2].Available
occupied2 := resources.Network.ServicePorts[service].Status[port2].Occupied
assert.Len(t, available2, 1)
assert.Len(t, occupied2, 1)
assert.NotEmpty(t, instanceBindings)
err = AssignSpecifiPortsToService(service, id, bindings)
assert.Error(t, err)
available1 = resources.Network.ServicePorts[service].Status[port1].Available
occupied1 = resources.Network.ServicePorts[service].Status[port1].Occupied
assert.Len(t, available1, 3)
assert.Len(t, occupied1, 1)
available2 = resources.Network.ServicePorts[service].Status[port2].Available
occupied2 = resources.Network.ServicePorts[service].Status[port2].Occupied
assert.Len(t, available2, 1)
assert.Len(t, occupied2, 1)
bindings[port1] = []string{"50000"}
bindings[port2] = []string{"50201"}
err = AssignSpecifiPortsToService(service, id, bindings)
assert.NoError(t, err)
available1 = resources.Network.ServicePorts[service].Status[port1].Available
occupied1 = resources.Network.ServicePorts[service].Status[port1].Occupied
assert.Len(t, available1, 3)
assert.Len(t, occupied1, 2)
available2 = resources.Network.ServicePorts[service].Status[port2].Available
occupied2 = resources.Network.ServicePorts[service].Status[port2].Occupied
assert.Len(t, available2, 0)
assert.Len(t, occupied2, 2)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:50,代码来源:resources_test.go
示例7: TestGetAllData
func TestGetAllData(t *testing.T) {
intern := 0
//INTERNAL
dataStore = intern
Initialize()
_, err := GetAllData(enum.STATS)
assert.NoError(t, err)
_, err = GetAllData(enum.ANALYTICS)
assert.NoError(t, err)
_, err = GetAllData(enum.POLICIES)
assert.NoError(t, err)
_, err = GetAllData(enum.SHARED)
assert.NoError(t, err)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:15,代码来源:datastore_test.go
示例8: TestChangeServiceInstanceStatus
func TestChangeServiceInstanceStatus(t *testing.T) {
defer cfg.CleanServices()
cfg.SetServices(CreateMockServices())
name := "service1"
service, _ := GetServiceByName(name)
instance := "instance1_3"
var prev enum.Status
var upd enum.Status
var err error
prev = enum.PENDING
upd = enum.RUNNING
err = ChangeServiceInstanceStatus(name, instance, prev, upd)
assert.NotContains(t, service.Instances.Pending, instance)
assert.Contains(t, service.Instances.Running, instance)
assert.NoError(t, err)
prev = enum.RUNNING
upd = enum.PAUSED
err = ChangeServiceInstanceStatus(name, instance, prev, upd)
assert.NotContains(t, service.Instances.Running, instance)
assert.Contains(t, service.Instances.Paused, instance)
assert.NoError(t, err)
prev = enum.PAUSED
upd = enum.STOPPED
err = ChangeServiceInstanceStatus(name, instance, prev, upd)
assert.NotContains(t, service.Instances.Paused, instance)
assert.Contains(t, service.Instances.Stopped, instance)
assert.NoError(t, err)
prev = enum.STOPPED
upd = enum.PENDING
err = ChangeServiceInstanceStatus(name, instance, prev, upd)
assert.NotContains(t, service.Instances.Stopped, instance)
assert.Contains(t, service.Instances.Pending, instance)
assert.NoError(t, err)
prev = enum.PENDING
upd = enum.RUNNING
err = ChangeServiceInstanceStatus("pippo", instance, prev, upd)
assert.Error(t, err)
prev = enum.PENDING
upd = enum.RUNNING
err = ChangeServiceInstanceStatus(name, "pippo", prev, upd)
assert.Error(t, err)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:48,代码来源:service_test.go
示例9: TestRequestPortsForService
func TestRequestPortsForService(t *testing.T) {
defer clearServicePorts()
var err error
createServicePorts()
service := "pippo"
port1 := "50100"
port2 := "50200"
result, err := RequestPortsForService(service)
assert.NoError(t, err)
assert.Len(t, result, 2)
assert.Len(t, resources.Network.ServicePorts[service].LastRequested, 2)
available1 := resources.Network.ServicePorts[service].Status[port1].Available
occupied1 := resources.Network.ServicePorts[service].Status[port1].Occupied
assert.Len(t, available1, 4)
assert.Len(t, occupied1, 0)
available2 := resources.Network.ServicePorts[service].Status[port2].Available
occupied2 := resources.Network.ServicePorts[service].Status[port2].Occupied
assert.Len(t, available2, 2)
assert.Len(t, occupied2, 0)
ports := resources.Network.ServicePorts[service]
status := ports.Status[port1]
status.Available = []string{}
ports.Status[port1] = status
resources.Network.ServicePorts[service] = ports
_, err = RequestPortsForService(service)
assert.Error(t, err)
assert.Empty(t, resources.Network.ServicePorts[service].LastRequested)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:30,代码来源:resources_test.go
示例10: LogAndAssertText
func LogAndAssertText(t *testing.T, log func(*Logger), assertions func(fields map[string]string)) {
var buffer bytes.Buffer
logger := New()
logger.Out = &buffer
logger.Formatter = &TextFormatter{
DisableColors: true,
}
log(logger)
fields := make(map[string]string)
for _, kv := range strings.Split(buffer.String(), " ") {
if !strings.Contains(kv, "=") {
continue
}
kvArr := strings.Split(kv, "=")
key := strings.TrimSpace(kvArr[0])
val := kvArr[1]
if kvArr[1][0] == '"' {
var err error
val, err = strconv.Unquote(val)
assert.NoError(t, err)
}
fields[key] = val
}
assertions(fields)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:28,代码来源:logrus_test.go
示例11: TestCreateInfluxMetrics
func TestCreateInfluxMetrics(t *testing.T) {
New("influxdb", createInfluxMockConfig())
mockMetrics := CreateMockMetrics()
points, err := createInfluxMetrics(mockMetrics)
assert.NoError(t, err)
assert.NotEmpty(t, points)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:7,代码来源:metric_test.go
示例12: TestStoreClusterData
func TestStoreClusterData(t *testing.T) {
New("internal")
var err error
data := []byte{1, 2, 3, 4, 5}
err = StoreClusterData(data, enum.POLICIES)
assert.NoError(t, err)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:8,代码来源:datastore_test.go
示例13: TestGetServiceById
func TestGetServiceById(t *testing.T) {
defer cfg.CleanServices()
var err error
cfg.SetServices(CreateMockServices())
srv1, err := GetServiceById("instance1_0")
assert.NoError(t, err)
assert.Equal(t, "service1", srv1.Name)
srv2, err := GetServiceById("instance2_1")
assert.NoError(t, err)
assert.Equal(t, "service2", srv2.Name)
_, err = GetServiceById("pippo")
assert.Error(t, err)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:17,代码来源:service_test.go
示例14: TestStoreData
func TestStoreData(t *testing.T) {
intern := 0
key := "test"
data := []byte("pippo")
var err error
//INTERNAL
dataStore = intern
Initialize()
err = StoreData(key, data, enum.STATS)
assert.NoError(t, err)
err = StoreData(key, data, enum.ANALYTICS)
assert.NoError(t, err)
err = StoreData(key, data, enum.POLICIES)
assert.NoError(t, err)
err = StoreData(key, data, enum.SHARED)
assert.NoError(t, err)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:18,代码来源:datastore_test.go
示例15: TestGetClusterData
func TestGetClusterData(t *testing.T) {
data := []byte{1, 2, 3, 4, 5}
New("intenal")
StoreData(enum.CLUSTER.ToString(), data, enum.POLICIES)
test, err := GetClusterData(enum.POLICIES)
assert.NoError(t, err)
assert.Equal(t, data, test)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:9,代码来源:datastore_test.go
示例16: TestNew
func TestNew(t *testing.T) {
var err error
_, err = New("dummy")
assert.NoError(t, err)
assert.Equal(t, "dummy", Name())
_, err = New("probcumulative")
assert.NoError(t, err)
assert.Equal(t, "probcumulative", Name())
_, err = New("probdelta")
assert.NoError(t, err)
assert.Equal(t, "probdelta", Name())
_, err = New("notImplemented")
assert.Error(t, err)
assert.Equal(t, "dummy", Name())
}
开发者ID:elleFlorio,项目名称:gru,代码行数:19,代码来源:stategy_test.go
示例17: TestGetAnalytics
func TestGetAnalytics(t *testing.T) {
defer storage.DeleteAllData(enum.ANALYTICS)
var err error
_, err = GetAnalytics()
assert.Error(t, err)
expected := CreateMockAnalytics()
SaveMockAnalytics()
analytics, err := GetAnalytics()
assert.NoError(t, err)
assert.Equal(t, expected, analytics)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:13,代码来源:data_test.go
示例18: TestGetStats
func TestGetStats(t *testing.T) {
defer storage.DeleteAllData(enum.STATS)
var err error
_, err = GetStats()
assert.Error(t, err)
expected := CreateMockStats()
SaveMockStats()
stats, err := GetStats()
assert.NoError(t, err)
assert.Equal(t, expected, stats)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:13,代码来源:data_test.go
示例19: TestGetPolicy
func TestGetPolicy(t *testing.T) {
defer storage.DeleteAllData(enum.POLICIES)
var err error
_, err = GetPolicy()
assert.Error(t, err)
expected := CreateRandomMockPolicies(1)[0]
SavePolicy(expected)
policy, err := GetPolicy()
assert.NoError(t, err)
assert.Equal(t, expected, policy)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:13,代码来源:data_test.go
示例20: TestGeShared
func TestGeShared(t *testing.T) {
defer storage.DeleteAllData(enum.SHARED)
var err error
expected := CreateMockShared()
// Local
_, err = GetSharedLocal()
assert.Error(t, err)
SaveSharedLocal(expected)
info, err := GetSharedLocal()
assert.NoError(t, err)
assert.Equal(t, expected, info)
// Local
_, err = GetSharedCluster()
assert.Error(t, err)
SaveSharedCluster(expected)
info, err = GetSharedCluster()
assert.NoError(t, err)
assert.Equal(t, expected, info)
}
开发者ID:elleFlorio,项目名称:gru,代码行数:23,代码来源:data_test.go
注:本文中的github.com/elleFlorio/gru/Godeps/_workspace/src/github.com/stretchr/testify/assert.NoError函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论