integrations

package

v0.2.4 Latest Latest Go to latest Published: Dec 23, 2025 License: BSD-3-Clause Imports: 18 Imported by: 0

Documentation ¶

Index ¶

func InitEventStore(ctx context.Context, dataDir string, key string, _ *Metrics) (activity.Store, string, error)
func InitPermissionsManager(store store.Store, metric metric.Meter) permissions.Manager
func NewController(store store.Store) port_forwarding.Controller
func NewManager(eventStore activity.Store) extra_settings.Manager
func RegisterHandlers(ctx context.Context, prefix string, router *mux.Router, ...) (*mux.Router, error)
type IntegratedValidatorImpl
- func NewIntegratedValidator(_ context.Context, peersManager peers.Manager, ...) (*IntegratedValidatorImpl, error)
type ManagerImpl
- func (m *ManagerImpl) GetExtraSettings(ctx context.Context, accountID string) (*types.ExtraSettings, error)
- func (m *ManagerImpl) UpdateExtraSettings(ctx context.Context, accountID, userID string, ...) (bool, error)
type Metrics
- func InitIntegrationMetrics(ctx context.Context, metrics telemetry.AppMetrics) (*Metrics, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func InitEventStore ¶

func InitEventStore(ctx context.Context, dataDir string, key string, _ *Metrics) (activity.Store, string, error)

func InitPermissionsManager ¶

func InitPermissionsManager(store store.Store, metric metric.Meter) permissions.Manager

func NewController ¶

func NewController(store store.Store) port_forwarding.Controller

func NewManager ¶

func NewManager(eventStore activity.Store) extra_settings.Manager

func RegisterHandlers ¶

func RegisterHandlers(
	ctx context.Context,
	prefix string,
	router *mux.Router,
	accountManager account.Manager,
	integratedValidator integrated_validator.IntegratedValidator,
	meter metric.Meter,
	permissionsManager permissions.Manager,
	peersManager peers.Manager,
	proxyController port_forwarding.Controller,
	settingsManager settings.Manager,
) (*mux.Router, error)

Types ¶

type IntegratedValidatorImpl ¶

type IntegratedValidatorImpl struct {
}

func NewIntegratedValidator ¶

func NewIntegratedValidator(_ context.Context, peersManager peers.Manager, settingsManager settings.Manager, store activity.Store) (*IntegratedValidatorImpl, error)

func (*IntegratedValidatorImpl) GetInvalidPeers ¶

func (v *IntegratedValidatorImpl) GetInvalidPeers(ctx context.Context, accountID string, extraSettings *types.ExtraSettings) (map[string]string, error)

func (*IntegratedValidatorImpl) GetValidatedPeers ¶

func (v *IntegratedValidatorImpl) GetValidatedPeers(_ context.Context, _ string, _ []*types.Group, peers []*nbpeer.Peer, _ *types.ExtraSettings) (map[string]struct{}, error)

func (*IntegratedValidatorImpl) IsNotValidPeer ¶

func (v *IntegratedValidatorImpl) IsNotValidPeer(_ context.Context, _ string, _ *nbpeer.Peer, _ []string, _ *types.ExtraSettings) (bool, bool, error)

func (*IntegratedValidatorImpl) PeerDeleted ¶

func (v *IntegratedValidatorImpl) PeerDeleted(ctx context.Context, _, _ string, extraSettings *types.ExtraSettings) error

func (*IntegratedValidatorImpl) PreparePeer ¶

func (v *IntegratedValidatorImpl) PreparePeer(_ context.Context, _ string, peer *nbpeer.Peer, _ []string, _ *types.ExtraSettings, _ bool) *nbpeer.Peer

func (*IntegratedValidatorImpl) SetPeerInvalidationListener ¶

func (v *IntegratedValidatorImpl) SetPeerInvalidationListener(_ func(accountID string, peerIDs []string))

func (*IntegratedValidatorImpl) Stop ¶

func (v *IntegratedValidatorImpl) Stop(ctx context.Context)

func (*IntegratedValidatorImpl) ValidateExtraSettings ¶

func (v *IntegratedValidatorImpl) ValidateExtraSettings(context.Context, *types.ExtraSettings, *types.ExtraSettings, string, string) error

func (*IntegratedValidatorImpl) ValidateFlowResponse ¶

func (v *IntegratedValidatorImpl) ValidateFlowResponse(ctx context.Context, peerKey string, flowResponse *proto.PKCEAuthorizationFlow) *proto.PKCEAuthorizationFlow

func (*IntegratedValidatorImpl) ValidatePeer ¶

func (v *IntegratedValidatorImpl) ValidatePeer(_ context.Context, update *nbpeer.Peer, _ *nbpeer.Peer, _ string, _ string, _ string, _ []string, _ *types.ExtraSettings) (*nbpeer.Peer, bool, error)

type ManagerImpl ¶

type ManagerImpl struct {
}

func (*ManagerImpl) GetExtraSettings ¶

func (m *ManagerImpl) GetExtraSettings(ctx context.Context, accountID string) (*types.ExtraSettings, error)

func (*ManagerImpl) UpdateExtraSettings ¶

func (m *ManagerImpl) UpdateExtraSettings(ctx context.Context, accountID, userID string, accountExtraSettings *types.ExtraSettings) (bool, error)

type Metrics ¶

type Metrics struct {
	telemetry.AppMetrics
}

func InitIntegrationMetrics ¶

func InitIntegrationMetrics(ctx context.Context, metrics telemetry.AppMetrics) (*Metrics, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
config

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