source

type IPNBusWatcher interface {
	Next() (ipn.Notify, error)
	Close() error
}

type IPNBusWatcherFactory func(ctx context.Context, client *local.Client, mask ipn.NotifyWatchOpt) (IPNBusWatcher, error)

type LocalClientFactory func(server *tsnet.Server) (*local.Client, error)

type Netmap struct {
	PolledAt     time.Time `json:"polled_at"`
	Peers        []Peer    `json:"peers"`
	DaemonState  string    `json:"daemon_state,omitempty"`
	Prefs        Prefs     `json:"prefs,omitempty"`
	Tailnet      Tailnet   `json:"tailnet,omitempty"`
	ErrorMessage string    `json:"error_message,omitempty"`
}

type NetmapSource interface {
	Poll(ctx context.Context) (Netmap, error)
}

type Peer struct {
	ID                string            `json:"id"`
	Name              string            `json:"name"`
	Online            bool              `json:"online"`
	Tags              []string          `json:"tags,omitempty"`
	Owners            []string          `json:"owners,omitempty"`
	IPs               []string          `json:"ips,omitempty"`
	Routes            []string          `json:"routes,omitempty"`
	MachineAuthorized bool              `json:"machine_authorized,omitempty"`
	Expired           bool              `json:"expired,omitempty"`
	KeyExpiry         string            `json:"key_expiry,omitempty"`
	HostinfoHash      string            `json:"hostinfo_hash,omitempty"`
	Metadata          map[string]string `json:"metadata,omitempty"`
}

type Prefs struct {
	AdvertiseRoutes []string `json:"advertise_routes,omitempty"`
	ExitNodeID      string   `json:"exit_node_id,omitempty"`
	RunSSH          bool     `json:"run_ssh,omitempty"`
	ShieldsUp       bool     `json:"shields_up,omitempty"`
}

type RealtimeConfig struct {
	WatchMask      ipn.NotifyWatchOpt
	ReconnectMin   time.Duration
	ReconnectMax   time.Duration
	Logger         *zap.Logger
	NewWatcher     IPNBusWatcherFactory
	NewLocalClient LocalClientFactory
}

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

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

type TSNetFetchFunc func(ctx context.Context, server *tsnet.Server) (Netmap, error)

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

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

type Tailnet struct {
	Domain     string `json:"domain,omitempty"`
	TKAEnabled bool   `json:"tka_enabled,omitempty"`
}