519 lines
22 KiB
Go
519 lines
22 KiB
Go
// Code generated by goctl. DO NOT EDIT.
|
|
// Source: pcm-openstack.proto
|
|
|
|
package server
|
|
|
|
import (
|
|
"context"
|
|
|
|
"gitlink.org.cn/JointCloud/pcm-openstack/internal/logic"
|
|
"gitlink.org.cn/JointCloud/pcm-openstack/internal/svc"
|
|
"gitlink.org.cn/JointCloud/pcm-openstack/openstack"
|
|
)
|
|
|
|
type OpenstackServer struct {
|
|
svcCtx *svc.ServiceContext
|
|
openstack.UnimplementedOpenstackServer
|
|
}
|
|
|
|
func NewOpenstackServer(svcCtx *svc.ServiceContext) *OpenstackServer {
|
|
return &OpenstackServer{
|
|
svcCtx: svcCtx,
|
|
}
|
|
}
|
|
|
|
// Overview
|
|
func (s *OpenstackServer) GetComputeLimits(ctx context.Context, in *openstack.GetComputeLimitsReq) (*openstack.GetComputeLimitsResp, error) {
|
|
l := logic.NewGetComputeLimitsLogic(ctx, s.svcCtx)
|
|
return l.GetComputeLimits(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) GetVolumeLimits(ctx context.Context, in *openstack.GetVolumeLimitsReq) (*openstack.GetVolumeLimitsResp, error) {
|
|
l := logic.NewGetVolumeLimitsLogic(ctx, s.svcCtx)
|
|
return l.GetVolumeLimits(in)
|
|
}
|
|
|
|
// Servers
|
|
func (s *OpenstackServer) ListServers(ctx context.Context, in *openstack.ListServersReq) (*openstack.ListServersResp, error) {
|
|
l := logic.NewListServersLogic(ctx, s.svcCtx)
|
|
return l.ListServers(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListServersDetailed(ctx context.Context, in *openstack.ListServersDetailedReq) (*openstack.ListServersDetailedResp, error) {
|
|
l := logic.NewListServersDetailedLogic(ctx, s.svcCtx)
|
|
return l.ListServersDetailed(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateServer(ctx context.Context, in *openstack.CreateServerReq) (*openstack.CreateServerResp, error) {
|
|
l := logic.NewCreateServerLogic(ctx, s.svcCtx)
|
|
return l.CreateServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteServer(ctx context.Context, in *openstack.DeleteServerReq) (*openstack.DeleteServerResp, error) {
|
|
l := logic.NewDeleteServerLogic(ctx, s.svcCtx)
|
|
return l.DeleteServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) GetServersDetailedById(ctx context.Context, in *openstack.GetServersDetailedByIdReq) (*openstack.GetServersDetailedByIdResp, error) {
|
|
l := logic.NewGetServersDetailedByIdLogic(ctx, s.svcCtx)
|
|
return l.GetServersDetailedById(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UpdateServer(ctx context.Context, in *openstack.UpdateServerReq) (*openstack.UpdateServerResp, error) {
|
|
l := logic.NewUpdateServerLogic(ctx, s.svcCtx)
|
|
return l.UpdateServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) StartServer(ctx context.Context, in *openstack.StartServerReq) (*openstack.StartServerResp, error) {
|
|
l := logic.NewStartServerLogic(ctx, s.svcCtx)
|
|
return l.StartServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) StopServer(ctx context.Context, in *openstack.StopServerReq) (*openstack.StopServerResp, error) {
|
|
l := logic.NewStopServerLogic(ctx, s.svcCtx)
|
|
return l.StopServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) RebootServer(ctx context.Context, in *openstack.RebootServerReq) (*openstack.RebootServerResp, error) {
|
|
l := logic.NewRebootServerLogic(ctx, s.svcCtx)
|
|
return l.RebootServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) PauseServer(ctx context.Context, in *openstack.PauseServerReq) (*openstack.PauseServerResp, error) {
|
|
l := logic.NewPauseServerLogic(ctx, s.svcCtx)
|
|
return l.PauseServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UnpauseServer(ctx context.Context, in *openstack.UnpauseServerReq) (*openstack.UnpauseServerResp, error) {
|
|
l := logic.NewUnpauseServerLogic(ctx, s.svcCtx)
|
|
return l.UnpauseServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) RebuildServer(ctx context.Context, in *openstack.RebuildServerReq) (*openstack.RebuildServerResp, error) {
|
|
l := logic.NewRebuildServerLogic(ctx, s.svcCtx)
|
|
return l.RebuildServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ResizeServer(ctx context.Context, in *openstack.ResizeServerReq) (*openstack.ResizeServerResp, error) {
|
|
l := logic.NewResizeServerLogic(ctx, s.svcCtx)
|
|
return l.ResizeServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) MigrateServer(ctx context.Context, in *openstack.MigrateServerReq) (*openstack.MigrateServerResp, error) {
|
|
l := logic.NewMigrateServerLogic(ctx, s.svcCtx)
|
|
return l.MigrateServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShelveServer(ctx context.Context, in *openstack.ShelveServerReq) (*openstack.ShelveServerResp, error) {
|
|
l := logic.NewShelveServerLogic(ctx, s.svcCtx)
|
|
return l.ShelveServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UnshelveServer(ctx context.Context, in *openstack.UnshelveServerReq) (*openstack.UnshelveServerResp, error) {
|
|
l := logic.NewUnshelveServerLogic(ctx, s.svcCtx)
|
|
return l.UnshelveServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ChangeAdministrativePassword(ctx context.Context, in *openstack.ChangeAdministrativePasswordReq) (*openstack.ChangeAdministrativePasswordResp, error) {
|
|
l := logic.NewChangeAdministrativePasswordLogic(ctx, s.svcCtx)
|
|
return l.ChangeAdministrativePassword(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) RescueServer(ctx context.Context, in *openstack.RescueServerReq) (*openstack.RescueServerResp, error) {
|
|
l := logic.NewRescueServerLogic(ctx, s.svcCtx)
|
|
return l.RescueServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UnRescue(ctx context.Context, in *openstack.UnRescueServerReq) (*openstack.UnRescueServerResp, error) {
|
|
l := logic.NewUnRescueLogic(ctx, s.svcCtx)
|
|
return l.UnRescue(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) SuspendServer(ctx context.Context, in *openstack.SuspendServerReq) (*openstack.SuspendServerResp, error) {
|
|
l := logic.NewSuspendServerLogic(ctx, s.svcCtx)
|
|
return l.SuspendServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) AddSecurityGroupToServer(ctx context.Context, in *openstack.AddSecurityGroupToServerReq) (*openstack.AddSecurityGroupToServerResp, error) {
|
|
l := logic.NewAddSecurityGroupToServerLogic(ctx, s.svcCtx)
|
|
return l.AddSecurityGroupToServer(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) RemoveSecurityGroup(ctx context.Context, in *openstack.RemoveSecurityGroupReq) (*openstack.RemoveSecurityGroupResp, error) {
|
|
l := logic.NewRemoveSecurityGroupLogic(ctx, s.svcCtx)
|
|
return l.RemoveSecurityGroup(in)
|
|
}
|
|
|
|
// 规格(Flavors)
|
|
func (s *OpenstackServer) ListFlavorsDetail(ctx context.Context, in *openstack.ListFlavorsDetailReq) (*openstack.ListFlavorsDetailResp, error) {
|
|
l := logic.NewListFlavorsDetailLogic(ctx, s.svcCtx)
|
|
return l.ListFlavorsDetail(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateFlavor(ctx context.Context, in *openstack.CreateFlavorReq) (*openstack.CreateFlavorResp, error) {
|
|
l := logic.NewCreateFlavorLogic(ctx, s.svcCtx)
|
|
return l.CreateFlavor(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteFlavor(ctx context.Context, in *openstack.DeleteFlavorReq) (*openstack.DeleteFlavorResp, error) {
|
|
l := logic.NewDeleteFlavorLogic(ctx, s.svcCtx)
|
|
return l.DeleteFlavor(in)
|
|
}
|
|
|
|
// network
|
|
func (s *OpenstackServer) ShowNetworkDetails(ctx context.Context, in *openstack.ShowNetworkDetailsReq) (*openstack.ShowNetworkDetailsResp, error) {
|
|
l := logic.NewShowNetworkDetailsLogic(ctx, s.svcCtx)
|
|
return l.ShowNetworkDetails(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UpdateNetwork(ctx context.Context, in *openstack.UpdateNetworkReq) (*openstack.UpdateNetworkResp, error) {
|
|
l := logic.NewUpdateNetworkLogic(ctx, s.svcCtx)
|
|
return l.UpdateNetwork(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteNetwork(ctx context.Context, in *openstack.DeleteNetworkReq) (*openstack.DeleteNetworkResp, error) {
|
|
l := logic.NewDeleteNetworkLogic(ctx, s.svcCtx)
|
|
return l.DeleteNetwork(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListNetworks(ctx context.Context, in *openstack.ListNetworksReq) (*openstack.ListNetworksResp, error) {
|
|
l := logic.NewListNetworksLogic(ctx, s.svcCtx)
|
|
return l.ListNetworks(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateNetwork(ctx context.Context, in *openstack.CreateNetworkReq) (*openstack.CreateNetworkResp, error) {
|
|
l := logic.NewCreateNetworkLogic(ctx, s.svcCtx)
|
|
return l.CreateNetwork(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) BulkCreateNetworks(ctx context.Context, in *openstack.BulkCreateNetworksReq) (*openstack.BulkCreateNetworksResp, error) {
|
|
l := logic.NewBulkCreateNetworksLogic(ctx, s.svcCtx)
|
|
return l.BulkCreateNetworks(in)
|
|
}
|
|
|
|
// 子网
|
|
func (s *OpenstackServer) CreateSubnet(ctx context.Context, in *openstack.CreateSubnetReq) (*openstack.CreateSubnetResp, error) {
|
|
l := logic.NewCreateSubnetLogic(ctx, s.svcCtx)
|
|
return l.CreateSubnet(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListSubnets(ctx context.Context, in *openstack.ListSubnetsReq) (*openstack.ListSubnetsResp, error) {
|
|
l := logic.NewListSubnetsLogic(ctx, s.svcCtx)
|
|
return l.ListSubnets(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteSubnet(ctx context.Context, in *openstack.DeleteSubnetReq) (*openstack.DeleteSubnetResp, error) {
|
|
l := logic.NewDeleteSubnetLogic(ctx, s.svcCtx)
|
|
return l.DeleteSubnet(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UpdateSubnet(ctx context.Context, in *openstack.UpdateSubnetReq) (*openstack.UpdateSubnetResp, error) {
|
|
l := logic.NewUpdateSubnetLogic(ctx, s.svcCtx)
|
|
return l.UpdateSubnet(in)
|
|
}
|
|
|
|
// 网段
|
|
func (s *OpenstackServer) CreateNetworkSegmentRange(ctx context.Context, in *openstack.CreateNetworkSegmentRangeReq) (*openstack.CreateNetworkSegmentRangeResp, error) {
|
|
l := logic.NewCreateNetworkSegmentRangeLogic(ctx, s.svcCtx)
|
|
return l.CreateNetworkSegmentRange(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListNetworkSegmentRanges(ctx context.Context, in *openstack.ListNetworkSegmentRangesReq) (*openstack.ListNetworkSegmentRangesResp, error) {
|
|
l := logic.NewListNetworkSegmentRangesLogic(ctx, s.svcCtx)
|
|
return l.ListNetworkSegmentRanges(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteNetworkSegmentRanges(ctx context.Context, in *openstack.DeleteNetworkSegmentRangesReq) (*openstack.DeleteNetworkSegmentRangesResp, error) {
|
|
l := logic.NewDeleteNetworkSegmentRangesLogic(ctx, s.svcCtx)
|
|
return l.DeleteNetworkSegmentRanges(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UpdateNetworkSegmentRanges(ctx context.Context, in *openstack.UpdateNetworkSegmentRangesReq) (*openstack.UpdateNetworkSegmentRangesResp, error) {
|
|
l := logic.NewUpdateNetworkSegmentRangesLogic(ctx, s.svcCtx)
|
|
return l.UpdateNetworkSegmentRanges(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShowNetworkSegmentRangeDetails(ctx context.Context, in *openstack.ShowNetworkSegmentRangeDetailsReq) (*openstack.ShowNetworkSegmentRangeDetailsResp, error) {
|
|
l := logic.NewShowNetworkSegmentRangeDetailsLogic(ctx, s.svcCtx)
|
|
return l.ShowNetworkSegmentRangeDetails(in)
|
|
}
|
|
|
|
// 端口
|
|
func (s *OpenstackServer) CreatePort(ctx context.Context, in *openstack.CreatePortReq) (*openstack.CreatePortResp, error) {
|
|
l := logic.NewCreatePortLogic(ctx, s.svcCtx)
|
|
return l.CreatePort(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListPorts(ctx context.Context, in *openstack.ListPortsReq) (*openstack.ListPortsResp, error) {
|
|
l := logic.NewListPortsLogic(ctx, s.svcCtx)
|
|
return l.ListPorts(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeletePort(ctx context.Context, in *openstack.DeletePortReq) (*openstack.DeletePortResp, error) {
|
|
l := logic.NewDeletePortLogic(ctx, s.svcCtx)
|
|
return l.DeletePort(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UpdatePort(ctx context.Context, in *openstack.UpdatePortReq) (*openstack.UpdatePortResp, error) {
|
|
l := logic.NewUpdatePortLogic(ctx, s.svcCtx)
|
|
return l.UpdatePort(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShowPortDetails(ctx context.Context, in *openstack.ShowPortDetailsReq) (*openstack.ShowPortDetailsResp, error) {
|
|
l := logic.NewShowPortDetailsLogic(ctx, s.svcCtx)
|
|
return l.ShowPortDetails(in)
|
|
}
|
|
|
|
// 路由
|
|
func (s *OpenstackServer) CreateRouter(ctx context.Context, in *openstack.CreateRouterReq) (*openstack.CreateRouterResp, error) {
|
|
l := logic.NewCreateRouterLogic(ctx, s.svcCtx)
|
|
return l.CreateRouter(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListRouters(ctx context.Context, in *openstack.ListRoutersReq) (*openstack.ListRoutersResp, error) {
|
|
l := logic.NewListRoutersLogic(ctx, s.svcCtx)
|
|
return l.ListRouters(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShowRouterDetails(ctx context.Context, in *openstack.ShowRouterDetailsReq) (*openstack.ShowRouterDetailsResp, error) {
|
|
l := logic.NewShowRouterDetailsLogic(ctx, s.svcCtx)
|
|
return l.ShowRouterDetails(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UpdateRouter(ctx context.Context, in *openstack.UpdateRouterReq) (*openstack.UpdateRouterResp, error) {
|
|
l := logic.NewUpdateRouterLogic(ctx, s.svcCtx)
|
|
return l.UpdateRouter(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteRouter(ctx context.Context, in *openstack.DeleteRouterReq) (*openstack.DeleteRouterResp, error) {
|
|
l := logic.NewDeleteRouterLogic(ctx, s.svcCtx)
|
|
return l.DeleteRouter(in)
|
|
}
|
|
|
|
// 浮动IP
|
|
func (s *OpenstackServer) ListFloatingIPs(ctx context.Context, in *openstack.ListFloatingIPsReq) (*openstack.ListFloatingIPsResp, error) {
|
|
l := logic.NewListFloatingIPsLogic(ctx, s.svcCtx)
|
|
return l.ListFloatingIPs(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateFloatingIP(ctx context.Context, in *openstack.CreateFloatingIPReq) (*openstack.CreateFloatingIPResp, error) {
|
|
l := logic.NewCreateFloatingIPLogic(ctx, s.svcCtx)
|
|
return l.CreateFloatingIP(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UpdateFloatingIP(ctx context.Context, in *openstack.UpdateFloatingIPReq) (*openstack.UpdateFloatingIPResp, error) {
|
|
l := logic.NewUpdateFloatingIPLogic(ctx, s.svcCtx)
|
|
return l.UpdateFloatingIP(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteFloatingIP(ctx context.Context, in *openstack.DeleteFloatingIPReq) (*openstack.DeleteFloatingIPResp, error) {
|
|
l := logic.NewDeleteFloatingIPLogic(ctx, s.svcCtx)
|
|
return l.DeleteFloatingIP(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShowFloatingIPDetails(ctx context.Context, in *openstack.ShowFloatingIPDetailsReq) (*openstack.ShowFloatingIPDetailsResp, error) {
|
|
l := logic.NewShowFloatingIPDetailsLogic(ctx, s.svcCtx)
|
|
return l.ShowFloatingIPDetails(in)
|
|
}
|
|
|
|
// 防火墙
|
|
func (s *OpenstackServer) ListFirewallGroups(ctx context.Context, in *openstack.ListFirewallGroupsReq) (*openstack.ListFirewallGroupsResp, error) {
|
|
l := logic.NewListFirewallGroupsLogic(ctx, s.svcCtx)
|
|
return l.ListFirewallGroups(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteFirewallGroup(ctx context.Context, in *openstack.DeleteFirewallGroupReq) (*openstack.DeleteFirewallGroupResp, error) {
|
|
l := logic.NewDeleteFirewallGroupLogic(ctx, s.svcCtx)
|
|
return l.DeleteFirewallGroup(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateFirewallGroup(ctx context.Context, in *openstack.CreateFirewallGroupReq) (*openstack.CreateFirewallGroupResp, error) {
|
|
l := logic.NewCreateFirewallGroupLogic(ctx, s.svcCtx)
|
|
return l.CreateFirewallGroup(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UpdateFirewallGroup(ctx context.Context, in *openstack.UpdateFirewallGroupReq) (*openstack.UpdateFirewallGroupResp, error) {
|
|
l := logic.NewUpdateFirewallGroupLogic(ctx, s.svcCtx)
|
|
return l.UpdateFirewallGroup(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShowFirewallGroupDetails(ctx context.Context, in *openstack.ShowFirewallGroupDetailsReq) (*openstack.ShowFirewallGroupDetailsResp, error) {
|
|
l := logic.NewShowFirewallGroupDetailsLogic(ctx, s.svcCtx)
|
|
return l.ShowFirewallGroupDetails(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateFirewallPolicy(ctx context.Context, in *openstack.CreateFirewallPolicyReq) (*openstack.CreateFirewallPolicyResp, error) {
|
|
l := logic.NewCreateFirewallPolicyLogic(ctx, s.svcCtx)
|
|
return l.CreateFirewallPolicy(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteFirewallPolicy(ctx context.Context, in *openstack.DeleteFirewallPolicyReq) (*openstack.DeleteFirewallPolicyResp, error) {
|
|
l := logic.NewDeleteFirewallPolicyLogic(ctx, s.svcCtx)
|
|
return l.DeleteFirewallPolicy(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListFirewallPolicies(ctx context.Context, in *openstack.ListFirewallPoliciesReq) (*openstack.ListFirewallPoliciesResp, error) {
|
|
l := logic.NewListFirewallPoliciesLogic(ctx, s.svcCtx)
|
|
return l.ListFirewallPolicies(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShowFirewallPolicyDetails(ctx context.Context, in *openstack.ShowFirewallPolicyDetailsReq) (*openstack.ShowFirewallPolicyDetailsResp, error) {
|
|
l := logic.NewShowFirewallPolicyDetailsLogic(ctx, s.svcCtx)
|
|
return l.ShowFirewallPolicyDetails(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateFirewallRule(ctx context.Context, in *openstack.CreateFirewallRuleReq) (*openstack.CreateFirewallRuleResp, error) {
|
|
l := logic.NewCreateFirewallRuleLogic(ctx, s.svcCtx)
|
|
return l.CreateFirewallRule(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteFirewallRule(ctx context.Context, in *openstack.DeleteFirewallRuleReq) (*openstack.DeleteFirewallRuleResp, error) {
|
|
l := logic.NewDeleteFirewallRuleLogic(ctx, s.svcCtx)
|
|
return l.DeleteFirewallRule(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListFirewallRules(ctx context.Context, in *openstack.ListFirewallRulesReq) (*openstack.ListFirewallRulesResp, error) {
|
|
l := logic.NewListFirewallRulesLogic(ctx, s.svcCtx)
|
|
return l.ListFirewallRules(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShowFirewallRuleDetails(ctx context.Context, in *openstack.ShowFirewallRuleDetailsReq) (*openstack.ShowFirewallRuleDetailsResp, error) {
|
|
l := logic.NewShowFirewallRuleDetailsLogic(ctx, s.svcCtx)
|
|
return l.ShowFirewallRuleDetails(in)
|
|
}
|
|
|
|
// 安全组
|
|
func (s *OpenstackServer) ListSecurityGroups(ctx context.Context, in *openstack.ListSecurityGroupsReq) (*openstack.ListSecurityGroupsResp, error) {
|
|
l := logic.NewListSecurityGroupsLogic(ctx, s.svcCtx)
|
|
return l.ListSecurityGroups(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateSecurityGroup(ctx context.Context, in *openstack.CreateSecurityGroupReq) (*openstack.CreateSecurityGroupResp, error) {
|
|
l := logic.NewCreateSecurityGroupLogic(ctx, s.svcCtx)
|
|
return l.CreateSecurityGroup(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteSecurityGroup(ctx context.Context, in *openstack.DeleteSecurityGroupReq) (*openstack.DeleteSecurityGroupResp, error) {
|
|
l := logic.NewDeleteSecurityGroupLogic(ctx, s.svcCtx)
|
|
return l.DeleteSecurityGroup(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UpdateSecurityGroup(ctx context.Context, in *openstack.UpdateSecurityGroupReq) (*openstack.UpdateSecurityGroupResp, error) {
|
|
l := logic.NewUpdateSecurityGroupLogic(ctx, s.svcCtx)
|
|
return l.UpdateSecurityGroup(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShowSecurityGroup(ctx context.Context, in *openstack.ShowSecurityGroupReq) (*openstack.ShowSecurityGroupResp, error) {
|
|
l := logic.NewShowSecurityGroupLogic(ctx, s.svcCtx)
|
|
return l.ShowSecurityGroup(in)
|
|
}
|
|
|
|
// 安全组规则
|
|
func (s *OpenstackServer) ListSecurityGroupRules(ctx context.Context, in *openstack.ListSecurityGroupRulesReq) (*openstack.ListSecurityGroupRulesResp, error) {
|
|
l := logic.NewListSecurityGroupRulesLogic(ctx, s.svcCtx)
|
|
return l.ListSecurityGroupRules(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateSecurityGroupRule(ctx context.Context, in *openstack.CreateSecurityGroupRuleReq) (*openstack.CreateSecurityGroupRuleResp, error) {
|
|
l := logic.NewCreateSecurityGroupRuleLogic(ctx, s.svcCtx)
|
|
return l.CreateSecurityGroupRule(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShowSecurityGroupRule(ctx context.Context, in *openstack.ShowSecurityGroupRuleReq) (*openstack.ShowSecurityGroupRuleResp, error) {
|
|
l := logic.NewShowSecurityGroupRuleLogic(ctx, s.svcCtx)
|
|
return l.ShowSecurityGroupRule(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteSecurityGroupRule(ctx context.Context, in *openstack.DeleteSecurityGroupRuleReq) (*openstack.DeleteSecurityGroupRuleResp, error) {
|
|
l := logic.NewDeleteSecurityGroupRuleLogic(ctx, s.svcCtx)
|
|
return l.DeleteSecurityGroupRule(in)
|
|
}
|
|
|
|
// Images from glance
|
|
func (s *OpenstackServer) CreateImage(ctx context.Context, in *openstack.CreateImageReq) (*openstack.CreateImageResp, error) {
|
|
l := logic.NewCreateImageLogic(ctx, s.svcCtx)
|
|
return l.CreateImage(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListImages(ctx context.Context, in *openstack.ListImagesReq) (*openstack.ListImagesResp, error) {
|
|
l := logic.NewListImagesLogic(ctx, s.svcCtx)
|
|
return l.ListImages(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteImage(ctx context.Context, in *openstack.DeleteImageReq) (*openstack.DeleteImageResp, error) {
|
|
l := logic.NewDeleteImageLogic(ctx, s.svcCtx)
|
|
return l.DeleteImage(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UploadImage(ctx context.Context, in *openstack.UploadOsImageReq) (*openstack.UploadOsImageResp, error) {
|
|
l := logic.NewUploadImageLogic(ctx, s.svcCtx)
|
|
return l.UploadImage(in)
|
|
}
|
|
|
|
// Bare Metal
|
|
func (s *OpenstackServer) ListNodes(ctx context.Context, in *openstack.ListNodesReq) (*openstack.ListNodesResp, error) {
|
|
l := logic.NewListNodesLogic(ctx, s.svcCtx)
|
|
return l.ListNodes(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateNode(ctx context.Context, in *openstack.CreateNodeReq) (*openstack.CreateNodeResp, error) {
|
|
l := logic.NewCreateNodeLogic(ctx, s.svcCtx)
|
|
return l.CreateNode(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteNode(ctx context.Context, in *openstack.DeleteNodeReq) (*openstack.DeleteNodeResp, error) {
|
|
l := logic.NewDeleteNodeLogic(ctx, s.svcCtx)
|
|
return l.DeleteNode(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ShowNodeDetails(ctx context.Context, in *openstack.ShowNodeDetailsReq) (*openstack.ShowNodeDetailsResp, error) {
|
|
l := logic.NewShowNodeDetailsLogic(ctx, s.svcCtx)
|
|
return l.ShowNodeDetails(in)
|
|
}
|
|
|
|
// cinder(block storage) volumes
|
|
func (s *OpenstackServer) ListVolumes(ctx context.Context, in *openstack.ListVolumesReq) (*openstack.ListVolumesResp, error) {
|
|
l := logic.NewListVolumesLogic(ctx, s.svcCtx)
|
|
return l.ListVolumes(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListVolumesDetail(ctx context.Context, in *openstack.ListVolumesDetailReq) (*openstack.ListVolumesDetailResp, error) {
|
|
l := logic.NewListVolumesDetailLogic(ctx, s.svcCtx)
|
|
return l.ListVolumesDetail(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateVolume(ctx context.Context, in *openstack.CreateVolumeReq) (*openstack.CreateVolumeResp, error) {
|
|
l := logic.NewCreateVolumeLogic(ctx, s.svcCtx)
|
|
return l.CreateVolume(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteVolume(ctx context.Context, in *openstack.DeleteVolumeReq) (*openstack.DeleteVolumeResp, error) {
|
|
l := logic.NewDeleteVolumeLogic(ctx, s.svcCtx)
|
|
return l.DeleteVolume(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) UpdateVolume(ctx context.Context, in *openstack.UpdateVolumeReq) (*openstack.UpdateVolumeResp, error) {
|
|
l := logic.NewUpdateVolumeLogic(ctx, s.svcCtx)
|
|
return l.UpdateVolume(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) GetVolumeDetailedById(ctx context.Context, in *openstack.GetVolumeDetailedByIdReq) (*openstack.GetVolumeDetailedByIdResp, error) {
|
|
l := logic.NewGetVolumeDetailedByIdLogic(ctx, s.svcCtx)
|
|
return l.GetVolumeDetailedById(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) ListVolumeTypes(ctx context.Context, in *openstack.ListVolumeTypesReq) (*openstack.ListVolumeTypesResp, error) {
|
|
l := logic.NewListVolumeTypesLogic(ctx, s.svcCtx)
|
|
return l.ListVolumeTypes(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) CreateVolumeTypes(ctx context.Context, in *openstack.CreateVolumeTypeReq) (*openstack.CreateVolumeTypeResp, error) {
|
|
l := logic.NewCreateVolumeTypesLogic(ctx, s.svcCtx)
|
|
return l.CreateVolumeTypes(in)
|
|
}
|
|
|
|
func (s *OpenstackServer) DeleteVolumeTypes(ctx context.Context, in *openstack.DeleteVolumeTypeReq) (*openstack.DeleteVolumeTypeResp, error) {
|
|
l := logic.NewDeleteVolumeTypesLogic(ctx, s.svcCtx)
|
|
return l.DeleteVolumeTypes(in)
|
|
}
|