lbagent

package
v0.10.0-alpha-vishal1 Latest Latest
Warning

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

 Go to latest Published: Jun 27, 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 

type LoadBalancerAgentClient interface {
	Create(ctx context.Context, in *LoadBalancerRequest, opts ...grpc.CallOption) (*LoadBalancerResponse, error)
	Delete(ctx context.Context, in *LoadBalancerRequest, opts ...grpc.CallOption) (*LoadBalancerResponse, error)
	Get(ctx context.Context, in *LoadBalancerRequest, opts ...grpc.CallOption) (*LoadBalancerResponse, error)
	// GetConfig is for debugging/testing
	GetConfig(ctx context.Context, in *LoadBalancerConfigRequest, opts ...grpc.CallOption) (*LoadBalancerConfigResponse, error)
	CheckNotification(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*common.NotificationResponse, error)
	AddPeer(ctx context.Context, in *LoadBalancerPeerRequest, opts ...grpc.CallOption) (*LoadBalancerPeerResponse, error)
	RemovePeer(ctx context.Context, in *LoadBalancerPeerRequest, opts ...grpc.CallOption) (*LoadBalancerPeerResponse, error)
	Resync(ctx context.Context, in *LoadBalancerResyncRequest, opts ...grpc.CallOption) (*LoadBalancerResyncResponse, error)
}

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 LoadBalancerAgentServer 

type LoadBalancerAgentServer interface {
	Create(context.Context, *LoadBalancerRequest) (*LoadBalancerResponse, error)
	Delete(context.Context, *LoadBalancerRequest) (*LoadBalancerResponse, error)
	Get(context.Context, *LoadBalancerRequest) (*LoadBalancerResponse, error)
	// GetConfig is for debugging/testing
	GetConfig(context.Context, *LoadBalancerConfigRequest) (*LoadBalancerConfigResponse, error)
	CheckNotification(context.Context, *empty.Empty) (*common.NotificationResponse, error)
	AddPeer(context.Context, *LoadBalancerPeerRequest) (*LoadBalancerPeerResponse, error)
	RemovePeer(context.Context, *LoadBalancerPeerRequest) (*LoadBalancerPeerResponse, error)
	Resync(context.Context, *LoadBalancerResyncRequest) (*LoadBalancerResyncResponse, error)
}

LoadBalancerAgentServer is the server API for LoadBalancerAgent service.

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 (m *LoadBalancerPeerResponse) GetResult() *wrappers.BoolValue

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 (m *LoadBalancerResyncResponse) GetResult() *wrappers.BoolValue

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) AddPeer(ctx context.Context, req *LoadBalancerPeerRequest) (*LoadBalancerPeerResponse, error)

func (*UnimplementedLoadBalancerAgentServer) CheckNotification 

func (*UnimplementedLoadBalancerAgentServer) CheckNotification(ctx context.Context, req *empty.Empty) (*common.NotificationResponse, error)

func (*UnimplementedLoadBalancerAgentServer) Create 

func (*UnimplementedLoadBalancerAgentServer) Create(ctx context.Context, req *LoadBalancerRequest) (*LoadBalancerResponse, error)

func (*UnimplementedLoadBalancerAgentServer) Delete 

func (*UnimplementedLoadBalancerAgentServer) Delete(ctx context.Context, req *LoadBalancerRequest) (*LoadBalancerResponse, error)

func (*UnimplementedLoadBalancerAgentServer) Get 

func (*UnimplementedLoadBalancerAgentServer) Get(ctx context.Context, req *LoadBalancerRequest) (*LoadBalancerResponse, error)

func (*UnimplementedLoadBalancerAgentServer) GetConfig 

func (*UnimplementedLoadBalancerAgentServer) GetConfig(ctx context.Context, req *LoadBalancerConfigRequest) (*LoadBalancerConfigResponse, error)

func (*UnimplementedLoadBalancerAgentServer) RemovePeer added in v0.10.9 

func (*UnimplementedLoadBalancerAgentServer) RemovePeer(ctx context.Context, req *LoadBalancerPeerRequest) (*LoadBalancerPeerResponse, error)

func (*UnimplementedLoadBalancerAgentServer) Resync added in v0.10.9 

func (*UnimplementedLoadBalancerAgentServer) Resync(ctx context.Context, req *LoadBalancerResyncRequest) (*LoadBalancerResyncResponse, error)

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.