core

package
v1.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2026 License: GPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Core

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

func New

func New(st store.Disk, conn *connection.Service, subs *subscription.Service) (*Core, error)

func (*Core) AddSubscription

func (c *Core) AddSubscription(ctx context.Context, rawURL string) error

func (*Core) Connect

func (c *Core) Connect(ctx context.Context, nodeID, subscriptionID string) error

func (*Core) Disconnect

func (c *Core) Disconnect(ctx context.Context) error

func (*Core) MoveSubscription

func (c *Core) MoveSubscription(id string, dir int) error

func (*Core) Probe

func (c *Core) Probe(ctx context.Context, sub, id string) error

func (*Core) RefreshSubscription

func (c *Core) RefreshSubscription(ctx context.Context, id string) error

func (*Core) RefreshSubscriptions

func (c *Core) RefreshSubscriptions(ctx context.Context) error

func (*Core) RemoveSubscription

func (c *Core) RemoveSubscription(id string) error

func (*Core) RestartRequested

func (c *Core) RestartRequested() <-chan struct{}

func (*Core) Restore

func (c *Core) Restore()

func (*Core) SetSettings

func (c *Core) SetSettings(ctx context.Context, settings domain.Settings) error

func (*Core) SetTun

func (c *Core) SetTun(ctx context.Context, enable bool) error

func (*Core) Shutdown

func (c *Core) Shutdown()

func (*Core) Snapshot

func (c *Core) Snapshot() ipc.Snapshot

func (*Core) Watch

func (c *Core) Watch() (ipc.Changed, <-chan ipc.Changed, func())

Jump to

Keyboard shortcuts

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