PublishWorkspaceAgentLogsUpdateFn func(ctx context.Context, workspaceAgentID uuid.UUID, msg agentsdk.LogsNotifyMessage)

NetworkTelemetryHandler func(batch []*tailnetproto.TelemetryEvent)

BoundaryUsageTracker *boundaryusage.Tracker

LifecycleMetrics *LifecycleMetrics

AccessURL *url.URL

AppHostname string

Database: opts.Database,

Log: opts.Log,

PublishWorkspaceUpdateFn: api.publishWorkspaceUpdate,

Metrics: opts.LifecycleMetrics,

}

api.AppsAPI = &AppsAPI{

"context"

"database/sql"

"slices"

"sync"

"time"

"github.com/google/uuid"

Log slog.Logger

PublishWorkspaceUpdateFn func(context.Context, *database.WorkspaceAgent, wspubsub.WorkspaceEventKind) error

TimeNowFn func() time.Time // defaults to dbtime.Now()

TimeNowFn func() time.Time // defaults to dbtime.Now()

Metrics *LifecycleMetrics

emitMetricsOnce sync.Once

}

func (a *LifecycleAPI) now() time.Time {

}

}

// Emit build duration metric when agent transitions to a terminal startup state.

// We only emit once per agent connection to avoid duplicate metrics.

switch lifecycleState {

case database.WorkspaceAgentLifecycleStateReady,

database.WorkspaceAgentLifecycleStateStartTimeout,

database.WorkspaceAgentLifecycleStateStartError:

a.emitMetricsOnce.Do(func() {

a.emitBuildDurationMetric(ctx, workspaceAgent.ResourceID)

})

}

return req.Lifecycle, nil

}