ridv/gorealis
1
0
Fork 0
Code Issues Pull requests Projects Releases 23 Packages Wiki Activity Actions

Style fixes

Browse source
This commit is contained in:
Renan DelValle 2018-09-14 13:04:58 -07:00
parent d6860e4ca4
commit 7c7f0247fc
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
2 changed files with 5 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

8
realis.go
View file

@ -75,8 +75,8 @@ type Realis interface {
MaintenanceStatus(hosts ...string) (*aurora.Response, *aurora.MaintenanceStatusResult_, error) MaintenanceStatus(hosts ...string) (*aurora.Response, *aurora.MaintenanceStatusResult_, error)
SetQuota(role string, cpu *float64, ram *int64, disk *int64) (*aurora.Response, error) SetQuota(role string, cpu *float64, ram *int64, disk *int64) (*aurora.Response, error)
GetQuota(role string) (*aurora.Response, error) GetQuota(role string) (*aurora.Response, error)
Snapshot() (error) Snapshot() error
PerformBackup() (error) PerformBackup() error
} }
type realisClient struct { type realisClient struct {
@ -1086,7 +1086,7 @@ func (r *realisClient) GetQuota(role string) (*aurora.Response, error) {
} }
// Force Aurora Scheduler to perform a snapshot and write to Mesos log // Force Aurora Scheduler to perform a snapshot and write to Mesos log
func (r *realisClient) Snapshot() (error) { func (r *realisClient) Snapshot() error {
_, retryErr := r.thriftCallWithRetries(func() (*aurora.Response, error) { _, retryErr := r.thriftCallWithRetries(func() (*aurora.Response, error) {
return r.adminClient.Snapshot() return r.adminClient.Snapshot()
@ -1100,7 +1100,7 @@ func (r *realisClient) Snapshot() (error) {
} }
// Force Aurora Scheduler to write backup file to a file in the backup directory // Force Aurora Scheduler to write backup file to a file in the backup directory
func (r *realisClient) PerformBackup() (error) { func (r *realisClient) PerformBackup() error {
_, retryErr := r.thriftCallWithRetries(func() (*aurora.Response, error) { _, retryErr := r.thriftCallWithRetries(func() (*aurora.Response, error) {
return r.adminClient.PerformBackup() return r.adminClient.PerformBackup()

4
realis_e2e_test.go
View file

@ -149,10 +149,8 @@ func TestRealisClient_CreateJob_Thermos(t *testing.T) {
assert.Equal(t, len(result.Configs), 1) assert.Equal(t, len(result.Configs), 1)
assert.NoError(t, err) assert.NoError(t, err)
// Test asking the scheduler to perform a Snpshot // Test asking the scheduler to perform a Snpshot
t.Run("TestRealisClient_Snapshot", func (t *testing.T) { t.Run("TestRealisClient_Snapshot", func(t *testing.T) {
err := r.Snapshot() err := r.Snapshot()
assert.NoError(t, err) assert.NoError(t, err)
}) })