package stream

import "github.com/envoyproxy/go-control-plane/pkg/server/stream/v3"

Index

Types

type DeltaStream

type DeltaStream interface {
	grpc.ServerStream

	Send(*discovery.DeltaDiscoveryResponse) error
	Recv() (*discovery.DeltaDiscoveryRequest, error)
}

type Stream

type Stream interface {
	grpc.ServerStream

	Send(*discovery.DiscoveryResponse) error
	Recv() (*discovery.DiscoveryRequest, error)
}

Generic RPC stream.

type StreamState

type StreamState struct {
	// Indicates whether the original DeltaRequest was a wildcard LDS/RDS request.
	IsWildcard bool

	// ResourceVersions contains a hash of the resource as the value and the resource name as the key.
	// This field stores the last state sent to the client.
	ResourceVersions map[string]string
}

StreamState will keep track of resource state on a stream

Source Files

stream.go

Version
v0.9.9
Published
May 21, 2021
Platform
darwin/amd64
Imports
2 packages
Last checked
7 minutes ago

Tools for package owners.