tailnet

Documentation

Index

• Constants
• func NewCoordinator(logger slog.Logger, ps pubsub.Pubsub) (agpl.Coordinator, error)
• func NewPGCoord(ctx context.Context, logger slog.Logger, ps pubsub.Pubsub, ...) (agpl.Coordinator, error)
• func ServeWorkspaceProxy(ctx context.Context, conn net.Conn, ma agpl.MultiAgentConn) error

Constants

const (
	EventHeartbeats = "tailnet_coordinator_heartbeat"

	HeartbeatPeriod  = time.Second * 2
	MissedHeartbeats = 3
)

Functions

func NewCoordinator

func NewCoordinator(logger slog.Logger, ps pubsub.Pubsub) (agpl.Coordinator, error)

NewCoordinator creates a new high availability coordinator that uses PostgreSQL pubsub to exchange handshakes.

func NewPGCoord

func NewPGCoord(ctx context.Context, logger slog.Logger, ps pubsub.Pubsub, store database.Store) (agpl.Coordinator, error)

NewPGCoord creates a high-availability coordinator that stores state in the PostgreSQL database and receives notifications of updates via the pubsub.

func ServeWorkspaceProxy

func ServeWorkspaceProxy(ctx context.Context, conn net.Conn, ma agpl.MultiAgentConn) error