envoy

package

v0.0.0-...-a8942de Latest Latest Go to latest Published: Jan 19, 2021 License: GPL-3.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/lfmunoz/cobweb

Links

Open Source Insights

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
type Connection

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL