xds

package
v0.0.0-...-a1fe31f Latest Latest
Warning

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

Go to latest
Published: Dec 28, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const CONSTANT_HASH_VALUE = "sesame"

nolint:revive

Variables

This section is empty.

Functions

func ClusterLoadAssignmentName

func ClusterLoadAssignmentName(service types.NamespacedName, portName string) string

ClusterLoadAssignmentName generates the name used for an EDS ClusterLoadAssignment, given a fully qualified Service name and port. This name is a contract between the producer of a cluster (i.e. the EDS service) and the consumer of a cluster (most likely a HTTP Route Action).

func NewServer

func NewServer(registry *prometheus.Registry, opts ...grpc.ServerOption) *grpc.Server

NewServer If registry is non-nil gRPC server metrics will be automatically configured and enabled.

Types

type ConstantHashV3

type ConstantHashV3 struct{}

ConstantHashV3 is a specialized node ID hasher used to allow any instance of Envoy to connect to Sesame regardless of the service-node flag configured on Envoy.

func (ConstantHashV3) ID

func (ConstantHashV3) String

func (c ConstantHashV3) String() string

type Counter

type Counter uint64

Counter holds an atomically incrementing counter.

func (*Counter) Next

func (c *Counter) Next() uint64

type Resource

type Resource interface {
	// Contents returns the contents of this resource.
	Contents() []proto.Message

	// Query returns an entry for each resource name supplied.
	Query(names []string) []proto.Message

	// Register registers ch to receive a value when Notify is called.
	Register(chan int, int, ...string)

	// TypeURL returns the typeURL of messages returned from Values.
	TypeURL() string
}

Resource represents a source of proto.Messages that can be registered for interest.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL