grpc

Documentation

Overview

Package grpc provides a gRPC implementation of the Envoy v2 xDS API.

Index

• func NewAPI(log logrus.FieldLogger, cacheMap map[string]Cache) *grpc.Server
• type CDS
  • func (c *CDS) TypeURL() string
  • func (c *CDS) Values(filter func(string) bool) []proto.Message
• type Cache
• type EDS
  • func (e *EDS) TypeURL() string
  • func (e *EDS) Values(filter func(string) bool) []proto.Message
• type LDS
  • func (l *LDS) TypeURL() string
  • func (l *LDS) Values(filter func(string) bool) []proto.Message
• type RDS
  • func (r *RDS) TypeURL() string
  • func (r *RDS) Values(filter func(string) bool) []proto.Message

Functions

func NewAPI

func NewAPI(log logrus.FieldLogger, cacheMap map[string]Cache) *grpc.Server

NewAPI returns a *grpc.Server which responds to the Envoy v2 xDS gRPC API.

Types

type CDS

type CDS struct {
	Cache
}

CDS implements the CDS v2 gRPC API.

func (*CDS) TypeURL

func (c *CDS) TypeURL() string

func (*CDS) Values

func (c *CDS) Values(filter func(string) bool) []proto.Message

Values returns a sorted list of Clusters.

type Cache

type Cache interface {
	// Values returns a slice of proto.Message implementations that match
	// the provided filter.
	Values(func(string) bool) []proto.Message

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

cache represents a source of proto.Message valus that can be registered for interest.

type EDS

type EDS struct {
	Cache
}

EDS implements the EDS v2 gRPC API.

func (*EDS) TypeURL

func (e *EDS) TypeURL() string

func (*EDS) Values

func (e *EDS) Values(filter func(string) bool) []proto.Message

Values returns a sorted list of ClusterLoadAssignments.

type LDS

type LDS struct {
	Cache
}

LDS implements the LDS v2 gRPC API.

func (*LDS) TypeURL

func (l *LDS) TypeURL() string

func (*LDS) Values

func (l *LDS) Values(filter func(string) bool) []proto.Message

Values returns a sorted list of Listeners.

type RDS

type RDS struct {
	Cache
}

RDS implements the RDS v2 gRPC API.

func (*RDS) TypeURL

func (r *RDS) TypeURL() string

func (*RDS) Values

func (r *RDS) Values(filter func(string) bool) []proto.Message

Values returns a sorted list of RouteConfigurations.