rworkspace

type WorkspaceEvent struct {
	Type      string
	Workspace *apiv1.Workspace
}

type WorkspaceServiceRPC struct {
	DB *sql.DB
	// contains filtered or unexported fields
}

type WorkspaceServiceRPCDeps struct {
	DB        *sql.DB
	Services  WorkspaceServiceRPCServices
	Readers   WorkspaceServiceRPCReaders
	Streamers WorkspaceServiceRPCStreamers
	Publisher mutation.Publisher // Unified publisher for cascade delete events
}

type WorkspaceServiceRPCReaders struct {
	Workspace *sworkspace.WorkspaceReader
	User      *sworkspace.UserReader
}

type WorkspaceServiceRPCServices struct {
	Workspace     sworkspace.WorkspaceService
	WorkspaceUser sworkspace.UserService
	User          suser.UserService
	Env           senv.EnvService
}

type WorkspaceServiceRPCStreamers struct {
	Workspace   eventstream.SyncStreamer[WorkspaceTopic, WorkspaceEvent]
	Environment eventstream.SyncStreamer[renv.EnvironmentTopic, renv.EnvironmentEvent]
}

type WorkspaceTopic struct {
	WorkspaceID idwrap.IDWrap
}