Documentation
¶
Index ¶
- type Controller
- func (c *Controller) BufferUpdateAccountPeers(ctx context.Context, accountID string) error
- func (c *Controller) DeletePeer(ctx context.Context, accountId string, peerId string) error
- func (c *Controller) DisconnectPeers(ctx context.Context, peerIDs []string)
- func (c *Controller) GetDNSDomain(settings *types.Settings) string
- func (c *Controller) GetNetworkMap(ctx context.Context, peerID string) (*types.NetworkMap, error)
- func (c *Controller) GetValidatedPeerWithMap(ctx context.Context, isRequiresApproval bool, accountID string, ...) (*nbpeer.Peer, *types.NetworkMap, []*posture.Checks, int64, error)
- func (c *Controller) IsConnected(peerID string) bool
- func (c *Controller) OnPeerAdded(ctx context.Context, accountID string, peerID string) error
- func (c *Controller) OnPeerDeleted(ctx context.Context, accountID string, peerID string) error
- func (c *Controller) OnPeerUpdated(accountId string, peer *nbpeer.Peer)
- func (c *Controller) RecalculateNetworkMapCache(ctx context.Context, accountId string) error
- func (c *Controller) StartWarmup(ctx context.Context)
- func (c *Controller) UpdateAccountPeer(ctx context.Context, accountId string, peerId string) error
- func (c *Controller) UpdateAccountPeers(ctx context.Context, accountID string) error
- func (c *Controller) UpdatePeerInNetworkMapCache(accountId string, peer *nbpeer.Peer)
- type Repository
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(ctx context.Context, store store.Store, metrics telemetry.AppMetrics, peersUpdateManager network_map.PeersUpdateManager, requestBuffer account.RequestBuffer, integratedPeerValidator integrated_validator.IntegratedValidator, settingsManager settings.Manager, dnsDomain string, proxyController port_forwarding.Controller) *Controller
func (*Controller) BufferUpdateAccountPeers ¶
func (c *Controller) BufferUpdateAccountPeers(ctx context.Context, accountID string) error
func (*Controller) DeletePeer ¶
func (*Controller) DisconnectPeers ¶
func (c *Controller) DisconnectPeers(ctx context.Context, peerIDs []string)
func (*Controller) GetDNSDomain ¶
func (c *Controller) GetDNSDomain(settings *types.Settings) string
GetDNSDomain returns the configured dnsDomain
func (*Controller) GetNetworkMap ¶
func (c *Controller) GetNetworkMap(ctx context.Context, peerID string) (*types.NetworkMap, error)
GetNetworkMap returns Network map for a given peer (omits original peer from the Peers result)
func (*Controller) GetValidatedPeerWithMap ¶
func (*Controller) IsConnected ¶
func (c *Controller) IsConnected(peerID string) bool
func (*Controller) OnPeerAdded ¶
func (*Controller) OnPeerDeleted ¶
func (*Controller) OnPeerUpdated ¶
func (c *Controller) OnPeerUpdated(accountId string, peer *nbpeer.Peer)
func (*Controller) RecalculateNetworkMapCache ¶
func (c *Controller) RecalculateNetworkMapCache(ctx context.Context, accountId string) error
func (*Controller) StartWarmup ¶
func (c *Controller) StartWarmup(ctx context.Context)
func (*Controller) UpdateAccountPeer ¶
func (*Controller) UpdateAccountPeers ¶
func (c *Controller) UpdateAccountPeers(ctx context.Context, accountID string) error
UpdatePeers updates all peers that belong to an account. Should be called when changes have to be synced to peers.
func (*Controller) UpdatePeerInNetworkMapCache ¶
func (c *Controller) UpdatePeerInNetworkMapCache(accountId string, peer *nbpeer.Peer)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.