kubernetes

Documentation

Index

• Constants
• func EncodeUpstreamSpec(spec UpstreamSpec) *types.Struct
• func NewEndpointDiscovery(masterUrl, kubeconfigPath string, resyncDuration time.Duration) (endpointdiscovery.Interface, error)
• type Plugin
  • func (p *Plugin) GetDependencies(_ *v1.Config) *plugin.Dependencies
  • func (p *Plugin) ProcessUpstream(_ *plugin.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error
• type UpstreamSpec
  • func DecodeUpstreamSpec(generic v1.UpstreamSpec) (*UpstreamSpec, error)

Constants

const (
	// define Upstream type name
	UpstreamTypeKube = "kubernetes"
)

Functions

func EncodeUpstreamSpec

func EncodeUpstreamSpec(spec UpstreamSpec) *types.Struct

func NewEndpointDiscovery

func NewEndpointDiscovery(masterUrl, kubeconfigPath string, resyncDuration time.Duration) (endpointdiscovery.Interface, error)

Types

type Plugin

type Plugin struct{}

func (*Plugin) GetDependencies

func (p *Plugin) GetDependencies(_ *v1.Config) *plugin.Dependencies

func (*Plugin) ProcessUpstream

func (p *Plugin) ProcessUpstream(_ *plugin.UpstreamPluginParams, in *v1.Upstream, out *envoyapi.Cluster) error

type UpstreamSpec

type UpstreamSpec struct {
	ServiceName      string            `json:"service_name"`
	ServiceNamespace string            `json:"service_namespace"`
	ServicePort      int32             `json:"service_port,omitempty"`
	Labels           map[string]string `json:"labels,omitempty"`
}

func DecodeUpstreamSpec

func DecodeUpstreamSpec(generic v1.UpstreamSpec) (*UpstreamSpec, error)