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
KubeResolver

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
KubeResolver

Index

• type KubeResolver
  • func (*KubeResolver) Descriptor() ([]byte, []int)
  • func (m *KubeResolver) GetNamespace() string
  • func (m *KubeResolver) GetPortName() string
  • func (m *KubeResolver) GetServiceName() string
  • func (*KubeResolver) ProtoMessage()
  • func (m *KubeResolver) Reset()
  • func (m *KubeResolver) String() string
  • func (this *KubeResolver) Validate() error
• type SrvResolver
  • func (*SrvResolver) Descriptor() ([]byte, []int)
  • func (m *SrvResolver) GetDnsName() string
  • func (*SrvResolver) ProtoMessage()
  • func (m *SrvResolver) Reset()
  • func (m *SrvResolver) String() string
  • func (this *SrvResolver) Validate() error

Types

type KubeResolver

type KubeResolver struct {
	// / namespace is the k8s namespace to use.
	// / If unset, it deafults to 'deafult'.
	Namespace string `protobuf:"bytes,1,opt,name=namespace" json:"namespace,omitempty"`
	// / service_name is the k8s service name to use.
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName" json:"service_name,omitempty"`
	// / port_name is the name of the port to bind in the service.
	PortName string `protobuf:"bytes,3,opt,name=port_name,json=portName" json:"port_name,omitempty"`
}

/ KubeResolver uses the Kubernetes Endpoints API to identify the service. / It requires the job to run inside a K8S pod and uses the pod's credentails to fetch the service information.

func (*KubeResolver) Descriptor

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

func (*KubeResolver) GetNamespace

func (m *KubeResolver) GetNamespace() string

func (*KubeResolver) GetPortName

func (m *KubeResolver) GetPortName() string

func (*KubeResolver) GetServiceName

func (m *KubeResolver) GetServiceName() string

func (*KubeResolver) ProtoMessage

func (*KubeResolver) ProtoMessage()

func (*KubeResolver) Reset

func (m *KubeResolver) Reset()

func (*KubeResolver) String

func (m *KubeResolver) String() string

func (*KubeResolver) Validate

func (this *KubeResolver) 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,2,opt,name=dns_name,json=dnsName" json:"dns_name,omitempty"`
}

/ SrvBackend describes a gRPC 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) 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