grpc: google.golang.org/grpc/xds/internal/proto/envoy/api/v2/eds Index | Files

package envoy_api_v2

import "google.golang.org/grpc/xds/internal/proto/envoy/api/v2/eds"

Index

Package Files

eds.pb.go

func RegisterEndpointDiscoveryServiceServer Uses

func RegisterEndpointDiscoveryServiceServer(s *grpc.Server, srv EndpointDiscoveryServiceServer)

type ClusterLoadAssignment Uses

type ClusterLoadAssignment struct {
    ClusterName          string                          `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
    Endpoints            []*endpoint.LocalityLbEndpoints `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
    NamedEndpoints       map[string]*endpoint.Endpoint   `protobuf:"bytes,5,rep,name=named_endpoints,json=namedEndpoints,proto3" json:"named_endpoints,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    Policy               *ClusterLoadAssignment_Policy   `protobuf:"bytes,4,opt,name=policy,proto3" json:"policy,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
    XXX_unrecognized     []byte                          `json:"-"`
    XXX_sizecache        int32                           `json:"-"`
}

func (*ClusterLoadAssignment) Descriptor Uses

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

func (*ClusterLoadAssignment) GetClusterName Uses

func (m *ClusterLoadAssignment) GetClusterName() string

func (*ClusterLoadAssignment) GetEndpoints Uses

func (m *ClusterLoadAssignment) GetEndpoints() []*endpoint.LocalityLbEndpoints

func (*ClusterLoadAssignment) GetNamedEndpoints Uses

func (m *ClusterLoadAssignment) GetNamedEndpoints() map[string]*endpoint.Endpoint

func (*ClusterLoadAssignment) GetPolicy Uses

func (m *ClusterLoadAssignment) GetPolicy() *ClusterLoadAssignment_Policy

func (*ClusterLoadAssignment) ProtoMessage Uses

func (*ClusterLoadAssignment) ProtoMessage()

func (*ClusterLoadAssignment) Reset Uses

func (m *ClusterLoadAssignment) Reset()

func (*ClusterLoadAssignment) String Uses

func (m *ClusterLoadAssignment) String() string

func (*ClusterLoadAssignment) XXX_DiscardUnknown Uses

func (m *ClusterLoadAssignment) XXX_DiscardUnknown()

func (*ClusterLoadAssignment) XXX_Marshal Uses

func (m *ClusterLoadAssignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterLoadAssignment) XXX_Merge Uses

func (dst *ClusterLoadAssignment) XXX_Merge(src proto.Message)

func (*ClusterLoadAssignment) XXX_Size Uses

func (m *ClusterLoadAssignment) XXX_Size() int

func (*ClusterLoadAssignment) XXX_Unmarshal Uses

func (m *ClusterLoadAssignment) XXX_Unmarshal(b []byte) error

type ClusterLoadAssignment_Policy Uses

type ClusterLoadAssignment_Policy struct {
    DropOverloads          []*ClusterLoadAssignment_Policy_DropOverload `protobuf:"bytes,2,rep,name=drop_overloads,json=dropOverloads,proto3" json:"drop_overloads,omitempty"`
    OverprovisioningFactor *wrappers.UInt32Value                        `protobuf:"bytes,3,opt,name=overprovisioning_factor,json=overprovisioningFactor,proto3" json:"overprovisioning_factor,omitempty"`
    EndpointStaleAfter     *duration.Duration                           `protobuf:"bytes,4,opt,name=endpoint_stale_after,json=endpointStaleAfter,proto3" json:"endpoint_stale_after,omitempty"`
    XXX_NoUnkeyedLiteral   struct{}                                     `json:"-"`
    XXX_unrecognized       []byte                                       `json:"-"`
    XXX_sizecache          int32                                        `json:"-"`
}

func (*ClusterLoadAssignment_Policy) Descriptor Uses

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

func (*ClusterLoadAssignment_Policy) GetDropOverloads Uses

func (m *ClusterLoadAssignment_Policy) GetDropOverloads() []*ClusterLoadAssignment_Policy_DropOverload

func (*ClusterLoadAssignment_Policy) GetEndpointStaleAfter Uses

func (m *ClusterLoadAssignment_Policy) GetEndpointStaleAfter() *duration.Duration

func (*ClusterLoadAssignment_Policy) GetOverprovisioningFactor Uses

func (m *ClusterLoadAssignment_Policy) GetOverprovisioningFactor() *wrappers.UInt32Value

func (*ClusterLoadAssignment_Policy) ProtoMessage Uses

func (*ClusterLoadAssignment_Policy) ProtoMessage()

func (*ClusterLoadAssignment_Policy) Reset Uses

func (m *ClusterLoadAssignment_Policy) Reset()

func (*ClusterLoadAssignment_Policy) String Uses

func (m *ClusterLoadAssignment_Policy) String() string

func (*ClusterLoadAssignment_Policy) XXX_DiscardUnknown Uses

func (m *ClusterLoadAssignment_Policy) XXX_DiscardUnknown()

func (*ClusterLoadAssignment_Policy) XXX_Marshal Uses

func (m *ClusterLoadAssignment_Policy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterLoadAssignment_Policy) XXX_Merge Uses

func (dst *ClusterLoadAssignment_Policy) XXX_Merge(src proto.Message)

func (*ClusterLoadAssignment_Policy) XXX_Size Uses

func (m *ClusterLoadAssignment_Policy) XXX_Size() int

func (*ClusterLoadAssignment_Policy) XXX_Unmarshal Uses

func (m *ClusterLoadAssignment_Policy) XXX_Unmarshal(b []byte) error

type ClusterLoadAssignment_Policy_DropOverload Uses

type ClusterLoadAssignment_Policy_DropOverload struct {
    Category             string                     `protobuf:"bytes,1,opt,name=category,proto3" json:"category,omitempty"`
    DropPercentage       *percent.FractionalPercent `protobuf:"bytes,2,opt,name=drop_percentage,json=dropPercentage,proto3" json:"drop_percentage,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
    XXX_unrecognized     []byte                     `json:"-"`
    XXX_sizecache        int32                      `json:"-"`
}

func (*ClusterLoadAssignment_Policy_DropOverload) Descriptor Uses

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

func (*ClusterLoadAssignment_Policy_DropOverload) GetCategory Uses

func (m *ClusterLoadAssignment_Policy_DropOverload) GetCategory() string

func (*ClusterLoadAssignment_Policy_DropOverload) GetDropPercentage Uses

func (m *ClusterLoadAssignment_Policy_DropOverload) GetDropPercentage() *percent.FractionalPercent

func (*ClusterLoadAssignment_Policy_DropOverload) ProtoMessage Uses

func (*ClusterLoadAssignment_Policy_DropOverload) ProtoMessage()

func (*ClusterLoadAssignment_Policy_DropOverload) Reset Uses

func (m *ClusterLoadAssignment_Policy_DropOverload) Reset()

func (*ClusterLoadAssignment_Policy_DropOverload) String Uses

func (m *ClusterLoadAssignment_Policy_DropOverload) String() string

func (*ClusterLoadAssignment_Policy_DropOverload) XXX_DiscardUnknown Uses

func (m *ClusterLoadAssignment_Policy_DropOverload) XXX_DiscardUnknown()

func (*ClusterLoadAssignment_Policy_DropOverload) XXX_Marshal Uses

func (m *ClusterLoadAssignment_Policy_DropOverload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterLoadAssignment_Policy_DropOverload) XXX_Merge Uses

func (dst *ClusterLoadAssignment_Policy_DropOverload) XXX_Merge(src proto.Message)

func (*ClusterLoadAssignment_Policy_DropOverload) XXX_Size Uses

func (m *ClusterLoadAssignment_Policy_DropOverload) XXX_Size() int

func (*ClusterLoadAssignment_Policy_DropOverload) XXX_Unmarshal Uses

func (m *ClusterLoadAssignment_Policy_DropOverload) XXX_Unmarshal(b []byte) error

type EndpointDiscoveryServiceClient Uses

type EndpointDiscoveryServiceClient interface {
    StreamEndpoints(ctx context.Context, opts ...grpc.CallOption) (EndpointDiscoveryService_StreamEndpointsClient, error)
    DeltaEndpoints(ctx context.Context, opts ...grpc.CallOption) (EndpointDiscoveryService_DeltaEndpointsClient, error)
    FetchEndpoints(ctx context.Context, in *discovery.DiscoveryRequest, opts ...grpc.CallOption) (*discovery.DiscoveryResponse, error)
}

EndpointDiscoveryServiceClient is the client API for EndpointDiscoveryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEndpointDiscoveryServiceClient Uses

func NewEndpointDiscoveryServiceClient(cc *grpc.ClientConn) EndpointDiscoveryServiceClient

type EndpointDiscoveryServiceServer Uses

type EndpointDiscoveryServiceServer interface {
    StreamEndpoints(EndpointDiscoveryService_StreamEndpointsServer) error
    DeltaEndpoints(EndpointDiscoveryService_DeltaEndpointsServer) error
    FetchEndpoints(context.Context, *discovery.DiscoveryRequest) (*discovery.DiscoveryResponse, error)
}

EndpointDiscoveryServiceServer is the server API for EndpointDiscoveryService service.

type EndpointDiscoveryService_DeltaEndpointsClient Uses

type EndpointDiscoveryService_DeltaEndpointsClient interface {
    Send(*discovery.DeltaDiscoveryRequest) error
    Recv() (*discovery.DeltaDiscoveryResponse, error)
    grpc.ClientStream
}

type EndpointDiscoveryService_DeltaEndpointsServer Uses

type EndpointDiscoveryService_DeltaEndpointsServer interface {
    Send(*discovery.DeltaDiscoveryResponse) error
    Recv() (*discovery.DeltaDiscoveryRequest, error)
    grpc.ServerStream
}

type EndpointDiscoveryService_StreamEndpointsClient Uses

type EndpointDiscoveryService_StreamEndpointsClient interface {
    Send(*discovery.DiscoveryRequest) error
    Recv() (*discovery.DiscoveryResponse, error)
    grpc.ClientStream
}

type EndpointDiscoveryService_StreamEndpointsServer Uses

type EndpointDiscoveryService_StreamEndpointsServer interface {
    Send(*discovery.DiscoveryResponse) error
    Recv() (*discovery.DiscoveryRequest, error)
    grpc.ServerStream
}

Package envoy_api_v2 imports 12 packages (graph) and is imported by 3 packages. Updated 2019-08-12. Refresh now. Tools for package owners.