RepoMirrors/go-ceph
1
0
Fork 0
mirror of https://github.com/ceph/go-ceph synced 2025-02-05 04:52:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

rados: test functions for MonCommandTarget

Browse Source 
Signed-off-by: John Mulligan <jmulligan@redhat.com>
This commit is contained in:
John Mulligan 2020-05-20 14:13:26 -04:00 committed by John Mulligan
parent 665611d054
commit 861747663b
1 changed files with 43 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
rados/command_test.go
View File

@ -10,6 +10,7 @@ import (
var (
osdNumber = 0
monName = "a"
)
func (suite *RadosTestSuite) TestMonCommand() {
@ -175,3 +176,45 @@ func (suite *RadosTestSuite) TestOsdCommandMalformedCommand() {
assert.NotEqual(suite.T(), info, "")
assert.Len(suite.T(), buf, 0)
}
func (suite *RadosTestSuite) TestMonCommandTargetDescriptions() {
suite.SetupConnection()
command, err := json.Marshal(
map[string]string{"prefix": "get_command_descriptions", "format": "json"})
assert.NoError(suite.T(), err)
buf, info, err := suite.conn.MonCommandTarget(monName, [][]byte{command})
assert.NoError(suite.T(), err)
assert.Equal(suite.T(), info, "")
var message map[string]interface{}
err = json.Unmarshal(buf, &message)
assert.NoError(suite.T(), err)
}
func (suite *RadosTestSuite) TestMonCommandTarget() {
suite.SetupConnection()
command, err := json.Marshal(
map[string]string{"prefix": "mon_status"})
assert.NoError(suite.T(), err)
buf, info, err := suite.conn.MonCommandTarget(monName, [][]byte{command})
assert.NoError(suite.T(), err)
assert.Equal(suite.T(), info, "")
var message map[string]interface{}
err = json.Unmarshal(buf, &message)
assert.NoError(suite.T(), err)
}
func (suite *RadosTestSuite) TestMonCommandTargetMalformedCommand() {
suite.SetupConnection()
command := []byte("JUNK!")
buf, info, err := suite.conn.MonCommandTarget(monName, [][]byte{command})
assert.Error(suite.T(), err)
assert.NotEqual(suite.T(), info, "")
assert.Len(suite.T(), buf, 0)
}