executor

Documentation

Index

• Constants
• type ClientConfig
• type QingCloudClient
  • func (q *QingCloudClient) AllocateEIP(eip *apis.EIP) (*apis.EIP, error)
  • func (q *QingCloudClient) CreateBackends(backends []*apis.LoadBalancerBackend) ([]*string, error)
  • func (q *QingCloudClient) CreateLB(input *apis.LoadBalancer) (*apis.LoadBalancer, error)
  • func (q *QingCloudClient) CreateListener(inputs []*apis.LoadBalancerListener) ([]*apis.LoadBalancerListener, error)
  • func (q *QingCloudClient) CreateSecurityGroup(input *apis.SecurityGroup) (*apis.SecurityGroup, error)
  • func (q *QingCloudClient) DeleteBackends(ids []*string) error
  • func (q *QingCloudClient) DeleteLB(id *string) error
  • func (q *QingCloudClient) DeleteListener(lsnid []*string) error
  • func (q *QingCloudClient) DeleteSG(sg *string) error
  • func (q *QingCloudClient) GetAvaliableEIPs() ([]*apis.EIP, error)
  • func (q *QingCloudClient) GetListeners(id []*string) ([]*apis.LoadBalancerListener, error)
  • func (q *QingCloudClient) GetLoadBalancerByID(id string) (*apis.LoadBalancer, error)
  • func (q *QingCloudClient) GetLoadBalancerByName(name string) (*apis.LoadBalancer, error)
  • func (q *QingCloudClient) GetSecurityGroupByName(name string) (*apis.SecurityGroup, error)
  • func (i *QingCloudClient) InstancesExist(ids []string) error
  • func (q *QingCloudClient) ModifyLB(conf *apis.LoadBalancer) error
  • func (q *QingCloudClient) ReleaseEIP(ids []*string) error
  • func (q *QingCloudClient) UpdateLB(id *string) error
• type QingCloudClientInterface
  • func NewQingCloudClient(config *ClientConfig, path string) (QingCloudClientInterface, error)

Constants

const (
	ResourceNameLoadBalancer  = "LoadBalancer"
	ResourceNameListener      = "Listener"
	ResourceNameBackend       = "Backend"
	ResourceNameSecurityGroup = "SecurityGroup"

	SGTagResourceType  = "security_group"
	EIPTagResourceType = "eip"
)

const (
	DefaultBandWidth   = 2
	EIPStatusAvailable = "available"
	AllocateEIPName    = "k8s_lb_allocate_eip"
)

const (
	QingCloudLBIPPrefix = "198.19"
	DefaultNodeNum      = 2
	DefaultMode         = 1
	DefaultLBType       = 0
)

const (
	DefaultSgName = "k8s_lb_default_sg"
)

Types

type ClientConfig

type ClientConfig struct {
	IsAPP  bool
	UserID string
	TagIDs []string
}

type QingCloudClient

type QingCloudClient struct {
	InstanceService *qcservice.InstanceService
	LBService       *qcservice.LoadBalancerService

	EIPService *qcservice.EIPService

	Config *ClientConfig
	// contains filtered or unexported fields
}

QingCloud is the main entry of all interface

func (*QingCloudClient) AllocateEIP

func (q *QingCloudClient) AllocateEIP(eip *apis.EIP) (*apis.EIP, error)

func (*QingCloudClient) CreateBackends

func (q *QingCloudClient) CreateBackends(backends []*apis.LoadBalancerBackend) ([]*string, error)

need update lb

func (*QingCloudClient) CreateLB

func (q *QingCloudClient) CreateLB(input *apis.LoadBalancer) (*apis.LoadBalancer, error)

func (*QingCloudClient) CreateListener

func (q *QingCloudClient) CreateListener(inputs []*apis.LoadBalancerListener) ([]*apis.LoadBalancerListener, error)

need update lb

func (*QingCloudClient) CreateSecurityGroup

func (q *QingCloudClient) CreateSecurityGroup(input *apis.SecurityGroup) (*apis.SecurityGroup, error)

func (*QingCloudClient) DeleteBackends

func (q *QingCloudClient) DeleteBackends(ids []*string) error

func (*QingCloudClient) DeleteLB

func (q *QingCloudClient) DeleteLB(id *string) error

need update before delete

func (*QingCloudClient) DeleteListener

func (q *QingCloudClient) DeleteListener(lsnid []*string) error

func (*QingCloudClient) DeleteSG

func (q *QingCloudClient) DeleteSG(sg *string) error

func (*QingCloudClient) GetAvaliableEIPs

func (q *QingCloudClient) GetAvaliableEIPs() ([]*apis.EIP, error)

func (*QingCloudClient) GetListeners

func (q *QingCloudClient) GetListeners(id []*string) ([]*apis.LoadBalancerListener, error)

func (*QingCloudClient) GetLoadBalancerByID

func (q *QingCloudClient) GetLoadBalancerByID(id string) (*apis.LoadBalancer, error)

func (*QingCloudClient) GetLoadBalancerByName

func (q *QingCloudClient) GetLoadBalancerByName(name string) (*apis.LoadBalancer, error)

func (*QingCloudClient) GetSecurityGroupByName

func (q *QingCloudClient) GetSecurityGroupByName(name string) (*apis.SecurityGroup, error)

func (*QingCloudClient) InstancesExist

func (i *QingCloudClient) InstancesExist(ids []string) error

func (*QingCloudClient) ModifyLB

func (q *QingCloudClient) ModifyLB(conf *apis.LoadBalancer) error

need update lb

func (*QingCloudClient) ReleaseEIP

func (q *QingCloudClient) ReleaseEIP(ids []*string) error

func (*QingCloudClient) UpdateLB

func (q *QingCloudClient) UpdateLB(id *string) error

type QingCloudClientInterface

type QingCloudClientInterface interface {
	//LoadBalancer
	GetLoadBalancerByName(name string) (*apis.LoadBalancer, error)
	GetLoadBalancerByID(id string) (*apis.LoadBalancer, error)
	ModifyLB(conf *apis.LoadBalancer) error
	CreateLB(input *apis.LoadBalancer) (*apis.LoadBalancer, error)
	DeleteLB(id *string) error
	UpdateLB(id *string) error

	//sg
	GetSecurityGroupByName(name string) (*apis.SecurityGroup, error)

	//EIP
	AllocateEIP(eip *apis.EIP) (*apis.EIP, error)
	GetAvaliableEIPs() ([]*apis.EIP, error)
	ReleaseEIP(ids []*string) error

	//backend
	CreateBackends(backends []*apis.LoadBalancerBackend) ([]*string, error)
	DeleteBackends(ids []*string) error

	//listener
	CreateListener(inputs []*apis.LoadBalancerListener) ([]*apis.LoadBalancerListener, error)
	GetListeners(id []*string) ([]*apis.LoadBalancerListener, error)
	DeleteListener(lsnid []*string) error
}

func NewQingCloudClient

func NewQingCloudClient(config *ClientConfig, path string) (QingCloudClientInterface, error)