Documentation ¶
Index ¶
- func RegisterHandlers(manager *Manager, srv *rest.Server)
- type Manager
- func (m *Manager) CreateAccessPolicy(policy *store.AccessPolicy) error
- func (m *Manager) CreateExport(export *store.Export) error
- func (m *Manager) CreateImport(imp *store.Import) error
- func (m *Manager) CreatePeer(peer *store.Peer) error
- func (m *Manager) DeleteAccessPolicy(name string) (*store.AccessPolicy, error)
- func (m *Manager) DeleteExport(name string) (*store.Export, error)
- func (m *Manager) DeleteImport(name string) (*store.Import, error)
- func (m *Manager) DeletePeer(name string) (*store.Peer, error)
- func (m *Manager) GetAccessPolicy(name string) *store.AccessPolicy
- func (m *Manager) GetAllAccessPolicies() []*store.AccessPolicy
- func (m *Manager) GetAllExports() []*store.Export
- func (m *Manager) GetAllImports() []*store.Import
- func (m *Manager) GetAllPeers() []*store.Peer
- func (m *Manager) GetExport(name string) *store.Export
- func (m *Manager) GetImport(name string) *store.Import
- func (m *Manager) GetK8sExport(name string, export *v1alpha1.Export) error
- func (m *Manager) GetK8sImport(name string, imp *v1alpha1.Import) error
- func (m *Manager) GetK8sPeer(name string, peer *v1alpha1.Peer) error
- func (m *Manager) GetMergeImportList() *v1alpha1.ImportList
- func (m *Manager) GetPeer(name string) *store.Peer
- func (m *Manager) UpdateAccessPolicy(policy *store.AccessPolicy) error
- func (m *Manager) UpdateExport(export *store.Export) error
- func (m *Manager) UpdateExportStatus(name string, status *v1alpha1.ExportStatus)
- func (m *Manager) UpdateImport(imp *store.Import) error
- func (m *Manager) UpdatePeer(peer *store.Peer) error
- func (m *Manager) UpdatePeerStatus(name string, status *v1alpha1.PeerStatus)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterHandlers ¶
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 ¶
CreateExport defines a new route target for ingress dataplane connections.
func (*Manager) CreateImport ¶
CreateImport creates a listening socket for an imported remote service.
func (*Manager) CreatePeer ¶
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 ¶
DeleteExport removes the possibility for ingress dataplane connections to access a given service.
func (*Manager) DeleteImport ¶
DeleteImport removes the listening socket of a previously imported service.
func (*Manager) DeletePeer ¶
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 ¶
GetAllExports returns the list of all exports.
func (*Manager) GetAllImports ¶
GetAllImports returns the list of all imports.
func (*Manager) GetAllPeers ¶
GetAllPeers returns the list of all peers.
func (*Manager) GetK8sExport ¶ added in v0.2.1
func (*Manager) GetK8sImport ¶ added in v0.2.0
func (*Manager) GetK8sPeer ¶ added in v0.2.1
func (*Manager) GetMergeImportList ¶ added in v0.2.0
func (m *Manager) GetMergeImportList() *v1alpha1.ImportList
func (*Manager) UpdateAccessPolicy ¶
func (m *Manager) UpdateAccessPolicy(policy *store.AccessPolicy) error
UpdateAccessPolicy updates an access policy to allow/deny specific connections.
func (*Manager) UpdateExport ¶
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 ¶
UpdateImport updates a listening socket for an imported remote service.
func (*Manager) UpdatePeer ¶
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.