-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #94 from ukfast/volume-groups
add volume group crud operations
- Loading branch information
Showing
8 changed files
with
707 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,193 @@ | ||
| package ecloud | ||
|
|
||
| import ( | ||
| "fmt" | ||
|
|
||
| "github.com/ukfast/sdk-go/pkg/connection" | ||
| ) | ||
|
|
||
| // GetVolumeGroups retrieves a list of volume groups | ||
| func (s *Service) GetVolumeGroups(parameters connection.APIRequestParameters) ([]VolumeGroup, error) { | ||
| var volGroups []VolumeGroup | ||
|
|
||
| getFunc := func(p connection.APIRequestParameters) (connection.Paginated, error) { | ||
| return s.GetVolumeGroupsPaginated(p) | ||
| } | ||
|
|
||
| responseFunc := func(response connection.Paginated) { | ||
| for _, volumeGroup := range response.(*PaginatedVolumeGroup).Items { | ||
| volGroups = append(volGroups, volumeGroup) | ||
| } | ||
| } | ||
|
|
||
| return volGroups, connection.InvokeRequestAll(getFunc, responseFunc, parameters) | ||
| } | ||
|
|
||
| // GetVolumeGroupsPaginated retrieves a paginated list of volume groups | ||
| func (s *Service) GetVolumeGroupsPaginated(parameters connection.APIRequestParameters) (*PaginatedVolumeGroup, error) { | ||
| body, err := s.getVolumeGroupsPaginatedResponseBody(parameters) | ||
|
|
||
| return NewPaginatedVolumeGroup(func(p connection.APIRequestParameters) (connection.Paginated, error) { | ||
| return s.GetVolumeGroupsPaginated(p) | ||
| }, parameters, body.Metadata.Pagination, body.Data), err | ||
| } | ||
|
|
||
| func (s *Service) getVolumeGroupsPaginatedResponseBody(parameters connection.APIRequestParameters) (*GetVolumeGroupSliceResponseBody, error) { | ||
| body := &GetVolumeGroupSliceResponseBody{} | ||
|
|
||
| response, err := s.connection.Get("/ecloud/v2/volume-groups", parameters) | ||
| if err != nil { | ||
| return body, err | ||
| } | ||
|
|
||
| return body, response.HandleResponse(body, nil) | ||
| } | ||
|
|
||
| // GetVolumeGroup retrieves a single volumeGroup by id | ||
| func (s *Service) GetVolumeGroup(volumeGroupID string) (VolumeGroup, error) { | ||
| body, err := s.getVolumeGroupResponseBody(volumeGroupID) | ||
|
|
||
| return body.Data, err | ||
| } | ||
|
|
||
| func (s *Service) getVolumeGroupResponseBody(volumeGroupID string) (*GetVolumeGroupResponseBody, error) { | ||
| body := &GetVolumeGroupResponseBody{} | ||
|
|
||
| if volumeGroupID == "" { | ||
| return body, fmt.Errorf("invalid volume group id") | ||
| } | ||
|
|
||
| response, err := s.connection.Get(fmt.Sprintf("/ecloud/v2/volume-groups/%s", volumeGroupID), connection.APIRequestParameters{}) | ||
| if err != nil { | ||
| return body, err | ||
| } | ||
|
|
||
| return body, response.HandleResponse(body, func(resp *connection.APIResponse) error { | ||
| if response.StatusCode == 404 { | ||
| return &VolumeGroupNotFoundError{ID: volumeGroupID} | ||
| } | ||
|
|
||
| return nil | ||
| }) | ||
| } | ||
|
|
||
| // CreateVolumeGroup creates a volumeGroup | ||
| func (s *Service) CreateVolumeGroup(req CreateVolumeGroupRequest) (TaskReference, error) { | ||
| body, err := s.createVolumeGroupResponseBody(req) | ||
|
|
||
| return body.Data, err | ||
| } | ||
|
|
||
| func (s *Service) createVolumeGroupResponseBody(req CreateVolumeGroupRequest) (*GetTaskReferenceResponseBody, error) { | ||
| body := &GetTaskReferenceResponseBody{} | ||
|
|
||
| response, err := s.connection.Post("/ecloud/v2/volume-groups", &req) | ||
| if err != nil { | ||
| return body, err | ||
| } | ||
|
|
||
| return body, response.HandleResponse(body, nil) | ||
| } | ||
|
|
||
| // PatchVolumeGroup patches a volumeGroup | ||
| func (s *Service) PatchVolumeGroup(volumeGroupID string, req PatchVolumeGroupRequest) (TaskReference, error) { | ||
| body, err := s.patchVolumeGroupResponseBody(volumeGroupID, req) | ||
|
|
||
| return body.Data, err | ||
| } | ||
|
|
||
| func (s *Service) patchVolumeGroupResponseBody(volumeGroupID string, req PatchVolumeGroupRequest) (*GetTaskReferenceResponseBody, error) { | ||
| body := &GetTaskReferenceResponseBody{} | ||
|
|
||
| if volumeGroupID == "" { | ||
| return body, fmt.Errorf("invalid volume group id") | ||
| } | ||
|
|
||
| response, err := s.connection.Patch(fmt.Sprintf("/ecloud/v2/volume-groups/%s", volumeGroupID), &req) | ||
| if err != nil { | ||
| return body, err | ||
| } | ||
|
|
||
| return body, response.HandleResponse(body, func(resp *connection.APIResponse) error { | ||
| if response.StatusCode == 404 { | ||
| return &VolumeGroupNotFoundError{ID: volumeGroupID} | ||
| } | ||
|
|
||
| return nil | ||
| }) | ||
| } | ||
|
|
||
| // DeleteVolumeGroup deletes a volumeGroup | ||
| func (s *Service) DeleteVolumeGroup(volumeGroupID string) (string, error) { | ||
| body, err := s.deleteVolumeGroupResponseBody(volumeGroupID) | ||
|
|
||
| return body.Data.TaskID, err | ||
| } | ||
|
|
||
| func (s *Service) deleteVolumeGroupResponseBody(volumeGroupID string) (*GetTaskReferenceResponseBody, error) { | ||
| body := &GetTaskReferenceResponseBody{} | ||
|
|
||
| if volumeGroupID == "" { | ||
| return body, fmt.Errorf("invalid volume group id") | ||
| } | ||
|
|
||
| response, err := s.connection.Delete(fmt.Sprintf("/ecloud/v2/volume-groups/%s", volumeGroupID), nil) | ||
| if err != nil { | ||
| return body, err | ||
| } | ||
|
|
||
| return body, response.HandleResponse(body, func(resp *connection.APIResponse) error { | ||
| if response.StatusCode == 404 { | ||
| return &VolumeGroupNotFoundError{ID: volumeGroupID} | ||
| } | ||
|
|
||
| return nil | ||
| }) | ||
| } | ||
|
|
||
| // GetVolumeGroupVolumes retrieves a list of VolumeGroup volumes | ||
| func (s *Service) GetVolumeGroupVolumes(volumeGroupID string, parameters connection.APIRequestParameters) ([]Volume, error) { | ||
| var volumes []Volume | ||
|
|
||
| getFunc := func(p connection.APIRequestParameters) (connection.Paginated, error) { | ||
| return s.GetVolumeGroupVolumesPaginated(volumeGroupID, p) | ||
| } | ||
|
|
||
| responseFunc := func(response connection.Paginated) { | ||
| for _, volume := range response.(*PaginatedVolume).Items { | ||
| volumes = append(volumes, volume) | ||
| } | ||
| } | ||
|
|
||
| return volumes, connection.InvokeRequestAll(getFunc, responseFunc, parameters) | ||
| } | ||
|
|
||
| // GetVolumeGroupVolumesPaginated retrieves a paginated list of VolumeGroup volumes | ||
| func (s *Service) GetVolumeGroupVolumesPaginated(volumeGroupID string, parameters connection.APIRequestParameters) (*PaginatedVolume, error) { | ||
| body, err := s.getVolumeGroupVolumesPaginatedResponseBody(volumeGroupID, parameters) | ||
|
|
||
| return NewPaginatedVolume(func(p connection.APIRequestParameters) (connection.Paginated, error) { | ||
| return s.GetVolumeGroupVolumesPaginated(volumeGroupID, p) | ||
| }, parameters, body.Metadata.Pagination, body.Data), err | ||
| } | ||
|
|
||
| func (s *Service) getVolumeGroupVolumesPaginatedResponseBody(volumeGroupID string, parameters connection.APIRequestParameters) (*GetVolumeSliceResponseBody, error) { | ||
| body := &GetVolumeSliceResponseBody{} | ||
|
|
||
| if volumeGroupID == "" { | ||
| return body, fmt.Errorf("invalid volume group id") | ||
| } | ||
|
|
||
| response, err := s.connection.Get(fmt.Sprintf("/ecloud/v2/volume-groups/%s/volumes", volumeGroupID), parameters) | ||
| if err != nil { | ||
| return body, err | ||
| } | ||
|
|
||
| return body, response.HandleResponse(body, func(resp *connection.APIResponse) error { | ||
| if response.StatusCode == 404 { | ||
| return &VolumeGroupNotFoundError{ID: volumeGroupID} | ||
| } | ||
|
|
||
| return nil | ||
| }) | ||
| } |
Oops, something went wrong.