api

package
v0.9.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type APICommonFunc 

type APICommonFunc struct{}

func (*APICommonFunc) MakeDeletedSubResource 

func (a *APICommonFunc) MakeDeletedSubResource(deleteKey []string, LbModel LoxiModel) (string, error)

func (*APICommonFunc) MakeQueryParam 

func (a *APICommonFunc) MakeQueryParam(LbModel LoxiModel) (map[string]string, error)

type BGPAPI added in v0.9.0 

type BGPAPI struct {
	APICommonFunc
	// contains filtered or unexported fields
}

func (*BGPAPI) CreateGlobalConfig added in v0.9.0 

func (b *BGPAPI) CreateGlobalConfig(ctx context.Context, Model LoxiModel) error

func (*BGPAPI) CreateNeigh added in v0.9.0 

func (b *BGPAPI) CreateNeigh(ctx context.Context, Model LoxiModel) error

func (*BGPAPI) DeleteNeigh added in v0.9.0 

func (b *BGPAPI) DeleteNeigh(ctx context.Context, neighIP string, remoteAs int) error

type BGPGlobalConfig added in v0.9.0 

type BGPGlobalConfig struct {
	// Local AS number
	LocalAs int64 `json:"localAs,omitempty"`
	// BGP Router ID
	RouterID string `json:"routerId,omitempty"`
	// Set Next hop self option
	SetNHSelf bool `json:"setNextHopSelf,omitempty"`
	// Listen Port
	ListenPort uint16 `json:"listenPort,omitempty"`
}

func (*BGPGlobalConfig) GetKeyStruct added in v0.9.0 

func (bgpGlobalModel *BGPGlobalConfig) GetKeyStruct() LoxiModel

type BGPNeigh added in v0.9.0 

type BGPNeigh struct {
	// BGP Neighbor IP address
	IPAddress string `json:"ipAddress,omitempty"`
	// Remote AS number
	RemoteAs int64 `json:"remoteAs,omitempty"`
	// Remote Connect Port (default 179)
	RemotePort int64 `json:"remotePort,omitempty"`
	// Enable multi-hop peering (if needed)
	SetMultiHop bool `json:"setMultiHop,omitempty"`
}

func (*BGPNeigh) GetKeyStruct added in v0.9.0 

func (bgpNeighModel *BGPNeigh) GetKeyStruct() LoxiModel

type CIStatusModel added in v0.9.0 

type CIStatusModel struct {
	// Instance name
	Instance string `json:"instance,omitempty"`
	// Current Cluster Instance State
	State string `json:"state,omitempty"`
	// Instance Virtual IP address
	Vip string `json:"vip,omitempty"`
}

func (*CIStatusModel) GetKeyStruct added in v0.9.0 

func (ciModel *CIStatusModel) GetKeyStruct() LoxiModel

type CiStatusAPI added in v0.9.0 

type CiStatusAPI struct {
	APICommonFunc
	// contains filtered or unexported fields
}

func (*CiStatusAPI) Create added in v0.9.0 

func (c *CiStatusAPI) Create(ctx context.Context, Model LoxiModel) error

type EpSelect 

type EpSelect uint
const (
	// LbSelRr - select the lb end-points based on round-robin
	LbSelRr EpSelect = iota
	// LbSelHash - select the lb end-points based on hashing
	LbSelHash
	// LbSelPrio - select the lb based on weighted round-robin
	LbSelPrio
	// LbSelRrPersist - persist connectons from same client
	LbSelRrPersist
	// LbSelLeastConnections - select client based on least connections
	LbSelLeastConnections
)

type HealthCheckAPI 

type HealthCheckAPI struct {
	APICommonFunc
	// contains filtered or unexported fields
}

func (*HealthCheckAPI) Create 

func (h *HealthCheckAPI) Create(ctx context.Context, lbModel LoxiModel) error

func (*HealthCheckAPI) Delete 

func (h *HealthCheckAPI) Delete(ctx context.Context, lbModel LoxiModel) error

func (*HealthCheckAPI) Get 

func (h *HealthCheckAPI) Get(ctx context.Context, name string) (LoxiModel, error)

func (*HealthCheckAPI) List 

func (h *HealthCheckAPI) List(ctx context.Context) (LoxiModel, error)

type LbMode 

type LbMode int32

type LoadBalancerAPI 

type LoadBalancerAPI struct {
	APICommonFunc
	// contains filtered or unexported fields
}

func (*LoadBalancerAPI) Create 

func (l *LoadBalancerAPI) Create(ctx context.Context, lbModel LoxiModel) error

func (*LoadBalancerAPI) Delete 

func (l *LoadBalancerAPI) Delete(ctx context.Context, lbModel LoxiModel) error

func (*LoadBalancerAPI) Get 

func (l *LoadBalancerAPI) Get(ctx context.Context, name string) (LoxiModel, error)

func (*LoadBalancerAPI) GetListModel 

func (l *LoadBalancerAPI) GetListModel() LoxiModel

func (*LoadBalancerAPI) GetModel 

func (l *LoadBalancerAPI) GetModel() LoxiModel

func (*LoadBalancerAPI) List 

func (l *LoadBalancerAPI) List(ctx context.Context) (LoxiModel, error)

type LoadBalancerEndpoint 

type LoadBalancerEndpoint struct {
	EndpointIP string `json:"endpointIP"`
	TargetPort uint16 `json:"targetPort"`
	Weight     uint8  `json:"weight"`
	State      string `json:"state"`
	Counter    string `json:"counter"`
}

type LoadBalancerListModel 

type LoadBalancerListModel struct {
	Item []LoadBalancerModel `json:"lbAttr"`
}

func (*LoadBalancerListModel) GetKeyStruct 

func (lbListModel *LoadBalancerListModel) GetKeyStruct() LoxiModel

type LoadBalancerModel 

type LoadBalancerModel struct {
	Service      LoadBalancerService    `json:"serviceArguments"`
	SecondaryIPs []LoadBalancerSecIp    `json:"secondaryIPs"`
	Endpoints    []LoadBalancerEndpoint `json:"endpoints"`
}

func (*LoadBalancerModel) GetKeyStruct 

func (lbModel *LoadBalancerModel) GetKeyStruct() LoxiModel

type LoadBalancerSecIp 

type LoadBalancerSecIp struct {
	SecondaryIP string `json:"secondaryIP"`
}

type LoadBalancerService 

type LoadBalancerService struct {
	ExternalIP   string   `json:"externalIP" key:"externalipaddress"`
	Port         uint16   `json:"port" key:"port"`
	Protocol     string   `json:"protocol" key:"protocol"`
	Sel          EpSelect `json:"sel"`
	Mode         LbMode   `json:"mode"`
	BGP          bool     `json:"BGP" options:"bgp"`
	Monitor      bool     `json:"Monitor"`
	Timeout      uint32   `json:"inactiveTimeOut"`
	Block        uint16   `json:"block" options:"block"`
	Managed      bool     `json:"managed,omitempty"`
	ProbeType    string   `json:"probetype"`
	ProbePort    uint16   `json:"probeport"`
	ProbeReq     string   `json:"probereq"`
	ProbeResp    string   `json:"proberesp"`
	ProbeRetries int32    `json:"probeRetries,omitempty"`
	ProbeTimeout uint32   `json:"probeTimeout,omitempty"`
	Name         string   `json:"name,omitempty"`
}

func (*LoadBalancerService) GetKeyStruct 

func (lbService *LoadBalancerService) GetKeyStruct() LoxiModel

type LoxiAPI 

type LoxiAPI interface {
	Get(context.Context, string) (LoxiModel, error)
	List(context.Context) (LoxiModel, error)
	Create(context.Context, LoxiModel) error
	Delete(context.Context, LoxiModel) error
}

type LoxiClient 

type LoxiClient struct {
	RestClient  *RESTClient
	MasterLB    bool
	PeeringOnly bool
	Url         string
	Host        string
	Port        string
	IsAlive     bool
	DeadSigTs   time.Time
	DoBGPCfg    bool
	Purge       bool
	Stop        chan struct{}
}

func NewLoxiClient 

func NewLoxiClient(apiServer string, aliveCh chan *LoxiClient, deadCh chan struct{}, peerOnly bool) (*LoxiClient, error)

apiServer is string. what format? http://10.0.0.1 or 10.0.0.1

func (*LoxiClient) BGP added in v0.9.0 

func (l *LoxiClient) BGP() *BGPAPI

func (*LoxiClient) CIStatus added in v0.9.0 

func (l *LoxiClient) CIStatus() *CiStatusAPI

func (*LoxiClient) GetRESTClient 

func (l *LoxiClient) GetRESTClient() *RESTClient

func (*LoxiClient) HealthCheck 

func (l *LoxiClient) HealthCheck() *HealthCheckAPI

func (*LoxiClient) LoadBalancer 

func (l *LoxiClient) LoadBalancer() *LoadBalancerAPI

func (*LoxiClient) StartLoxiHealthCheckChan added in v0.9.0 

func (l *LoxiClient) StartLoxiHealthCheckChan(aliveCh chan *LoxiClient, deadCh chan struct{})

func (*LoxiClient) StopLoxiHealthCheckChan added in v0.9.0 

func (l *LoxiClient) StopLoxiHealthCheckChan()

type LoxiModel 

type LoxiModel interface {
	GetKeyStruct() LoxiModel
}

type LoxiRequest 

type LoxiRequest struct {
	// contains filtered or unexported fields
}

func NewLoxiRequest 

func NewLoxiRequest(method, resource string, client *RESTClient) *LoxiRequest

func (*LoxiRequest) Body 

func (l *LoxiRequest) Body(obj LoxiModel) *LoxiRequest

func (*LoxiRequest) Do 

func (l *LoxiRequest) Do(ctx context.Context) *LoxiResponse

func (*LoxiRequest) Query 

func (l *LoxiRequest) Query(param map[string]string) *LoxiRequest

func (*LoxiRequest) SubResource 

func (l *LoxiRequest) SubResource(subresources ...string) *LoxiRequest

func (*LoxiRequest) URL 

func (l *LoxiRequest) URL() *url.URL

URL make REST API url

type LoxiResponse 

type LoxiResponse struct {
	// contains filtered or unexported fields
}

func (*LoxiResponse) UnMarshal 

func (l *LoxiResponse) UnMarshal(obj LoxiModel) *LoxiResponse

type LoxiResult added in v0.9.0 

type LoxiResult struct {
	Result string `json:"result"`
}

type RESTClient 

type RESTClient struct {
	Client *http.Client
	// contains filtered or unexported fields
}

func NewRESTClient 

func NewRESTClient(baseURL *url.URL, provider, version string, client *http.Client) (*RESTClient, error)

func (*RESTClient) CreateRequest 

func (r *RESTClient) CreateRequest(method string, resource string) *LoxiRequest

func (*RESTClient) DELETE 

func (r *RESTClient) DELETE(resource string) *LoxiRequest

func (*RESTClient) GET 

func (r *RESTClient) GET(resource string) *LoxiRequest

func (*RESTClient) GetBaseURL 

func (r *RESTClient) GetBaseURL() string

func (*RESTClient) POST 

func (r *RESTClient) POST(resource string) *LoxiRequest

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.