Help us shape the future of Go! Take the 2026 Go Developer Survey

destination

package
v0.4.4 Latest Latest
Warning

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

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

Documentation

Overview

Package destination is a generated protocol buffer package.

It is generated from these files: 

proxy/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.