envoy

Jan 22, 2021

Changes in this version

+ type APIVersion string

+ const APIv2

+ const APIv3

+ func ParseAPIVersion(version string) (APIVersion, error)

+ func (version APIVersion) String() string

+ type Resource interface

+ type Type string

+ const Cluster

+ const Endpoint

+ const Listener

+ const Route

+ const Runtime

+ const Secret

Jul 16, 2020

Changes in this version

+ func GenerateBootstrapConfig(host string, port uint32) (string, error)

+ func GenerateTlsCertificateSdsConfig(host string, port uint32) (string, error)

Jul 2, 2020

Changes in this version

+ func ResourcesToJSON(pb proto.Message) ([]byte, error)

+ type B64JSON struct

+ func (s B64JSON) Unmarshal(str string, res xds_cache_types.Resource) error

type Callbacks

+ OnError func(nodeID, previousVersion, msg string) error

+ SnapshotCache *cache.SnapshotCache

+ type JSON struct

+ func (s JSON) Marshal(res xds_cache_types.Resource) (string, error)

+ func (s JSON) Unmarshal(str string, res xds_cache_types.Resource) error

+ type ResourceMarshaller interface

+ Marshal func(xds_cache_types.Resource) (string, error)

+ type ResourceUnmarshaller interface

+ Unmarshal func(string, xds_cache_types.Resource) error

+ type Resources struct

+ Clusters []*envoyapi.Cluster

+ Listeners []*envoyapi.Listener

+ func YAMLtoResources(data []byte) (*Resources, error)

+ func (*Resources) ProtoMessage()

+ func (m *Resources) Reset()

+ func (m *Resources) String() string

type XdsServer

+ func (xdss *XdsServer) Start(stopCh <-chan struct{}) error

+ type YAML struct

+ func (s YAML) Unmarshal(str string, res xds_cache_types.Resource) error

Apr 15, 2020

Changes in this version

+ func NewSecret(name, privateKey, certificateChain string) *auth.Secret

+ type Callbacks struct

+ Logger *zap.SugaredLogger

+ func (cb *Callbacks) OnFetchRequest(ctx context.Context, req *v2.DiscoveryRequest) error

+ func (cb *Callbacks) OnFetchResponse(req *v2.DiscoveryRequest, resp *v2.DiscoveryResponse)

+ func (cb *Callbacks) OnStreamClosed(id int64)

+ func (cb *Callbacks) OnStreamOpen(ctx context.Context, id int64, typ string) error

+ func (cb *Callbacks) OnStreamRequest(id int64, req *v2.DiscoveryRequest) error

+ func (cb *Callbacks) OnStreamResponse(id int64, req *v2.DiscoveryRequest, rsp *v2.DiscoveryResponse)

+ type XdsServer struct

+ func NewXdsServer(ctx context.Context, adsPort uint, tlsConfig *tls.Config, ...) *XdsServer

+ func (xdss *XdsServer) GetSnapshotCache() *cache.SnapshotCache

+ func (xdss *XdsServer) RunADSServer() error