lbagent

package
v0.11.0-alpha.4-test Latest Latest
Warning

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

Go to latest
Published: Apr 20, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var LoadBalancerType_name = map[int32]string{
	0: "Haproxy",
	1: "Keepalived",
	2: "Nginx",
}
View Source
var LoadBalancerType_value = map[string]int32{
	"Haproxy":    0,
	"Keepalived": 1,
	"Nginx":      2,
}

Functions

func RegisterLoadBalancerAgentServer

func RegisterLoadBalancerAgentServer(s *grpc.Server, srv LoadBalancerAgentServer)

Types

type LoadBalancer

type LoadBalancer struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id                   string               `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Backendips           []string             `protobuf:"bytes,3,rep,name=backendips,proto3" json:"backendips,omitempty"`
	Frontendip           string               `protobuf:"bytes,4,opt,name=frontendip,proto3" json:"frontendip,omitempty"`
	Loadbalancingrules   []*LoadBalancingRule `protobuf:"bytes,5,rep,name=loadbalancingrules,proto3" json:"loadbalancingrules,omitempty"`
	Status               *common.Status       `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*LoadBalancer) Descriptor

func (*LoadBalancer) Descriptor() ([]byte, []int)

func (*LoadBalancer) GetBackendips

func (m *LoadBalancer) GetBackendips() []string

func (*LoadBalancer) GetFrontendip

func (m *LoadBalancer) GetFrontendip() string

func (*LoadBalancer) GetId

func (m *LoadBalancer) GetId() string

func (*LoadBalancer) GetLoadbalancingrules

func (m *LoadBalancer) GetLoadbalancingrules() []*LoadBalancingRule

func (*LoadBalancer) GetName

func (m *LoadBalancer) GetName() string

func (*LoadBalancer) GetStatus

func (m *LoadBalancer) GetStatus() *common.Status

func (*LoadBalancer) ProtoMessage

func (*LoadBalancer) ProtoMessage()

func (*LoadBalancer) Reset

func (m *LoadBalancer) Reset()

func (*LoadBalancer) String

func (m *LoadBalancer) String() string

func (*LoadBalancer) XXX_DiscardUnknown

func (m *LoadBalancer) XXX_DiscardUnknown()

func (*LoadBalancer) XXX_Marshal

func (m *LoadBalancer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancer) XXX_Merge

func (m *LoadBalancer) XXX_Merge(src proto.Message)

func (*LoadBalancer) XXX_Size

func (m *LoadBalancer) XXX_Size() int

func (*LoadBalancer) XXX_Unmarshal

func (m *LoadBalancer) XXX_Unmarshal(b []byte) error

type LoadBalancerAgentClient

LoadBalancerAgentClient is the client API for LoadBalancerAgent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLoadBalancerAgentClient

func NewLoadBalancerAgentClient(cc *grpc.ClientConn) LoadBalancerAgentClient

type LoadBalancerConfigRequest

type LoadBalancerConfigRequest struct {
	Loadbalancertype     LoadBalancerType `protobuf:"varint,1,opt,name=loadbalancertype,proto3,enum=moc.lbagent.LoadBalancerType" json:"loadbalancertype,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*LoadBalancerConfigRequest) Descriptor

func (*LoadBalancerConfigRequest) Descriptor() ([]byte, []int)

func (*LoadBalancerConfigRequest) GetLoadbalancertype

func (m *LoadBalancerConfigRequest) GetLoadbalancertype() LoadBalancerType

func (*LoadBalancerConfigRequest) ProtoMessage

func (*LoadBalancerConfigRequest) ProtoMessage()

func (*LoadBalancerConfigRequest) Reset

func (m *LoadBalancerConfigRequest) Reset()

func (*LoadBalancerConfigRequest) String

func (m *LoadBalancerConfigRequest) String() string

func (*LoadBalancerConfigRequest) XXX_DiscardUnknown

func (m *LoadBalancerConfigRequest) XXX_DiscardUnknown()

func (*LoadBalancerConfigRequest) XXX_Marshal

func (m *LoadBalancerConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerConfigRequest) XXX_Merge

func (m *LoadBalancerConfigRequest) XXX_Merge(src proto.Message)

func (*LoadBalancerConfigRequest) XXX_Size

func (m *LoadBalancerConfigRequest) XXX_Size() int

func (*LoadBalancerConfigRequest) XXX_Unmarshal

func (m *LoadBalancerConfigRequest) XXX_Unmarshal(b []byte) error

type LoadBalancerConfigResponse

type LoadBalancerConfigResponse struct {
	Config               string   `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadBalancerConfigResponse) Descriptor

func (*LoadBalancerConfigResponse) Descriptor() ([]byte, []int)

func (*LoadBalancerConfigResponse) GetConfig

func (m *LoadBalancerConfigResponse) GetConfig() string

func (*LoadBalancerConfigResponse) ProtoMessage

func (*LoadBalancerConfigResponse) ProtoMessage()

func (*LoadBalancerConfigResponse) Reset

func (m *LoadBalancerConfigResponse) Reset()

func (*LoadBalancerConfigResponse) String

func (m *LoadBalancerConfigResponse) String() string

func (*LoadBalancerConfigResponse) XXX_DiscardUnknown

func (m *LoadBalancerConfigResponse) XXX_DiscardUnknown()

func (*LoadBalancerConfigResponse) XXX_Marshal

func (m *LoadBalancerConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerConfigResponse) XXX_Merge

func (m *LoadBalancerConfigResponse) XXX_Merge(src proto.Message)

func (*LoadBalancerConfigResponse) XXX_Size

func (m *LoadBalancerConfigResponse) XXX_Size() int

func (*LoadBalancerConfigResponse) XXX_Unmarshal

func (m *LoadBalancerConfigResponse) XXX_Unmarshal(b []byte) error

type LoadBalancerPeerRequest added in v0.10.9

type LoadBalancerPeerRequest struct {
	Peers                []string `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LoadBalancerPeerRequest) Descriptor added in v0.10.9

func (*LoadBalancerPeerRequest) Descriptor() ([]byte, []int)

func (*LoadBalancerPeerRequest) GetPeers added in v0.10.9

func (m *LoadBalancerPeerRequest) GetPeers() []string

func (*LoadBalancerPeerRequest) ProtoMessage added in v0.10.9

func (*LoadBalancerPeerRequest) ProtoMessage()

func (*LoadBalancerPeerRequest) Reset added in v0.10.9

func (m *LoadBalancerPeerRequest) Reset()

func (*LoadBalancerPeerRequest) String added in v0.10.9

func (m *LoadBalancerPeerRequest) String() string

func (*LoadBalancerPeerRequest) XXX_DiscardUnknown added in v0.10.9

func (m *LoadBalancerPeerRequest) XXX_DiscardUnknown()

func (*LoadBalancerPeerRequest) XXX_Marshal added in v0.10.9

func (m *LoadBalancerPeerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerPeerRequest) XXX_Merge added in v0.10.9

func (m *LoadBalancerPeerRequest) XXX_Merge(src proto.Message)

func (*LoadBalancerPeerRequest) XXX_Size added in v0.10.9

func (m *LoadBalancerPeerRequest) XXX_Size() int

func (*LoadBalancerPeerRequest) XXX_Unmarshal added in v0.10.9

func (m *LoadBalancerPeerRequest) XXX_Unmarshal(b []byte) error

type LoadBalancerPeerResponse added in v0.10.9

type LoadBalancerPeerResponse struct {
	Peers                []string            `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*LoadBalancerPeerResponse) Descriptor added in v0.10.9

func (*LoadBalancerPeerResponse) Descriptor() ([]byte, []int)

func (*LoadBalancerPeerResponse) GetError added in v0.10.9

func (m *LoadBalancerPeerResponse) GetError() string

func (*LoadBalancerPeerResponse) GetPeers added in v0.10.9

func (m *LoadBalancerPeerResponse) GetPeers() []string

func (*LoadBalancerPeerResponse) GetResult added in v0.10.9

func (*LoadBalancerPeerResponse) ProtoMessage added in v0.10.9

func (*LoadBalancerPeerResponse) ProtoMessage()

func (*LoadBalancerPeerResponse) Reset added in v0.10.9

func (m *LoadBalancerPeerResponse) Reset()

func (*LoadBalancerPeerResponse) String added in v0.10.9

func (m *LoadBalancerPeerResponse) String() string

func (*LoadBalancerPeerResponse) XXX_DiscardUnknown added in v0.10.9

func (m *LoadBalancerPeerResponse) XXX_DiscardUnknown()

func (*LoadBalancerPeerResponse) XXX_Marshal added in v0.10.9

func (m *LoadBalancerPeerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerPeerResponse) XXX_Merge added in v0.10.9

func (m *LoadBalancerPeerResponse) XXX_Merge(src proto.Message)

func (*LoadBalancerPeerResponse) XXX_Size added in v0.10.9

func (m *LoadBalancerPeerResponse) XXX_Size() int

func (*LoadBalancerPeerResponse) XXX_Unmarshal added in v0.10.9

func (m *LoadBalancerPeerResponse) XXX_Unmarshal(b []byte) error

type LoadBalancerRequest

type LoadBalancerRequest struct {
	LoadBalancers        []*LoadBalancer  `protobuf:"bytes,1,rep,name=LoadBalancers,proto3" json:"LoadBalancers,omitempty"`
	OperationType        common.Operation `protobuf:"varint,2,opt,name=OperationType,proto3,enum=moc.Operation" json:"OperationType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*LoadBalancerRequest) Descriptor

func (*LoadBalancerRequest) Descriptor() ([]byte, []int)

func (*LoadBalancerRequest) GetLoadBalancers

func (m *LoadBalancerRequest) GetLoadBalancers() []*LoadBalancer

func (*LoadBalancerRequest) GetOperationType

func (m *LoadBalancerRequest) GetOperationType() common.Operation

func (*LoadBalancerRequest) ProtoMessage

func (*LoadBalancerRequest) ProtoMessage()

func (*LoadBalancerRequest) Reset

func (m *LoadBalancerRequest) Reset()

func (*LoadBalancerRequest) String

func (m *LoadBalancerRequest) String() string

func (*LoadBalancerRequest) XXX_DiscardUnknown

func (m *LoadBalancerRequest) XXX_DiscardUnknown()

func (*LoadBalancerRequest) XXX_Marshal

func (m *LoadBalancerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerRequest) XXX_Merge

func (m *LoadBalancerRequest) XXX_Merge(src proto.Message)

func (*LoadBalancerRequest) XXX_Size

func (m *LoadBalancerRequest) XXX_Size() int

func (*LoadBalancerRequest) XXX_Unmarshal

func (m *LoadBalancerRequest) XXX_Unmarshal(b []byte) error

type LoadBalancerResponse

type LoadBalancerResponse struct {
	LoadBalancers        []*LoadBalancer     `protobuf:"bytes,1,rep,name=LoadBalancers,proto3" json:"LoadBalancers,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*LoadBalancerResponse) Descriptor

func (*LoadBalancerResponse) Descriptor() ([]byte, []int)

func (*LoadBalancerResponse) GetError

func (m *LoadBalancerResponse) GetError() string

func (*LoadBalancerResponse) GetLoadBalancers

func (m *LoadBalancerResponse) GetLoadBalancers() []*LoadBalancer

func (*LoadBalancerResponse) GetResult

func (m *LoadBalancerResponse) GetResult() *wrappers.BoolValue

func (*LoadBalancerResponse) ProtoMessage

func (*LoadBalancerResponse) ProtoMessage()

func (*LoadBalancerResponse) Reset

func (m *LoadBalancerResponse) Reset()

func (*LoadBalancerResponse) String

func (m *LoadBalancerResponse) String() string

func (*LoadBalancerResponse) XXX_DiscardUnknown

func (m *LoadBalancerResponse) XXX_DiscardUnknown()

func (*LoadBalancerResponse) XXX_Marshal

func (m *LoadBalancerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerResponse) XXX_Merge

func (m *LoadBalancerResponse) XXX_Merge(src proto.Message)

func (*LoadBalancerResponse) XXX_Size

func (m *LoadBalancerResponse) XXX_Size() int

func (*LoadBalancerResponse) XXX_Unmarshal

func (m *LoadBalancerResponse) XXX_Unmarshal(b []byte) error

type LoadBalancerResyncRequest added in v0.10.9

type LoadBalancerResyncRequest struct {
	LoadBalancers        []*LoadBalancer `protobuf:"bytes,1,rep,name=LoadBalancers,proto3" json:"LoadBalancers,omitempty"`
	Peers                []string        `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*LoadBalancerResyncRequest) Descriptor added in v0.10.9

func (*LoadBalancerResyncRequest) Descriptor() ([]byte, []int)

func (*LoadBalancerResyncRequest) GetLoadBalancers added in v0.10.9

func (m *LoadBalancerResyncRequest) GetLoadBalancers() []*LoadBalancer

func (*LoadBalancerResyncRequest) GetPeers added in v0.10.9

func (m *LoadBalancerResyncRequest) GetPeers() []string

func (*LoadBalancerResyncRequest) ProtoMessage added in v0.10.9

func (*LoadBalancerResyncRequest) ProtoMessage()

func (*LoadBalancerResyncRequest) Reset added in v0.10.9

func (m *LoadBalancerResyncRequest) Reset()

func (*LoadBalancerResyncRequest) String added in v0.10.9

func (m *LoadBalancerResyncRequest) String() string

func (*LoadBalancerResyncRequest) XXX_DiscardUnknown added in v0.10.9

func (m *LoadBalancerResyncRequest) XXX_DiscardUnknown()

func (*LoadBalancerResyncRequest) XXX_Marshal added in v0.10.9

func (m *LoadBalancerResyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerResyncRequest) XXX_Merge added in v0.10.9

func (m *LoadBalancerResyncRequest) XXX_Merge(src proto.Message)

func (*LoadBalancerResyncRequest) XXX_Size added in v0.10.9

func (m *LoadBalancerResyncRequest) XXX_Size() int

func (*LoadBalancerResyncRequest) XXX_Unmarshal added in v0.10.9

func (m *LoadBalancerResyncRequest) XXX_Unmarshal(b []byte) error

type LoadBalancerResyncResponse added in v0.10.9

type LoadBalancerResyncResponse struct {
	LoadBalancers        []*LoadBalancer     `protobuf:"bytes,1,rep,name=LoadBalancers,proto3" json:"LoadBalancers,omitempty"`
	Peers                []string            `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,3,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*LoadBalancerResyncResponse) Descriptor added in v0.10.9

func (*LoadBalancerResyncResponse) Descriptor() ([]byte, []int)

func (*LoadBalancerResyncResponse) GetError added in v0.10.9

func (m *LoadBalancerResyncResponse) GetError() string

func (*LoadBalancerResyncResponse) GetLoadBalancers added in v0.10.9

func (m *LoadBalancerResyncResponse) GetLoadBalancers() []*LoadBalancer

func (*LoadBalancerResyncResponse) GetPeers added in v0.10.9

func (m *LoadBalancerResyncResponse) GetPeers() []string

func (*LoadBalancerResyncResponse) GetResult added in v0.10.9

func (*LoadBalancerResyncResponse) ProtoMessage added in v0.10.9

func (*LoadBalancerResyncResponse) ProtoMessage()

func (*LoadBalancerResyncResponse) Reset added in v0.10.9

func (m *LoadBalancerResyncResponse) Reset()

func (*LoadBalancerResyncResponse) String added in v0.10.9

func (m *LoadBalancerResyncResponse) String() string

func (*LoadBalancerResyncResponse) XXX_DiscardUnknown added in v0.10.9

func (m *LoadBalancerResyncResponse) XXX_DiscardUnknown()

func (*LoadBalancerResyncResponse) XXX_Marshal added in v0.10.9

func (m *LoadBalancerResyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancerResyncResponse) XXX_Merge added in v0.10.9

func (m *LoadBalancerResyncResponse) XXX_Merge(src proto.Message)

func (*LoadBalancerResyncResponse) XXX_Size added in v0.10.9

func (m *LoadBalancerResyncResponse) XXX_Size() int

func (*LoadBalancerResyncResponse) XXX_Unmarshal added in v0.10.9

func (m *LoadBalancerResyncResponse) XXX_Unmarshal(b []byte) error

type LoadBalancerType

type LoadBalancerType int32
const (
	LoadBalancerType_Haproxy    LoadBalancerType = 0
	LoadBalancerType_Keepalived LoadBalancerType = 1
	LoadBalancerType_Nginx      LoadBalancerType = 2
)

func (LoadBalancerType) EnumDescriptor

func (LoadBalancerType) EnumDescriptor() ([]byte, []int)

func (LoadBalancerType) String

func (x LoadBalancerType) String() string

type LoadBalancingRule

type LoadBalancingRule struct {
	FrontendPort         uint32          `protobuf:"varint,1,opt,name=frontendPort,proto3" json:"frontendPort,omitempty"`
	BackendPort          uint32          `protobuf:"varint,2,opt,name=backendPort,proto3" json:"backendPort,omitempty"`
	Protocol             common.Protocol `protobuf:"varint,3,opt,name=protocol,proto3,enum=moc.Protocol" json:"protocol,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*LoadBalancingRule) Descriptor

func (*LoadBalancingRule) Descriptor() ([]byte, []int)

func (*LoadBalancingRule) GetBackendPort

func (m *LoadBalancingRule) GetBackendPort() uint32

func (*LoadBalancingRule) GetFrontendPort

func (m *LoadBalancingRule) GetFrontendPort() uint32

func (*LoadBalancingRule) GetProtocol

func (m *LoadBalancingRule) GetProtocol() common.Protocol

func (*LoadBalancingRule) ProtoMessage

func (*LoadBalancingRule) ProtoMessage()

func (*LoadBalancingRule) Reset

func (m *LoadBalancingRule) Reset()

func (*LoadBalancingRule) String

func (m *LoadBalancingRule) String() string

func (*LoadBalancingRule) XXX_DiscardUnknown

func (m *LoadBalancingRule) XXX_DiscardUnknown()

func (*LoadBalancingRule) XXX_Marshal

func (m *LoadBalancingRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadBalancingRule) XXX_Merge

func (m *LoadBalancingRule) XXX_Merge(src proto.Message)

func (*LoadBalancingRule) XXX_Size

func (m *LoadBalancingRule) XXX_Size() int

func (*LoadBalancingRule) XXX_Unmarshal

func (m *LoadBalancingRule) XXX_Unmarshal(b []byte) error

type UnimplementedLoadBalancerAgentServer

type UnimplementedLoadBalancerAgentServer struct {
}

UnimplementedLoadBalancerAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedLoadBalancerAgentServer) AddPeer added in v0.10.9

func (*UnimplementedLoadBalancerAgentServer) CheckNotification

func (*UnimplementedLoadBalancerAgentServer) Create

func (*UnimplementedLoadBalancerAgentServer) Delete

func (*UnimplementedLoadBalancerAgentServer) Get

func (*UnimplementedLoadBalancerAgentServer) GetConfig

func (*UnimplementedLoadBalancerAgentServer) RemovePeer added in v0.10.9

func (*UnimplementedLoadBalancerAgentServer) Resync added in v0.10.9

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL