kubernetes

Documentation

Index

• Variables
• type UpstreamSpec
  • func (m *UpstreamSpec) Clone() proto.Message
  • func (*UpstreamSpec) Descriptor() ([]byte, []int)
  • func (m *UpstreamSpec) Equal(that interface{}) bool
  • func (x *UpstreamSpec) GetSelector() map[string]string
  • func (x *UpstreamSpec) GetServiceName() string
  • func (x *UpstreamSpec) GetServiceNamespace() string
  • func (x *UpstreamSpec) GetServicePort() uint32
  • func (x *UpstreamSpec) GetServiceSpec() *options.ServiceSpec
  • func (x *UpstreamSpec) GetSubsetSpec() *options.SubsetSpec
  • func (m *UpstreamSpec) Hash(hasher hash.Hash64) (uint64, error)
  • func (m *UpstreamSpec) HashUnique(hasher hash.Hash64) (uint64, error)
  • func (*UpstreamSpec) ProtoMessage()
  • func (x *UpstreamSpec) ProtoReflect() protoreflect.Message
  • func (x *UpstreamSpec) Reset()
  • func (x *UpstreamSpec) String() string

Variables

var File_github_com_solo_io_gloo_projects_gloo_api_v1_options_kubernetes_kubernetes_proto protoreflect.FileDescriptor

Types

type UpstreamSpec

type UpstreamSpec struct {

	// The name of the Kubernetes Service
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// The namespace where the Service lives
	ServiceNamespace string `protobuf:"bytes,2,opt,name=service_namespace,json=serviceNamespace,proto3" json:"service_namespace,omitempty"`
	// The access port of the kubernetes service is listening. This port is used by Gloo to look up the corresponding
	// port on the pod for routing.
	ServicePort uint32 `protobuf:"varint,3,opt,name=service_port,json=servicePort,proto3" json:"service_port,omitempty"`
	// Allows finer-grained filtering of pods for the Upstream. Gloo will select pods based on their labels if
	// any are provided here.
	// (see [Kubernetes labels and selectors](https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/)
	Selector map[string]string `` /* 157-byte string literal not displayed */
	// An optional Service Spec describing the service listening at this address
	ServiceSpec *options.ServiceSpec `protobuf:"bytes,5,opt,name=service_spec,json=serviceSpec,proto3" json:"service_spec,omitempty"`
	// Subset configuration. For discovery sources that has labels (like kubernetes). this
	// configuration allows you to partition the upstream to a set of subsets.
	// for each unique set of keys and values, a subset will be created.
	SubsetSpec *options.SubsetSpec `protobuf:"bytes,6,opt,name=subset_spec,json=subsetSpec,proto3" json:"subset_spec,omitempty"`
	// contains filtered or unexported fields
}

Kubernetes Upstreams represent a set of one or more addressable pods for a Kubernetes Service the Gloo Kubernetes Upstream maps to a single service port. Because Kubernetes Services support multiple ports, Gloo requires that a different upstream be created for each port Kubernetes Upstreams are typically generated automatically by Gloo from the Kubernetes API

func (*UpstreamSpec) Clone

func (m *UpstreamSpec) Clone() proto.Message

Clone function

func (*UpstreamSpec) Descriptor

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

Deprecated: Use UpstreamSpec.ProtoReflect.Descriptor instead.

func (*UpstreamSpec) Equal

func (m *UpstreamSpec) Equal(that interface{}) bool

Equal function

func (*UpstreamSpec) GetSelector

func (x *UpstreamSpec) GetSelector() map[string]string

func (*UpstreamSpec) GetServiceName

func (x *UpstreamSpec) GetServiceName() string

func (*UpstreamSpec) GetServiceNamespace

func (x *UpstreamSpec) GetServiceNamespace() string

func (*UpstreamSpec) GetServicePort

func (x *UpstreamSpec) GetServicePort() uint32

func (*UpstreamSpec) GetServiceSpec

func (x *UpstreamSpec) GetServiceSpec() *options.ServiceSpec

func (*UpstreamSpec) GetSubsetSpec

func (x *UpstreamSpec) GetSubsetSpec() *options.SubsetSpec

func (*UpstreamSpec) Hash

func (m *UpstreamSpec) Hash(hasher hash.Hash64) (uint64, error)

Hash function

Deprecated: due to hashing implemention only using field values. The omission of the field name in the hash calculation can lead to hash collisions. Prefer the HashUnique function instead.

func (*UpstreamSpec) HashUnique

func (m *UpstreamSpec) HashUnique(hasher hash.Hash64) (uint64, error)

HashUnique function generates a hash of the object that is unique to the object by hashing field name and value pairs. Replaces Hash due to original hashing implemention only using field values. The omission of the field name in the hash calculation can lead to hash collisions.

func (*UpstreamSpec) ProtoMessage

func (*UpstreamSpec) ProtoMessage()

func (*UpstreamSpec) ProtoReflect

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

func (*UpstreamSpec) Reset

func (x *UpstreamSpec) Reset()

func (*UpstreamSpec) String

func (x *UpstreamSpec) String() string