envoy

Documentation

Index

• type Release
  • func (r *Release) DownloadBinaryFromGitHub(ctx context.Context) (io.ReadCloser, error)
  • func (r *Release) String() string
• type Runtime
  • func (r *Runtime) Run(ctx context.Context) error
• type SnapshotManager
  • func NewSnapshotManager(ctx context.Context, mSvc middlewarev1.MiddlewareServiceClient, ...) *SnapshotManager
  • func (m *SnapshotManager) RegisterXDS(srv *grpc.Server)
  • func (s *SnapshotManager) Run(ctx context.Context) error
  • func (s *SnapshotManager) Shutdown()

Types

type Release

type Release struct {
	Version string
	Sha     string
}

func (*Release) DownloadBinaryFromGitHub

func (r *Release) DownloadBinaryFromGitHub(ctx context.Context) (io.ReadCloser, error)

func (*Release) String

func (r *Release) String() string

type Runtime

type Runtime struct {
	EnvoyPath           string
	BootstrapConfigPath string
	Release             *Release
}

Runtime vendors the Envoy binary and runs it.

func (*Runtime) Run

func (r *Runtime) Run(ctx context.Context) error

Run runs the Envoy binary.

type SnapshotManager

type SnapshotManager struct {
	// contains filtered or unexported fields
}

SnapshotManager is responsible for managing the Envoy snapshot cache.

func NewSnapshotManager

func NewSnapshotManager(
	ctx context.Context,
	mSvc middlewarev1.MiddlewareServiceClient,
	eSvc endpointv1.EndpointServiceClient,
	buildBaseDir string,
	host string, port int,
	syncInterval time.Duration) *SnapshotManager

NewSnapshotManager returns a new *SnapshotManager.

func (*SnapshotManager) RegisterXDS

func (m *SnapshotManager) RegisterXDS(srv *grpc.Server)

func (*SnapshotManager) Run

func (s *SnapshotManager) Run(ctx context.Context) error

Run starts a blocking sync loop that updates the snapshot cache at the configured interval.

func (*SnapshotManager) Shutdown

func (s *SnapshotManager) Shutdown()