proxy

package

v0.0.0-...-b55e7ca Latest Latest Go to latest Published: Feb 26, 2026 License: AGPL-3.0 Imports: 22 Imported by: 0

Details

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

Repository

github.com/spacechunks/explorer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DNSClusterResource() *clusterv3.Cluster
func DNSListenerResourceGroup(workloadID string, clusterName string, listenerAddr netip.AddrPort, ...) (xds.ResourceGroup, error)
func OriginalDstClusterResource() *clusterv3.Cluster
func WorkloadResources(workloadID string, httpListenerAddr netip.AddrPort, ...) (xds.ResourceGroup, error)
type Config
type Server
- func NewServer(svc Service) *Server
- func (s *Server) CreateListeners(ctx context.Context, req *proxyv1alpha1.CreateListenersRequest) (*proxyv1alpha1.CreateListenersResponse, error)
- func (s *Server) DeleteListeners(ctx context.Context, req *proxyv1alpha1.DeleteListenersRequest) (*proxyv1alpha1.DeleteListenersResponse, error)
type Service
- func NewService(logger *slog.Logger, cfg Config, resourceMap xds.Map) Service

Constants ¶

View Source

const (
	DNSClusterName         = "dns"
	OriginalDstClusterName = "public"
	TCPPort                = 9111
	HTTPPort               = 9080
	DNSPort                = 9053
)

Variables ¶

This section is empty.

Functions ¶

func DNSClusterResource ¶

func DNSClusterResource() *clusterv3.Cluster

func DNSListenerResourceGroup ¶

func DNSListenerResourceGroup(
	workloadID string,
	clusterName string,
	listenerAddr netip.AddrPort,
	upstreamAddr netip.AddrPort,
) (xds.ResourceGroup, error)

func OriginalDstClusterResource ¶

func OriginalDstClusterResource() *clusterv3.Cluster

func WorkloadResources ¶

func WorkloadResources(
	workloadID string,
	httpListenerAddr netip.AddrPort,
	tcpListenerAddr netip.AddrPort,
	originalDstClusterName string,
) (xds.ResourceGroup, error)

Types ¶

type Config ¶

type Config struct {
	DNSUpstream netip.AddrPort
}

type Server ¶

type Server struct {
	proxyv1alpha1.UnimplementedProxyServiceServer
	// contains filtered or unexported fields
}

func NewServer ¶

func NewServer(svc Service) *Server

func (*Server) CreateListeners ¶

func (s *Server) CreateListeners(
	ctx context.Context,
	req *proxyv1alpha1.CreateListenersRequest,
) (*proxyv1alpha1.CreateListenersResponse, error)

func (*Server) DeleteListeners ¶

func (s *Server) DeleteListeners(
	ctx context.Context,
	req *proxyv1alpha1.DeleteListenersRequest,
) (*proxyv1alpha1.DeleteListenersResponse, error)

type Service ¶

type Service interface {
	CreateListeners(ctx context.Context, workloadID string, addr netip.Addr) error
	ApplyGlobalResources(ctx context.Context) error
	DeleteListeners(ctx context.Context, workloadID string) error
}

func NewService ¶

func NewService(logger *slog.Logger, cfg Config, resourceMap xds.Map) Service

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
xds

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