conduit_proxy_destination

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

Index

• func RegisterDestinationServer(s *grpc.Server, srv DestinationServer)
• type AddrSet
  • func (*AddrSet) Descriptor() ([]byte, []int)
  • func (m *AddrSet) GetAddrs() []*conduit_common.TcpAddress
  • func (*AddrSet) ProtoMessage()
  • func (m *AddrSet) Reset()
  • func (m *AddrSet) String() string
• type DestinationClient
  • func NewDestinationClient(cc *grpc.ClientConn) DestinationClient
• type DestinationServer
• type Destination_GetClient
• type Destination_GetServer
• type Update
  • func (*Update) Descriptor() ([]byte, []int)
  • func (m *Update) GetAdd() *WeightedAddrSet
  • func (m *Update) GetRemove() *AddrSet
  • func (m *Update) GetUpdate() isUpdate_Update
  • func (*Update) ProtoMessage()
  • func (m *Update) Reset()
  • func (m *Update) String() string
  • func (*Update) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
• type Update_Add
• type Update_Remove
• type WeightedAddr
  • func (*WeightedAddr) Descriptor() ([]byte, []int)
  • func (m *WeightedAddr) GetAddr() *conduit_common.TcpAddress
  • func (m *WeightedAddr) GetWeight() uint32
  • func (*WeightedAddr) ProtoMessage()
  • func (m *WeightedAddr) Reset()
  • func (m *WeightedAddr) String() string
• type WeightedAddrSet
  • func (*WeightedAddrSet) Descriptor() ([]byte, []int)
  • func (m *WeightedAddrSet) GetAddrs() []*WeightedAddr
  • func (*WeightedAddrSet) ProtoMessage()
  • func (m *WeightedAddrSet) Reset()
  • func (m *WeightedAddrSet) String() string

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 Update

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

func (*Update) Descriptor

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

func (*Update) GetAdd

func (m *Update) GetAdd() *WeightedAddrSet

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_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"`
}

func (*WeightedAddr) Descriptor

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

func (*WeightedAddr) GetAddr

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

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"`
}

func (*WeightedAddrSet) Descriptor

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

func (*WeightedAddrSet) GetAddrs

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

func (*WeightedAddrSet) ProtoMessage

func (*WeightedAddrSet) ProtoMessage()

func (*WeightedAddrSet) Reset

func (m *WeightedAddrSet) Reset()

func (*WeightedAddrSet) String

func (m *WeightedAddrSet) String() string