cluster

package
v0.5.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Sep 25, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Cluster_LbPolicy_name = map[int32]string{
		0: "ROUND_ROBIN",
		1: "LEAST_REQUEST",
		3: "RANDOM",
	}
	Cluster_LbPolicy_value = map[string]int32{
		"ROUND_ROBIN":   0,
		"LEAST_REQUEST": 1,
		"RANDOM":        3,
	}
)

Enum value maps for Cluster_LbPolicy.

View Source 
var File_api_cluster_circuit_breaker_proto protoreflect.FileDescriptor
View Source 
var File_api_cluster_cluster_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CircuitBreakers 

type CircuitBreakers struct {
	Priority           core.RoutingPriority `protobuf:"varint,1,opt,name=priority,proto3,enum=core.RoutingPriority" json:"priority,omitempty"`
	MaxConnections     uint32               `protobuf:"varint,2,opt,name=max_connections,json=maxConnections,proto3" json:"max_connections,omitempty"`
	MaxPendingRequests uint32               `protobuf:"varint,3,opt,name=max_pending_requests,json=maxPendingRequests,proto3" json:"max_pending_requests,omitempty"`
	MaxRequests        uint32               `protobuf:"varint,4,opt,name=max_requests,json=maxRequests,proto3" json:"max_requests,omitempty"`
	MaxRetries         uint32               `protobuf:"varint,5,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	MaxConnectionPools uint32               `protobuf:"varint,7,opt,name=max_connection_pools,json=maxConnectionPools,proto3" json:"max_connection_pools,omitempty"`
	// contains filtered or unexported fields
}

func (*CircuitBreakers) Descriptor deprecated 

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

Deprecated: Use CircuitBreakers.ProtoReflect.Descriptor instead.

func (*CircuitBreakers) GetMaxConnectionPools 

func (x *CircuitBreakers) GetMaxConnectionPools() uint32

func (*CircuitBreakers) GetMaxConnections 

func (x *CircuitBreakers) GetMaxConnections() uint32

func (*CircuitBreakers) GetMaxPendingRequests 

func (x *CircuitBreakers) GetMaxPendingRequests() uint32

func (*CircuitBreakers) GetMaxRequests 

func (x *CircuitBreakers) GetMaxRequests() uint32

func (*CircuitBreakers) GetMaxRetries 

func (x *CircuitBreakers) GetMaxRetries() uint32

func (*CircuitBreakers) GetPriority 

func (x *CircuitBreakers) GetPriority() core.RoutingPriority

func (*CircuitBreakers) ProtoMessage 

func (*CircuitBreakers) ProtoMessage()

func (*CircuitBreakers) ProtoReflect 

func (x *CircuitBreakers) ProtoReflect() protoreflect.Message

func (*CircuitBreakers) Reset 

func (x *CircuitBreakers) Reset()

func (*CircuitBreakers) String 

func (x *CircuitBreakers) String() string

type Cluster 

type Cluster struct {
	ApiStatus       core.ApiStatus                  `protobuf:"varint,128,opt,name=api_status,json=apiStatus,proto3,enum=core.ApiStatus" json:"api_status,omitempty"`
	Name            string                          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ConnectTimeout  uint32                          `protobuf:"varint,4,opt,name=connect_timeout,json=connectTimeout,proto3" json:"connect_timeout,omitempty"`
	LbPolicy        Cluster_LbPolicy                `protobuf:"varint,6,opt,name=lb_policy,json=lbPolicy,proto3,enum=cluster.Cluster_LbPolicy" json:"lb_policy,omitempty"`
	LoadAssignment  *endpoint.ClusterLoadAssignment `protobuf:"bytes,33,opt,name=load_assignment,json=loadAssignment,proto3" json:"load_assignment,omitempty"`
	CircuitBreakers *CircuitBreakers                `protobuf:"bytes,10,opt,name=circuit_breakers,json=circuitBreakers,proto3" json:"circuit_breakers,omitempty"`
	// contains filtered or unexported fields
}

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetApiStatus 

func (x *Cluster) GetApiStatus() core.ApiStatus

func (*Cluster) GetCircuitBreakers 

func (x *Cluster) GetCircuitBreakers() *CircuitBreakers

func (*Cluster) GetConnectTimeout 

func (x *Cluster) GetConnectTimeout() uint32

func (*Cluster) GetLbPolicy 

func (x *Cluster) GetLbPolicy() Cluster_LbPolicy

func (*Cluster) GetLoadAssignment 

func (x *Cluster) GetLoadAssignment() *endpoint.ClusterLoadAssignment

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

func (x *Cluster) ProtoReflect() protoreflect.Message

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) String 

func (x *Cluster) String() string

type Cluster_LbPolicy 

type Cluster_LbPolicy int32
const (
	Cluster_ROUND_ROBIN   Cluster_LbPolicy = 0
	Cluster_LEAST_REQUEST Cluster_LbPolicy = 1
	Cluster_RANDOM        Cluster_LbPolicy = 3
)

func (Cluster_LbPolicy) Descriptor 

func (Cluster_LbPolicy) Descriptor() protoreflect.EnumDescriptor

func (Cluster_LbPolicy) Enum 

func (x Cluster_LbPolicy) Enum() *Cluster_LbPolicy

func (Cluster_LbPolicy) EnumDescriptor deprecated 

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

Deprecated: Use Cluster_LbPolicy.Descriptor instead.

func (Cluster_LbPolicy) Number 

func (x Cluster_LbPolicy) Number() protoreflect.EnumNumber

func (Cluster_LbPolicy) String 

func (x Cluster_LbPolicy) String() string

func (Cluster_LbPolicy) Type 

func (Cluster_LbPolicy) Type() protoreflect.EnumType

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.