rest

package

v0.2.1 Latest Latest Go to latest Published: May 15, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/clusterlink-net/clusterlink

Links

Open Source Insights

Documentation ¶

Index ¶

func RegisterHandlers(manager *Manager, srv *rest.Server)
type Manager
- func NewManager(namespace string, storeManager store.Manager, xdsManager *xds.Manager, ...) (*Manager, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func RegisterHandlers ¶

func RegisterHandlers(manager *Manager, srv *rest.Server)

RegisteHandlers registers the HTTP handlers for REST requests.

Types ¶

type Manager ¶

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

Manager of a controlplane, where all API servers delegate their requested actions to.

func NewManager ¶

func NewManager(
	namespace string,
	storeManager store.Manager,
	xdsManager *xds.Manager,
	authzManager *authz.Manager,
	controlManager *control.Manager,
) (*Manager, error)

NewManager returns a new controlplane CRUD manager.

func (*Manager) CreateAccessPolicy ¶

func (m *Manager) CreateAccessPolicy(policy *store.AccessPolicy) error

CreateAccessPolicy creates an access policy to allow/deny specific connections.

func (*Manager) CreateExport ¶

func (m *Manager) CreateExport(export *store.Export) error

CreateExport defines a new route target for ingress dataplane connections.

func (*Manager) CreateImport ¶

func (m *Manager) CreateImport(imp *store.Import) error

CreateImport creates a listening socket for an imported remote service.

func (*Manager) CreatePeer ¶

func (m *Manager) CreatePeer(peer *store.Peer) error

CreatePeer defines a new route target for egress dataplane connections.

func (*Manager) DeleteAccessPolicy ¶

func (m *Manager) DeleteAccessPolicy(name string) (*store.AccessPolicy, error)

DeleteAccessPolicy removes an access policy to allow/deny specific connections.

func (*Manager) DeleteExport ¶

func (m *Manager) DeleteExport(name string) (*store.Export, error)

DeleteExport removes the possibility for ingress dataplane connections to access a given service.

func (*Manager) DeleteImport ¶

func (m *Manager) DeleteImport(name string) (*store.Import, error)

DeleteImport removes the listening socket of a previously imported service.

func (*Manager) DeletePeer ¶

func (m *Manager) DeletePeer(name string) (*store.Peer, error)

DeletePeer removes the possibility for egress dataplane connections to be routed to a given peer.

func (*Manager) GetAccessPolicy ¶

func (m *Manager) GetAccessPolicy(name string) *store.AccessPolicy

GetAccessPolicy returns an access policy with the given name.

func (*Manager) GetAllAccessPolicies ¶

func (m *Manager) GetAllAccessPolicies() []*store.AccessPolicy

GetAllAccessPolicies returns the list of all AccessPolicies.

func (*Manager) GetAllExports ¶

func (m *Manager) GetAllExports() []*store.Export

GetAllExports returns the list of all exports.

func (*Manager) GetAllImports ¶

func (m *Manager) GetAllImports() []*store.Import

GetAllImports returns the list of all imports.

func (*Manager) GetAllPeers ¶

func (m *Manager) GetAllPeers() []*store.Peer

GetAllPeers returns the list of all peers.

func (*Manager) GetExport ¶

func (m *Manager) GetExport(name string) *store.Export

GetExport returns an existing export.

func (*Manager) GetImport ¶

func (m *Manager) GetImport(name string) *store.Import

GetImport returns an existing import.

func (*Manager) GetK8sExport ¶ added in v0.2.1

func (m *Manager) GetK8sExport(name string, export *v1alpha1.Export) error

func (*Manager) GetK8sImport ¶ added in v0.2.0

func (m *Manager) GetK8sImport(name string, imp *v1alpha1.Import) error

func (*Manager) GetK8sPeer ¶ added in v0.2.1

func (m *Manager) GetK8sPeer(name string, peer *v1alpha1.Peer) error

func (*Manager) GetMergeImportList ¶ added in v0.2.0

func (m *Manager) GetMergeImportList() *v1alpha1.ImportList

func (*Manager) GetPeer ¶

func (m *Manager) GetPeer(name string) *store.Peer

GetPeer returns an existing peer.

func (*Manager) UpdateAccessPolicy ¶

func (m *Manager) UpdateAccessPolicy(policy *store.AccessPolicy) error

UpdateAccessPolicy updates an access policy to allow/deny specific connections.

func (*Manager) UpdateExport ¶

func (m *Manager) UpdateExport(export *store.Export) error

UpdateExport updates a new route target for ingress dataplane connections.

func (*Manager) UpdateExportStatus ¶ added in v0.2.1

func (m *Manager) UpdateExportStatus(name string, status *v1alpha1.ExportStatus)

UpdateExportStatus updates the status of an existing export.

func (*Manager) UpdateImport ¶

func (m *Manager) UpdateImport(imp *store.Import) error

UpdateImport updates a listening socket for an imported remote service.

func (*Manager) UpdatePeer ¶

func (m *Manager) UpdatePeer(peer *store.Peer) error

UpdatePeer updates new route target for egress dataplane connections.

func (*Manager) UpdatePeerStatus ¶ added in v0.2.1

func (m *Manager) UpdatePeerStatus(name string, status *v1alpha1.PeerStatus)

UpdatePeerStatus updates the status of an existing peer.

Source Files ¶

View all Source files

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