本文整理汇总了Golang中github.com/facebookgo/ensure.NotNil函数的典型用法代码示例。如果您正苦于以下问题:Golang NotNil函数的具体用法?Golang NotNil怎么用?Golang NotNil使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了NotNil函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: CheckOpsReader
// Verify if the items being read are as expected.
func CheckOpsReader(t *testing.T, loader OpsReader) {
expectedOpsRead := 0
const startingTs = 1396456709420
for op := loader.Next(); op != nil; op = loader.Next() {
expectedOpsRead += 1
ensure.NotNil(t, op)
ensure.DeepEqual(t, loader.OpsRead(), expectedOpsRead)
// check the "ts" field
CheckTime(t, float64(startingTs+loader.OpsRead()), op.Timestamp)
// check the insert doc
// certain key exists
for i := 1; i <= 5; i++ {
logTypeKey := fmt.Sprintf("logType%d", i)
logType, ok := GetElem(op.InsertDoc, logTypeKey)
if i != expectedOpsRead {
ensure.False(t, ok)
ensure.Nil(t, logType)
} else {
ensure.True(t, ok)
ensure.NotNil(t, logType)
}
}
// check the value for the shared key
message := fmt.Sprintf("m%d", expectedOpsRead)
actualMessage, ok := GetElem(op.InsertDoc, "message")
ensure.True(t, ok)
ensure.DeepEqual(t, actualMessage.(string), message)
}
ensure.DeepEqual(t, expectedOpsRead, 5)
}
开发者ID:bradparks,项目名称:flashback,代码行数:33,代码来源:ops_reader_test.go
示例2: TestUploadFiles
func TestUploadFiles(t *testing.T) {
t.Parallel()
h := parsecli.NewHarness(t)
defer h.Stop()
h.MakeEmptyRoot()
createRandomFiles(t, h)
names := []string{"a", "b"}
ht := parsecli.TransportFunc(func(r *http.Request) (*http.Response, error) {
switch filepath.Base(r.URL.Path) {
case names[0]:
ensure.NotNil(t, r.Header)
ensure.DeepEqual(t, r.Header.Get("Key"), "Value")
ensure.DeepEqual(t, r.Header.Get("Content-Type"), "application/octet-stream")
ensure.DeepEqual(t, r.Header.Get("Content-MD5"), "4JnleFGzGppuArF6N50EWg==")
return &http.Response{
StatusCode: http.StatusOK,
Body: ioutil.NopCloser(strings.NewReader(`{"status":"success"}`)),
}, nil
case names[1]:
ensure.NotNil(t, r.Header)
ensure.DeepEqual(t, r.Header.Get("Key"), "Value")
ensure.DeepEqual(t, r.Header.Get("Content-Type"), "application/octet-stream")
ensure.DeepEqual(t, r.Header.Get("Content-MD5"), "Fv43qsp6mnGCJlC00VkOcA==")
return &http.Response{
StatusCode: http.StatusOK,
Body: ioutil.NopCloser(strings.NewReader(`{"status":"success"}`)),
}, nil
default:
return &http.Response{
StatusCode: http.StatusInternalServerError,
Body: ioutil.NopCloser(strings.NewReader(`{"error":"something is wrong"}`)),
}, nil
}
})
h.Env.ParseAPIClient = &parsecli.ParseAPIClient{APIClient: &parse.Client{Transport: ht}}
var filenames []string
for _, name := range names {
filenames = append(filenames, filepath.Join(h.Env.Root, name))
}
ensure.Nil(t, uploadSymbolFiles(filenames[:],
map[string]string{"Key": "Value"}, true, h.Env))
for _, filename := range filenames {
_, err := os.Lstat(filename)
ensure.NotNil(t, err)
ensure.True(t, os.IsNotExist(err))
}
}
开发者ID:swhitley,项目名称:parse-cli,代码行数:50,代码来源:parse_symbol_uploader_test.go
示例3: TestServerAbort
func TestServerAbort(t *testing.T) {
t.Parallel()
for _, code := range []int{200, 500} {
server := httptest.NewServer(
http.HandlerFunc(
func(w http.ResponseWriter, r *http.Request) {
w.Header().Add("Content-Length", "4000")
w.WriteHeader(code)
w.Write(bytes.Repeat([]byte("a"), 3000))
},
),
)
u, err := url.Parse(server.URL)
ensure.Nil(t, err)
c := &parse.Client{
Credentials: defaultRestAPIKey,
BaseURL: u,
}
res := make(map[string]interface{})
_, err = c.Get(nil, res)
ensure.NotNil(t, err)
server.CloseClientConnections()
server.Close()
}
}
开发者ID:fesanlu,项目名称:parse,代码行数:27,代码来源:parse_test.go
示例4: TestProvideWithFields
func TestProvideWithFields(t *testing.T) {
var g inject.Graph
a := &TypeAnswerStruct{}
err := g.Provide(&inject.Object{Value: a, Fields: map[string]*inject.Object{}})
ensure.NotNil(t, err)
ensure.DeepEqual(t, err.Error(), "fields were specified on object *inject_test.TypeAnswerStruct when it was provided")
}
开发者ID:stellar,项目名称:bridge-server,代码行数:7,代码来源:inject_test.go
示例5: TestServerAbort
func TestServerAbort(t *testing.T) {
t.Parallel()
for _, code := range []int{200, 500} {
server := httptest.NewServer(
http.HandlerFunc(
func(w http.ResponseWriter, r *http.Request) {
w.Header().Add("Content-Length", "4000")
w.WriteHeader(code)
w.Write(bytes.Repeat([]byte("a"), 3000))
},
),
)
u, err := url.Parse(server.URL)
ensure.Nil(t, err)
c := &fbapi.Client{
BaseURL: u,
}
_, err = c.Do(&http.Request{Method: "GET"}, nil)
ensure.NotNil(t, err)
ensure.Err(t, err, regexp.MustCompile("(invalid character|EOF)"))
server.CloseClientConnections()
server.Close()
}
}
开发者ID:jimneath,项目名称:fbapi,代码行数:26,代码来源:client_test.go
示例6: TestPrintListNoConfig
func TestPrintListNoConfig(t *testing.T) {
t.Parallel()
h, l := newListCmdHarness(t)
h.makeEmptyRoot()
defer h.Stop()
ensure.NotNil(t, l.printListOfApps(h.env))
ensure.DeepEqual(t, h.Out.String(), "")
}
开发者ID:Georotzen,项目名称:parse-cli,代码行数:8,代码来源:list_cmd_test.go
示例7: TestMissingCredentials
func TestMissingCredentials(t *testing.T) {
t.Parallel()
var c parse.Client
req := http.Request{Method: "GET", URL: &url.URL{Path: "classes/Foo/Bar"}}
_, err := c.Do(&req, nil, nil)
ensure.NotNil(t, err)
ensure.Err(t, err, regexp.MustCompile(`parse: api error with message="unauthorized"`))
}
开发者ID:fesanlu,项目名称:parse,代码行数:8,代码来源:integration_test.go
示例8: TestInheritErrorOnListenUnixWithInvalidCount
func TestInheritErrorOnListenUnixWithInvalidCount(t *testing.T) {
var n Net
os.Setenv(envCountKey, "a")
tmpdir, err := ioutil.TempDir("", "TestInheritErrorOnListenUnixWithInvalidCount-")
ensure.Nil(t, err)
ensure.Nil(t, os.RemoveAll(tmpdir))
_, err = n.Listen("unix", filepath.Join(tmpdir, "socket"))
ensure.NotNil(t, err)
}
开发者ID:absolute8511,项目名称:grace,代码行数:9,代码来源:net_test.go
示例9: TestBase64MD5OfFileNoFile
func TestBase64MD5OfFileNoFile(t *testing.T) {
t.Parallel()
h := parsecli.NewHarness(t)
defer h.Stop()
h.MakeEmptyRoot()
testFile := filepath.Join(h.Env.Root, "test")
_, err := base64MD5OfFile(testFile)
ensure.NotNil(t, err)
}
开发者ID:swhitley,项目名称:parse-cli,代码行数:10,代码来源:parse_symbol_uploader_test.go
示例10: TestReleasesCmdError
func TestReleasesCmdError(t *testing.T) {
h, c := newReleasesCmdHarness(t)
defer h.Stop()
ht := parsecli.TransportFunc(func(r *http.Request) (*http.Response, error) {
return nil, stackerr.New("Throws error")
})
h.Env.ParseAPIClient = &parsecli.ParseAPIClient{APIClient: &parse.Client{Transport: ht}}
ensure.NotNil(t, c.run(h.Env, &parsecli.Context{}))
}
开发者ID:swhitley,项目名称:parse-cli,代码行数:10,代码来源:releases_test.go
示例11: TestNewConfig
func TestNewConfig(t *testing.T) {
var err error
// CASE 1: unmarshalling err
_, err = newConfig(strings.NewReader("?????"))
ensure.NotNil(t, err)
// CASE 2: success!
_, err = newConfig(strings.NewReader(""))
ensure.Nil(t, err)
}
开发者ID:FPurchess,项目名称:blank,代码行数:11,代码来源:config_test.go
示例12: Start
// Start starts server used for MockS3
func (s *MockS3) Start(t *testing.T) {
srv, err := s3test.NewServer(s.config)
ensure.Nil(t, err)
ensure.NotNil(t, srv)
s.srv = srv
s.region = aws.Region{
Name: "faux-region-1",
S3Endpoint: srv.URL(),
S3LocationConstraint: true, // s3test server requires a LocationConstraint
}
}
开发者ID:naytzyrhc,项目名称:rocks-strata,代码行数:13,代码来源:mock_storage.go
示例13: CheckSetStartTime
func CheckSetStartTime(t *testing.T, loader OpsReader) {
expectedOpsRead := 0
numSkipped, err := loader.SetStartTime(1396456709424)
ensure.Nil(t, err)
ensure.DeepEqual(t, numSkipped, int64(4))
for op := loader.Next(); op != nil; op = loader.Next() {
expectedOpsRead += 1
ensure.NotNil(t, op)
ensure.DeepEqual(t, loader.OpsRead(), expectedOpsRead)
}
// Verify that only 4 ops are read, since we skipped one
ensure.DeepEqual(t, expectedOpsRead, 1)
}
开发者ID:bradparks,项目名称:flashback,代码行数:15,代码来源:ops_reader_test.go
示例14: CheckSkipOps
func CheckSkipOps(t *testing.T, loader OpsReader) {
expectedOpsRead := 0
// Skip a single op
loader.SkipOps(1)
// Read all remaining ops
for op := loader.Next(); op != nil; op = loader.Next() {
expectedOpsRead += 1
ensure.NotNil(t, op)
ensure.DeepEqual(t, loader.OpsRead(), expectedOpsRead)
}
// Verify that only 4 ops are read, since we skipped one
ensure.DeepEqual(t, expectedOpsRead, 4)
}
开发者ID:bradparks,项目名称:flashback,代码行数:16,代码来源:ops_reader_test.go
示例15: TestSafeGetInt
func TestSafeGetInt(t *testing.T) {
val, err := safeGetInt(int32(11))
ensure.Nil(t, err)
ensure.DeepEqual(t, val, int(11))
val, err = safeGetInt(int64(11))
ensure.Nil(t, err)
ensure.DeepEqual(t, val, int(11))
val, err = safeGetInt(float32(11))
ensure.Nil(t, err)
ensure.DeepEqual(t, val, int(11))
val, err = safeGetInt(float64(11))
ensure.Nil(t, err)
ensure.DeepEqual(t, val, int(11))
val, err = safeGetInt("a")
ensure.NotNil(t, err)
}
开发者ID:bradparks,项目名称:flashback,代码行数:16,代码来源:ops_executor_test.go
示例16: TestRunWithAppNamed
func TestRunWithAppNamed(t *testing.T) {
t.Parallel()
h := newHarness(t)
defer h.Stop()
const appName = "a"
c := &parseConfig{
Applications: map[string]*parseAppConfig{
appName: {ApplicationID: "id", MasterKey: "token"},
},
}
h.makeWithConfig(jsonStr(t, c))
r := runWithClient(h.env, func(e *env, c *context) error {
ensure.NotNil(t, c)
return nil
})
r(noOpCmd(), []string{"a"})
}
开发者ID:hassanabidpk,项目名称:parse-cli,代码行数:17,代码来源:main_test.go
示例17: TestRunWithDefault
func TestRunWithDefault(t *testing.T) {
t.Parallel()
h := NewHarness(t)
defer h.Stop()
const appName = "a"
c := &ParseConfig{
Applications: map[string]*ParseAppConfig{
appName: {ApplicationID: "id", MasterKey: "token"},
DefaultKey: {Link: appName},
},
}
h.MakeWithConfig(jsonStr(t, c))
r := RunWithClient(h.Env, func(e *Env, c *Context) error {
ensure.NotNil(t, c)
return nil
})
r(noOpCmd(), []string{"a"})
}
开发者ID:swhitley,项目名称:parse-cli,代码行数:18,代码来源:runners_test.go
示例18: TestParseVersionFromBytes
func TestParseVersionFromBytes(t *testing.T) {
t.Parallel()
_, err := parseVersionFromBytes([]byte(`versionCode='a'`))
ensure.NotNil(t, err)
tests := []struct {
input string
expected int
}{
{`versionCode='1'`, 1},
{`versionCode='12'`, 12},
{`versionCode='1234'`, 1234},
{`versionCode='12345678'`, 12345678},
}
for _, test := range tests {
actual, err := parseVersionFromBytes([]byte(test.input))
ensure.Nil(t, err)
ensure.DeepEqual(t, actual, test.expected)
}
}
开发者ID:swhitley,项目名称:parse-cli,代码行数:22,代码来源:android_symbol_uploader_test.go
示例19: TestRunWithAppError
func TestRunWithAppError(t *testing.T) {
t.Parallel()
h := newHarness(t)
defer h.Stop()
const appName = "a"
c := &parseConfig{
Applications: map[string]*parseAppConfig{
appName: {ApplicationID: "id", MasterKey: "token"},
},
}
h.makeWithConfig(jsonStr(t, c))
h.env.Exit = func(i int) { panic(exitCode(i)) }
const message = "hello world"
func() {
defer ensure.PanicDeepEqual(t, exitCode(1))
r := runWithClient(h.env, func(e *env, c *context) error {
ensure.NotNil(t, c)
return errors.New(message)
})
r(noOpCmd(), []string{"a"})
}()
ensure.StringContains(t, h.Err.String(), message)
}
开发者ID:hassanabidpk,项目名称:parse-cli,代码行数:23,代码来源:main_test.go
示例20: TestEnsureIndex
// inserting data voilating index clause on a separate connection should fail
func TestEnsureIndex(t *testing.T) {
t.Parallel()
p := NewSingleHarness(t)
defer p.Stop()
session := p.ProxySession()
collection := session.DB("test").C("coll1")
index := mgo.Index{
Key: []string{"lastname", "firstname"},
Unique: true,
DropDups: true,
Background: true, // See notes.
Sparse: true,
}
err := collection.EnsureIndex(index)
ensure.Nil(t, err)
err = collection.Insert(
map[string]string{
"firstname": "harvey",
"lastname": "dent",
},
)
if err != nil {
t.Fatal("insertion error", err)
}
session.Close()
session = p.ProxySession()
defer session.Close()
collection = session.DB("test").C("coll1")
err = collection.Insert(
map[string]string{
"firstname": "harvey",
"lastname": "dent",
},
)
ensure.NotNil(t, err)
}
开发者ID:wptad,项目名称:dvara,代码行数:37,代码来源:proxy_test.go
注:本文中的github.com/facebookgo/ensure.NotNil函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论