kedge_config_common_resolvers

Documentation

Overview

Package kedge_config_common_resolvers is a generated protocol buffer package.

It is generated from these files:

kedge/config/common/resolvers/resolvers.proto

It has these top-level messages:

SrvResolver
K8SResolver
HostResolver

Package kedge_config_common_resolvers is a generated protocol buffer package.

It is generated from these files:

kedge/config/common/resolvers/resolvers.proto

It has these top-level messages:

SrvResolver
K8SResolver
HostResolver

Index

• type HostResolver
  • func (*HostResolver) Descriptor() ([]byte, []int)
  • func (m *HostResolver) GetDnsName() string
  • func (m *HostResolver) GetPort() uint32
  • func (*HostResolver) ProtoMessage()
  • func (m *HostResolver) Reset()
  • func (m *HostResolver) String() string
  • func (this *HostResolver) Validate() error
• type K8SResolver
  • func (*K8SResolver) Descriptor() ([]byte, []int)
  • func (m *K8SResolver) GetDnsPortName() string
  • func (*K8SResolver) ProtoMessage()
  • func (m *K8SResolver) Reset()
  • func (m *K8SResolver) String() string
  • func (this *K8SResolver) Validate() error
• type SrvResolver
  • func (*SrvResolver) Descriptor() ([]byte, []int)
  • func (m *SrvResolver) GetDnsName() string
  • func (m *SrvResolver) GetPortOverride() uint32
  • func (*SrvResolver) ProtoMessage()
  • func (m *SrvResolver) Reset()
  • func (m *SrvResolver) String() string
  • func (this *SrvResolver) Validate() error

Types

type HostResolver

type HostResolver struct {
	// / dns_name specifies the address to look up using A record.
	DnsName string `protobuf:"bytes,1,opt,name=dns_name,json=dnsName" json:"dns_name,omitempty"`
	// / port specified the port that the load balancer should go after host lookup.
	Port uint32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
}

/ HostResolver describes a backend that is resolved and load balanced using host resultion with pinned port.

func (*HostResolver) Descriptor

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

func (*HostResolver) GetDnsName

func (m *HostResolver) GetDnsName() string

func (*HostResolver) GetPort

func (m *HostResolver) GetPort() uint32

func (*HostResolver) ProtoMessage

func (*HostResolver) ProtoMessage()

func (*HostResolver) Reset

func (m *HostResolver) Reset()

func (*HostResolver) String

func (m *HostResolver) String() string

func (*HostResolver) Validate

func (this *HostResolver) Validate() error

type K8SResolver

type K8SResolver struct {
	// Common kube DNS name with optional port: "<service><|.namespace>(.whatever suffix)<|:port_name|:value number>"
	// to resolve by this resolver using endpoints API.
	// e.g "backend1.namespace1:http_port1"
	DnsPortName string `protobuf:"bytes,1,opt,name=dns_port_name,json=dnsPortName" json:"dns_port_name,omitempty"`
}

/ K8sResolver uses the Kubernetes Endpoints API to identify the service. / It watched Endpoint API for changes using the pod's credentails to fetch the service information.

func (*K8SResolver) Descriptor

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

func (*K8SResolver) GetDnsPortName

func (m *K8SResolver) GetDnsPortName() string

func (*K8SResolver) ProtoMessage

func (*K8SResolver) ProtoMessage()

func (*K8SResolver) Reset

func (m *K8SResolver) Reset()

func (*K8SResolver) String

func (m *K8SResolver) String() string

func (*K8SResolver) Validate

func (this *K8SResolver) Validate() error

type SrvResolver

type SrvResolver struct {
	// / dns_name specifies the address to look up using DNS SRV. Needs to be a FQDN.
	// / E.g. "_grpc._tcp.someservice.somenamespace.svc.cluster.local"
	DnsName string `protobuf:"bytes,1,opt,name=dns_name,json=dnsName" json:"dns_name,omitempty"`
	// / not recommended, but port override allows to ignore port form SRV record and use one defined here.
	// / Useful when there are multiple services identifed under the same domain.
	PortOverride uint32 `protobuf:"varint,2,opt,name=port_override,json=portOverride" json:"port_override,omitempty"`
}

/ SrvBackend describes a backend that is resolved and load balanced using SRV.

func (*SrvResolver) Descriptor

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

func (*SrvResolver) GetDnsName

func (m *SrvResolver) GetDnsName() string

func (*SrvResolver) GetPortOverride

func (m *SrvResolver) GetPortOverride() uint32

func (*SrvResolver) ProtoMessage

func (*SrvResolver) ProtoMessage()

func (*SrvResolver) Reset

func (m *SrvResolver) Reset()

func (*SrvResolver) String

func (m *SrvResolver) String() string

func (*SrvResolver) Validate

func (this *SrvResolver) Validate() error