conduit_proxy_destination

package
v0.4.3 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2018 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package conduit_proxy_destination is a generated protocol buffer package.

It is generated from these files: 

proxy/destination/destination.proto

It has these top-level messages: 

Update
AddrSet
WeightedAddrSet
WeightedAddr
TlsIdentity
NoEndpoints

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDestinationServer 

func RegisterDestinationServer(s *grpc.Server, srv DestinationServer)

Types

type AddrSet 

type AddrSet struct {
	Addrs []*conduit_common.TcpAddress `protobuf:"bytes,1,rep,name=addrs" json:"addrs,omitempty"`
}

func (*AddrSet) Descriptor 

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

func (*AddrSet) GetAddrs 

func (m *AddrSet) GetAddrs() []*conduit_common.TcpAddress

func (*AddrSet) ProtoMessage 

func (*AddrSet) ProtoMessage()

func (*AddrSet) Reset 

func (m *AddrSet) Reset()

func (*AddrSet) String 

func (m *AddrSet) String() string

type DestinationClient 

type DestinationClient interface {
	// Given a destination, return all addresses in that destination as a long-
	// running stream of updates.
	Get(ctx context.Context, in *conduit_common.Destination, opts ...grpc.CallOption) (Destination_GetClient, error)
}

func NewDestinationClient 

func NewDestinationClient(cc *grpc.ClientConn) DestinationClient

type DestinationServer 

type DestinationServer interface {
	// Given a destination, return all addresses in that destination as a long-
	// running stream of updates.
	Get(*conduit_common.Destination, Destination_GetServer) error
}

type Destination_GetClient 

type Destination_GetClient interface {
	Recv() (*Update, error)
	grpc.ClientStream
}

type Destination_GetServer 

type Destination_GetServer interface {
	Send(*Update) error
	grpc.ServerStream
}

type NoEndpoints added in v0.4.0 

type NoEndpoints struct {
	Exists bool `protobuf:"varint,1,opt,name=exists" json:"exists,omitempty"`
}

func (*NoEndpoints) Descriptor added in v0.4.0 

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

func (*NoEndpoints) GetExists added in v0.4.0 

func (m *NoEndpoints) GetExists() bool

func (*NoEndpoints) ProtoMessage added in v0.4.0 

func (*NoEndpoints) ProtoMessage()

func (*NoEndpoints) Reset added in v0.4.0 

func (m *NoEndpoints) Reset()

func (*NoEndpoints) String added in v0.4.0 

func (m *NoEndpoints) String() string

type TlsIdentity added in v0.4.2 

type TlsIdentity struct {
	// Types that are valid to be assigned to Strategy:
	//	*TlsIdentity_K8SPodNamespace_
	Strategy isTlsIdentity_Strategy `protobuf_oneof:"strategy"`
}

Which strategy should be used for verifying TLS.

func (*TlsIdentity) Descriptor added in v0.4.2 

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

func (*TlsIdentity) GetK8SPodNamespace added in v0.4.2 

func (m *TlsIdentity) GetK8SPodNamespace() *TlsIdentity_K8SPodNamespace

func (*TlsIdentity) GetStrategy added in v0.4.2 

func (m *TlsIdentity) GetStrategy() isTlsIdentity_Strategy

func (*TlsIdentity) ProtoMessage added in v0.4.2 

func (*TlsIdentity) ProtoMessage()

func (*TlsIdentity) Reset added in v0.4.2 

func (m *TlsIdentity) Reset()

func (*TlsIdentity) String added in v0.4.2 

func (m *TlsIdentity) String() string

func (*TlsIdentity) XXX_OneofFuncs added in v0.4.2 

func (*TlsIdentity) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type TlsIdentity_K8SPodNamespace added in v0.4.2 

type TlsIdentity_K8SPodNamespace struct {
	// The Kubernetes namespace of the pod's Conduit control plane.
	ControllerNs string `protobuf:"bytes,1,opt,name=controller_ns,json=controllerNs" json:"controller_ns,omitempty"`
	// The Kubernetes namespace that the pod is in.
	PodNs string `protobuf:"bytes,2,opt,name=pod_ns,json=podNs" json:"pod_ns,omitempty"`
	// The name of the pod.
	PodName string `protobuf:"bytes,3,opt,name=pod_name,json=podName" json:"pod_name,omitempty"`
}

Verify the certificate based on the Kubernetes pod name, and ensure that the pod is configured with the same Conduit control plane namespace as this proxy.

func (*TlsIdentity_K8SPodNamespace) Descriptor added in v0.4.2 

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

func (*TlsIdentity_K8SPodNamespace) GetControllerNs added in v0.4.2 

func (m *TlsIdentity_K8SPodNamespace) GetControllerNs() string

func (*TlsIdentity_K8SPodNamespace) GetPodName added in v0.4.2 

func (m *TlsIdentity_K8SPodNamespace) GetPodName() string

func (*TlsIdentity_K8SPodNamespace) GetPodNs added in v0.4.2 

func (m *TlsIdentity_K8SPodNamespace) GetPodNs() string

func (*TlsIdentity_K8SPodNamespace) ProtoMessage added in v0.4.2 

func (*TlsIdentity_K8SPodNamespace) ProtoMessage()

func (*TlsIdentity_K8SPodNamespace) Reset added in v0.4.2 

func (m *TlsIdentity_K8SPodNamespace) Reset()

func (*TlsIdentity_K8SPodNamespace) String added in v0.4.2 

func (m *TlsIdentity_K8SPodNamespace) String() string

type TlsIdentity_K8SPodNamespace_ added in v0.4.2 

type TlsIdentity_K8SPodNamespace_ struct {
	K8SPodNamespace *TlsIdentity_K8SPodNamespace `protobuf:"bytes,1,opt,name=k8s_pod_namespace,json=k8sPodNamespace,oneof"`
}

type Update 

type Update struct {
	// Types that are valid to be assigned to Update:
	//	*Update_Add
	//	*Update_Remove
	//	*Update_NoEndpoints
	Update isUpdate_Update `protobuf_oneof:"update"`
}

func (*Update) Descriptor 

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

func (*Update) GetAdd 

func (m *Update) GetAdd() *WeightedAddrSet

func (*Update) GetNoEndpoints added in v0.4.0 

func (m *Update) GetNoEndpoints() *NoEndpoints

func (*Update) GetRemove 

func (m *Update) GetRemove() *AddrSet

func (*Update) GetUpdate 

func (m *Update) GetUpdate() isUpdate_Update

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) Reset 

func (m *Update) Reset()

func (*Update) String 

func (m *Update) String() string

func (*Update) XXX_OneofFuncs 

func (*Update) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Update_Add 

type Update_Add struct {
	Add *WeightedAddrSet `protobuf:"bytes,1,opt,name=add,oneof"`
}

type Update_NoEndpoints added in v0.4.0 

type Update_NoEndpoints struct {
	NoEndpoints *NoEndpoints `protobuf:"bytes,3,opt,name=no_endpoints,json=noEndpoints,oneof"`
}

type Update_Remove 

type Update_Remove struct {
	Remove *AddrSet `protobuf:"bytes,2,opt,name=remove,oneof"`
}

type WeightedAddr 

type WeightedAddr struct {
	Addr         *conduit_common.TcpAddress `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
	Weight       uint32                     `protobuf:"varint,3,opt,name=weight" json:"weight,omitempty"`
	MetricLabels map[string]string          `` /* 164-byte string literal not displayed */
	TlsIdentity  *TlsIdentity               `protobuf:"bytes,5,opt,name=tls_identity,json=tlsIdentity" json:"tls_identity,omitempty"`
}

func (*WeightedAddr) Descriptor 

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

func (*WeightedAddr) GetAddr 

func (m *WeightedAddr) GetAddr() *conduit_common.TcpAddress

func (*WeightedAddr) GetMetricLabels added in v0.4.0 

func (m *WeightedAddr) GetMetricLabels() map[string]string

func (*WeightedAddr) GetTlsIdentity added in v0.4.2 

func (m *WeightedAddr) GetTlsIdentity() *TlsIdentity

func (*WeightedAddr) GetWeight 

func (m *WeightedAddr) GetWeight() uint32

func (*WeightedAddr) ProtoMessage 

func (*WeightedAddr) ProtoMessage()

func (*WeightedAddr) Reset 

func (m *WeightedAddr) Reset()

func (*WeightedAddr) String 

func (m *WeightedAddr) String() string

type WeightedAddrSet 

type WeightedAddrSet struct {
	Addrs        []*WeightedAddr   `protobuf:"bytes,1,rep,name=addrs" json:"addrs,omitempty"`
	MetricLabels map[string]string `` /* 164-byte string literal not displayed */
}

func (*WeightedAddrSet) Descriptor 

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

func (*WeightedAddrSet) GetAddrs 

func (m *WeightedAddrSet) GetAddrs() []*WeightedAddr

func (*WeightedAddrSet) GetMetricLabels added in v0.4.0 

func (m *WeightedAddrSet) GetMetricLabels() map[string]string

func (*WeightedAddrSet) ProtoMessage 

func (*WeightedAddrSet) ProtoMessage()

func (*WeightedAddrSet) Reset 

func (m *WeightedAddrSet) Reset()

func (*WeightedAddrSet) String 

func (m *WeightedAddrSet) String() string

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.