grpcs

Documentation

Index

• Variables
• func ActionVM(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func Add(name string, command Command)
• func AppendAttachment(command string, attachment string) (content string)
• func ApplySecgroups(ctx context.Context, instance *model.Instance) (err error)
• func AttachVolume(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func ClearRouter(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func ClearVM(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func CreateImage(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func CreateNet(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func CreatePortmap(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func CreateRouter(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func CreateVolume(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func DecodeCommand(content string) (cmd string, args []string)
• func DetachVolume(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func EnableVncPortmap(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func EncodeCommand(name string, args ...interface{}) (command string)
• func GetHyperService() hypers.HyperServiceServer
• func GetJobService() *jobService
• func GetRemoteExecService() scripts.RemoteExecServer
• func HyperExecute(ctx context.Context, control, command string) (err error)
• func HyperStatus(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func InstanceStatus(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func JobServiceClient(endpoint string) jobs.JobServiceClient
• func LaunchVM(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func RemoteExecClient() scripts.RemoteExecClient
• func ReplaceVncPasswd(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func ReportRC(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func RouterStatus(ctx context.Context, job *model.Job, args []string) (status string, err error)
• func Run() (err error)
• func VlanStatus(ctx context.Context, job *model.Job, args []string) (status string, err error)
• type Command
  • func Get(name string) (command Command)
• type FdbRule
• type SecurityData

Variables

var (
	JobService *jobService
)

Functions

func ActionVM

func ActionVM(ctx context.Context, job *model.Job, args []string) (status string, err error)

func Add

func Add(name string, command Command)

func AppendAttachment

func AppendAttachment(command string, attachment string) (content string)

func ApplySecgroups

func ApplySecgroups(ctx context.Context, instance *model.Instance) (err error)

func AttachVolume

func AttachVolume(ctx context.Context, job *model.Job, args []string) (status string, err error)

func ClearRouter

func ClearRouter(ctx context.Context, job *model.Job, args []string) (status string, err error)

func ClearVM

func ClearVM(ctx context.Context, job *model.Job, args []string) (status string, err error)

func CreateImage

func CreateImage(ctx context.Context, job *model.Job, args []string) (status string, err error)

func CreateNet

func CreateNet(ctx context.Context, job *model.Job, args []string) (status string, err error)

func CreatePortmap

func CreatePortmap(ctx context.Context, job *model.Job, args []string) (status string, err error)

func CreateRouter

func CreateRouter(ctx context.Context, job *model.Job, args []string) (status string, err error)

func CreateVolume

func CreateVolume(ctx context.Context, job *model.Job, args []string) (status string, err error)

func DecodeCommand

func DecodeCommand(content string) (cmd string, args []string)

func DetachVolume

func DetachVolume(ctx context.Context, job *model.Job, args []string) (status string, err error)

func EnableVncPortmap

func EnableVncPortmap(ctx context.Context, job *model.Job, args []string) (status string, err error)

func EncodeCommand

func EncodeCommand(name string, args ...interface{}) (command string)

func GetHyperService

func GetHyperService() hypers.HyperServiceServer

func GetJobService

func GetJobService() *jobService

func GetRemoteExecService

func GetRemoteExecService() scripts.RemoteExecServer

func HyperExecute

func HyperExecute(ctx context.Context, control, command string) (err error)

func HyperStatus

func HyperStatus(ctx context.Context, job *model.Job, args []string) (status string, err error)

func InstanceStatus

func InstanceStatus(ctx context.Context, job *model.Job, args []string) (status string, err error)

func JobServiceClient

func JobServiceClient(endpoint string) jobs.JobServiceClient

func LaunchVM

func LaunchVM(ctx context.Context, job *model.Job, args []string) (status string, err error)

func RemoteExecClient

func RemoteExecClient() scripts.RemoteExecClient

func ReplaceVncPasswd

func ReplaceVncPasswd(ctx context.Context, job *model.Job, args []string) (status string, err error)

func ReportRC

func ReportRC(ctx context.Context, job *model.Job, args []string) (status string, err error)

func RouterStatus

func RouterStatus(ctx context.Context, job *model.Job, args []string) (status string, err error)

func Run

func Run() (err error)

func VlanStatus

func VlanStatus(ctx context.Context, job *model.Job, args []string) (status string, err error)

Types

type Command

type Command func(ctx context.Context, job *model.Job, args []string) (string, error)

func Get

func Get(name string) (command Command)

type FdbRule

type FdbRule struct {
	Instance string `json:"instance"`
	Vni      int64  `json:"vni"`
	InnerIP  string `json:"inner_ip"`
	InnerMac string `json:"inner_mac"`
	OuterIP  string `json:"outer_ip"`
}

type SecurityData

type SecurityData struct {
	Secgroup    int64
	RemoteIp    string `json:"remote_ip"`
	RemoteGroup string `json:"remote_group"`
	Direction   string `json:"direction"`
	IpVersion   string `json:"ip_version"`
	Protocol    string `json:"protocol"`
	PortMin     int32  `json:"port_min"`
	PortMax     int32  `json:"port_max"`
}