destination

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 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 

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

func (*NoEndpoints) Descriptor 

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

func (*NoEndpoints) GetExists 

func (m *NoEndpoints) GetExists() bool

func (*NoEndpoints) ProtoMessage 

func (*NoEndpoints) ProtoMessage()

func (*NoEndpoints) Reset 

func (m *NoEndpoints) Reset()

func (*NoEndpoints) String 

func (m *NoEndpoints) String() string

type TlsIdentity 

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

Which strategy should be used for verifying TLS.

func (*TlsIdentity) Descriptor 

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

func (*TlsIdentity) GetK8SPodIdentity 

func (m *TlsIdentity) GetK8SPodIdentity() *TlsIdentity_K8SPodIdentity

func (*TlsIdentity) GetStrategy 

func (m *TlsIdentity) GetStrategy() isTlsIdentity_Strategy

func (*TlsIdentity) ProtoMessage 

func (*TlsIdentity) ProtoMessage()

func (*TlsIdentity) Reset 

func (m *TlsIdentity) Reset()

func (*TlsIdentity) String 

func (m *TlsIdentity) String() string

func (*TlsIdentity) XXX_OneofFuncs 

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_K8SPodIdentity 

type TlsIdentity_K8SPodIdentity struct {
	// The pod_identity string is of the format:
	// {owner_name}.{owner_type}.{pod_ns}.conduit-managed.{controller_ns}.svc.cluster.local
	PodIdentity string `protobuf:"bytes,1,opt,name=pod_identity,json=podIdentity" json:"pod_identity,omitempty"`
	// The Kubernetes namespace of the pod's Conduit control plane.
	ControllerNs string `protobuf:"bytes,2,opt,name=controller_ns,json=controllerNs" json:"controller_ns,omitempty"`
}

Verify the certificate based on the Kubernetes pod identity.

func (*TlsIdentity_K8SPodIdentity) Descriptor 

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

func (*TlsIdentity_K8SPodIdentity) GetControllerNs 

func (m *TlsIdentity_K8SPodIdentity) GetControllerNs() string

func (*TlsIdentity_K8SPodIdentity) GetPodIdentity 

func (m *TlsIdentity_K8SPodIdentity) GetPodIdentity() string

func (*TlsIdentity_K8SPodIdentity) ProtoMessage 

func (*TlsIdentity_K8SPodIdentity) ProtoMessage()

func (*TlsIdentity_K8SPodIdentity) Reset 

func (m *TlsIdentity_K8SPodIdentity) Reset()

func (*TlsIdentity_K8SPodIdentity) String 

func (m *TlsIdentity_K8SPodIdentity) String() string

type TlsIdentity_K8SPodIdentity_ 

type TlsIdentity_K8SPodIdentity_ struct {
	K8SPodIdentity *TlsIdentity_K8SPodIdentity `protobuf:"bytes,2,opt,name=k8s_pod_identity,json=k8sPodIdentity,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 

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 

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 

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

func (*WeightedAddr) GetTlsIdentity 

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 

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.