envoy

Documentation

Index

• func BuildCluster(remote instance.Remote) *cluster.Cluster
• func BuildClusterResource(remote []instance.Remote) []types.Resource
• func BuildClusters(remote []instance.Remote) []cluster.Cluster
• func BuildListener(lis instance.Local, cluster instance.Remote) *listener.Listener
• func BuildListenerResource(lis []instance.Local, cluster []instance.Remote) []types.Resource
• func BuildListeners(lis []instance.Local, cluster []instance.Remote) []listener.Listener
• func RunManagementServer(ctx context.Context, server serverv3.Server, port uint)
• func Start(appConfig config.AppConfig)
• type Callbacks
  • func (cb *Callbacks) OnFetchRequest(ctx context.Context, req *discoverygrpc.DiscoveryRequest) error
  • func (cb *Callbacks) OnFetchResponse(*discoverygrpc.DiscoveryRequest, *discoverygrpc.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, r *discoverygrpc.DiscoveryRequest) error
  • func (cb *Callbacks) OnStreamResponse(int64, *discoverygrpc.DiscoveryRequest, *discoverygrpc.DiscoveryResponse)
  • func (cb *Callbacks) Report()
• type Connection

Functions

func BuildCluster

func BuildCluster(remote instance.Remote) *cluster.Cluster

func BuildClusterResource

func BuildClusterResource(remote []instance.Remote) []types.Resource

________________________________________________________________________________ CLUSTER ________________________________________________________________________________

func BuildClusters

func BuildClusters(remote []instance.Remote) []cluster.Cluster

func BuildListener

func BuildListener(lis instance.Local, cluster instance.Remote) *listener.Listener

func BuildListenerResource

func BuildListenerResource(lis []instance.Local, cluster []instance.Remote) []types.Resource

________________________________________________________________________________ LISTENER ________________________________________________________________________________

func BuildListeners

func BuildListeners(lis []instance.Local, cluster []instance.Remote) []listener.Listener

func RunManagementServer

func RunManagementServer(ctx context.Context, server serverv3.Server, port uint)

________________________________________________________________________________ RunManagementServer starts an xDS server at the given port. ________________________________________________________________________________

func Start

func Start(appConfig config.AppConfig)

Types

type Callbacks

type Callbacks struct {
	Signal   chan struct{}
	Debug    bool
	Fetches  int
	Requests int

	Cache cachev3.SnapshotCache
	// contains filtered or unexported fields
}

________________________________________________________________________________ GLOBAL ________________________________________________________________________________

func (*Callbacks) OnFetchRequest

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

func (*Callbacks) OnFetchResponse

func (cb *Callbacks) OnFetchResponse(*discoverygrpc.DiscoveryRequest, *discoverygrpc.DiscoveryResponse)

func (*Callbacks) OnStreamClosed

func (cb *Callbacks) OnStreamClosed(id int64)

func (*Callbacks) OnStreamOpen

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

func (*Callbacks) OnStreamRequest

func (cb *Callbacks) OnStreamRequest(id int64, r *discoverygrpc.DiscoveryRequest) error

func (*Callbacks) OnStreamResponse

func (cb *Callbacks) OnStreamResponse(int64, *discoverygrpc.DiscoveryRequest, *discoverygrpc.DiscoveryResponse)

func (*Callbacks) Report

func (cb *Callbacks) Report()

________________________________________________________________________________ callback handlers ________________________________________________________________________________

type Connection

type Connection struct {
	Addr         string
	NodeId       string
	ConnectionId int64
}