conduit_proxy_destination

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 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
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 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 */
}

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) 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.