grpc

Documentation

Overview

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

Index

• func NewAPI(log logrus.FieldLogger, t *contour.Translator) *grpc.Server
• type CDS
  • func (c *CDS) Resources() ([]types.Any, error)
  • func (c *CDS) TypeURL() string
• type ClusterCache
• type ClusterLoadAssignmentCache
• type EDS
  • func (e *EDS) Resources() ([]types.Any, error)
  • func (e *EDS) TypeURL() string
• type LDS
  • func (l *LDS) Resources() ([]types.Any, error)
  • func (l *LDS) TypeURL() string
• type ListenerCache
• type RDS
  • func (r *RDS) Resources() ([]types.Any, error)
  • func (r *RDS) TypeURL() string

Functions

func NewAPI

func NewAPI(log logrus.FieldLogger, t *contour.Translator) *grpc.Server

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

Types

type CDS

type CDS struct {
	ClusterCache
}

CDS implements the CDS v2 gRPC API.

func (*CDS) Resources

func (c *CDS) Resources() ([]types.Any, error)

Resources returns the contents of CDS"s cache as a []types.Any. TODO(dfc) cache the results of Resources in the ClusterCache so we can avoid the error handling.

func (*CDS) TypeURL

func (c *CDS) TypeURL() string

type ClusterCache

type ClusterCache interface {
	// Values returns a copy of the contents of the cache.
	// The slice and its contents should be treated as read-only.
	Values() []proto.Message

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

ClusterCache holds a set of computed v2.Cluster resources.

type ClusterLoadAssignmentCache

type ClusterLoadAssignmentCache interface {
	// Values returns a copy of the contents of the cache.
	// The slice and its contents should be treated as read-only.
	Values() []proto.Message

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

ClusterLoadAssignmentCache holds a set of computed v2.ClusterLoadAssignment resources.

type EDS

type EDS struct {
	ClusterLoadAssignmentCache
}

EDS implements the EDS v2 gRPC API.

func (*EDS) Resources

func (e *EDS) Resources() ([]types.Any, error)

Resources returns the contents of EDS"s cache as a []types.Any. TODO(dfc) cache the results of Resources in the ClusterLoadAssignmentCache so we can avoid the error handling.

func (*EDS) TypeURL

func (e *EDS) TypeURL() string

type LDS

type LDS struct {
	ListenerCache
}

LDS implements the LDS v2 gRPC API.

func (*LDS) Resources

func (l *LDS) Resources() ([]types.Any, error)

Resources returns the contents of LDS"s cache as a []types.Any. TODO(dfc) cache the results of Resources in the ListenerCache so we can avoid the error handling.

func (*LDS) TypeURL

func (l *LDS) TypeURL() string

type ListenerCache

type ListenerCache interface {
	// Values returns a copy of the contents of the cache.
	// The slice and its contents should be treated as read-only.
	Values() []proto.Message

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

ListenerCache holds a set of computed v2.Listener resources.

type RDS

type RDS struct {
	HTTP, HTTPS interface {
		// Values returns a copy of the contents of the cache.
		// The slice and its contents should be treated as read-only.
		Values() []proto.Message
	}
	*contour.Cond
}

RDS implements the RDS v2 gRPC API.

func (*RDS) Resources

func (r *RDS) Resources() ([]types.Any, error)

Resources returns the contents of RDS"s cache as a []types.Any. TODO(dfc) cache the results of Resources in the VirtualHostCache so we can avoid the error handling.

func (*RDS) TypeURL

func (r *RDS) TypeURL() string